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
Erforderlich

Der vollständige URI für das Blob. Dies kann auch ein SAS-Token enthalten.

output
str oder <xref:<xref:writable stream>>
Erforderlich

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
Standardwert: None

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
Standardwert: None

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