aio Paket
Klassen
BlobClient |
Ein Client, der mit einem bestimmten Blob interagiert, obwohl dieses Blob möglicherweise noch nicht vorhanden ist. |
BlobLeaseClient |
Erstellt einen neuen BlobLeaseClient. Dieser Client stellt Leasevorgänge für einen BlobClient oder ContainerClient bereit. |
BlobPrefix |
Eine Iterable von Blobeigenschaften. Wird von walk_blobs zurückgegeben, wenn ein Trennzeichen verwendet wird. Kann als virtuelles Blobverzeichnis betrachtet werden. |
BlobServiceClient |
Ein Client für die Interaktion mit dem Blobdienst auf Kontoebene. Dieser Client bietet Vorgänge zum Abrufen und Konfigurieren der Kontoeigenschaften sowie zum Auflisten, Erstellen und Löschen von Containern innerhalb des Kontos. Bei Vorgängen im Zusammenhang mit einem bestimmten Container oder Blob können Clients für diese Entitäten auch mithilfe der get_client-Funktionen abgerufen werden. |
ContainerClient |
Ein Client, der mit einem bestimmten Container interagiert, obwohl dieser Container möglicherweise noch nicht vorhanden ist. Für Vorgänge, die sich auf ein bestimmtes Blob in diesem Container beziehen, kann ein Blobclient mithilfe der get_blob_client -Funktion abgerufen werden. |
ExponentialRetry |
Exponentielle Wiederholung. Erstellt ein Exponentielles Wiederholungsobjekt. Die initial_backoff wird für den ersten Wiederholungsversuch verwendet. Nachfolgende Wiederholungsversuche werden nach initial_backoff + increment_power^retry_count Sekunden wiederholt. Beispielsweise erfolgt der erste Wiederholungsversuch standardmäßig nach 15 Sekunden, der zweite nach (15+3^1) = 18 Sekunden und der dritte nach (15+3^2) = 24 Sekunden. |
LinearRetry |
Linearer Wiederholungsversuch. Erstellt ein Linear-Wiederholungsobjekt. |
StorageStreamDownloader |
Ein Streamingobjekt, das aus Azure Storage heruntergeladen werden soll. |
Functions
download_blob_from_url
Laden Sie den Inhalt eines Blobs in eine lokale Datei oder einen lokalen Stream herunter.
async download_blob_from_url(blob_url: str, output: str, credential: Optional[Union[str, Dict[str, str], AzureNamedKeyCredential, AzureSasCredential, "TokenCredential"]] # pylint: disable=line-too-long = None, **kwargs) -> None
Parameter
- blob_url
- str
Der vollständige URI für das Blob. Dies kann auch ein SAS-Token enthalten.
- output
- str oder <xref:<xref:writable stream>>
Wo die Daten heruntergeladen werden sollen. Dies kann entweder ein Dateipfad sein, in den geschrieben werden soll, oder ein geöffnetes E/A-Handle, in das geschrieben werden soll.
- credential
Die Anmeldeinformationen, mit denen die Authentifizierung erfolgt. Dies ist optional, wenn die Blob-URL bereits über ein SAS-Token verfügt oder das Blob öffentlich ist. Der Wert kann eine SAS-Tokenzeichenfolge, eine instance eines AzureSasCredential- oder AzureNamedKeyCredential-Elements von azure.core.credentials, ein kontofreigaber Zugriffsschlüssel oder ein instance einer TokenCredentials-Klasse aus azure.identity sein. Wenn der Ressourcen-URI bereits ein SAS-Token enthält, wird dies zugunsten einer expliziten Anmeldeinformation ignoriert.
- außer im Fall von AzureSasCredential, bei dem die in Konflikt stehenden SAS-Token einen ValueError auslösen. Wenn Sie eine instance von AzureNamedKeyCredential verwenden, sollte "name" der Name des Speicherkontos und "key" der Speicherkontoschlüssel sein.
- overwrite
- bool
Gibt an, ob die lokale Datei überschrieben werden soll, wenn sie bereits vorhanden ist. Der Standardwert ist False . In diesem Fall wird ein ValueError ausgelöst, wenn die Datei bereits vorhanden ist. Wenn dieser Wert auf True festgelegt ist, wird versucht, in die vorhandene Datei zu schreiben. Wenn ein Streamhandle übergeben wird, wird dieser Wert ignoriert.
- max_concurrency
- int
Die Anzahl der parallelen Verbindungen, mit denen heruntergeladen werden soll.
- offset
- int
Anfang des Bytebereichs, der zum Herunterladen eines Abschnitts des Blobs verwendet werden soll. Muss festgelegt werden, wenn die Länge angegeben wird.
- length
- int
Anzahl der Bytes, die aus dem Stream gelesen werden sollen. Dies ist optional, sollte aber für eine optimale Leistung bereitgestellt werden.
- validate_content
- bool
Wenn true, berechnet einen MD5-Hash für jeden Block des Blobs. Der Speicherdienst überprüft den Hash des Inhalts, der mit dem gesendeten Hash eingetroffen ist. Dies ist in erster Linie hilfreich für die Erkennung von Bitflips im Netzwerk, wenn http anstelle von https als https (standard) bereits überprüft wird. Beachten Sie, dass dieser MD5-Hash nicht mit dem BLOB gespeichert wird. Beachten Sie auch, dass der speichereffiziente Uploadalgorithmus bei Aktivierter nicht verwendet wird, da das Berechnen des MD5-Hashs das Puffern ganzer Blöcke erfordert und dies den Zweck des speichereffizienten Algorithmus verfehlt.
Rückgabetyp
upload_blob_to_url
Hochladen von Daten in eine angegebene URL
Die Daten werden als Blockblob hochgeladen.
param str blob_url: Der vollständige URI für das Blob. Dies kann auch ein SAS-Token enthalten.
param-Daten: Die hochzuladenden Daten. Dies können Bytes, Text, ein iterierbares oder ein dateiähnliches Objekt sein.
Typdaten: Bytes oder str oder Iterable
async upload_blob_to_url(blob_url: str, data: Union[Iterable[AnyStr], IO[AnyStr]], credential: Optional[Union[str, Dict[str, str], AzureNamedKeyCredential, AzureSasCredential, "TokenCredential"]] # pylint: disable=line-too-long = None, **kwargs) -> dict[str, Any]
Parameter
- credential
Die Anmeldeinformationen, mit denen die Authentifizierung erfolgt. Dies ist optional, wenn die Blob-URL bereits über ein SAS-Token verfügt. Der Wert kann eine SAS-Tokenzeichenfolge, eine instance eines AzureSasCredential- oder AzureNamedKeyCredential-Elements von azure.core.credentials, ein kontofreigaber Zugriffsschlüssel oder ein instance einer TokenCredentials-Klasse aus azure.identity sein. Wenn der Ressourcen-URI bereits ein SAS-Token enthält, wird dies zugunsten einer expliziten Anmeldeinformation ignoriert.
- außer im Fall von AzureSasCredential, bei dem die in Konflikt stehenden SAS-Token einen ValueError auslösen. Wenn Sie eine instance von AzureNamedKeyCredential verwenden, sollte "name" der Name des Speicherkontos und "key" der Speicherkontoschlüssel sein.
Paramtype-Anmeldeinformationen: Optional[Union[str, Dict[str, str], AzureNamedKeyCredential, AzureSasCredential, "TokenCredential"]] # pylint: disable=line-too-long
Schlüsselwort (keyword) bool overwrite: Gibt an, ob das hochzuladende Blob die aktuellen Daten überschreiben soll. Bei True überschreibt upload_blob_to_url alle vorhandenen Daten. Wenn dieser Wert auf False festgelegt ist, schlägt der Vorgang mit einem ResourceExistsError-Element fehl.
Schlüsselwort (keyword) int max_concurrency: Die Anzahl der parallelen Verbindungen, mit denen heruntergeladen werden soll.
Schlüsselwort (keyword) länge int: Anzahl der Bytes, die aus dem Stream gelesen werden sollen. Dies ist optional, sollte aber für eine optimale Leistung bereitgestellt werden.
Schlüsselwort (keyword) dict(str,str)-Metadaten: Name-Wert-Paare, die dem Blob als Metadaten zugeordnet sind.
Schlüsselwort (keyword) bool validate_content: Wenn true, berechnet einen MD5-Hash für jeden Block des Blobs. Der Speicherdienst überprüft den Hash des Inhalts, der mit dem gesendeten Hash eingetroffen ist. Dies ist in erster Linie hilfreich für die Erkennung von Bitflips im Netzwerk, wenn http anstelle von https als https (standard) bereits überprüft wird. Beachten Sie, dass dieser MD5-Hash nicht mit dem BLOB gespeichert wird. Beachten Sie auch, dass der speichereffiziente Uploadalgorithmus bei Aktivierter nicht verwendet wird, da das Berechnen des MD5-Hashs das Puffern ganzer Blöcke erfordert und dies den Zweck des speichereffizienten Algorithmus verfehlt.
Schlüsselwort (keyword) str-Codierung: Codierung, die verwendet werden soll, wenn Text als Eingabe bereitgestellt wird. Der Standardwert ist UTF-8.
returns: Blob-update property dict (Etag und letzte Änderung)
rtype: dict(str, Any)
- blob_url
- data
Azure SDK for Python