Compartir a través de


aio Paquete

Clases

BlobClient

Un cliente para interactuar con un blob específico, aunque es posible que ese blob aún no exista.

BlobLeaseClient

Crea un nuevo BlobLeaseClient.

Este cliente proporciona operaciones de concesión en BlobClient o ContainerClient.

BlobPrefix

Iterable de propiedades de blob.

Se devuelve de walk_blobs cuando se usa un delimitador. Se puede considerar como un directorio de blobs virtuales.

BlobServiceClient

Un cliente para interactuar con Blob Service en el nivel de cuenta.

Este cliente proporciona operaciones para recuperar y configurar las propiedades de la cuenta, así como enumerar, crear y eliminar contenedores dentro de la cuenta. En el caso de las operaciones relacionadas con un contenedor o blob específico, los clientes de esas entidades también se pueden recuperar mediante las funciones get_client .

ContainerClient

Un cliente para interactuar con un contenedor específico, aunque es posible que ese contenedor aún no exista.

Para las operaciones relacionadas con un blob específico dentro de este contenedor, se puede recuperar un cliente de blobs mediante la get_blob_client función .

ExponentialRetry

Reintento exponencial.

Construye un objeto de reintento exponencial. El initial_backoff se usa para el primer reintento. Los reintentos posteriores se reintentan después de initial_backoff + increment_power^retry_count segundos. Por ejemplo, de forma predeterminada, el primer reintento se produce después de 15 segundos, el segundo después de (15+3^1) = 18 segundos y el tercero después (15+3^2) = 24 segundos.

LinearRetry

Reintento lineal.

Construye un objeto de reintento lineal.

StorageStreamDownloader

Objeto de streaming que se va a descargar de Azure Storage.

Funciones

download_blob_from_url

Descargue el contenido de un blob en un archivo o secuencia local.

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

Parámetros

blob_url
str
Requerido

Identificador URI completo del blob. Esto también puede incluir un token de SAS.

output
str o <xref:<xref:writable stream>>
Requerido

Dónde se deben descargar los datos. Puede tratarse de una ruta de acceso de archivo en la que escribir o un identificador de E/S abierto en el que se va a escribir.

credential
valor predeterminado: None

Credenciales con las que se va a autenticar. Esto es opcional si la dirección URL del blob ya tiene un token de SAS o el blob es público. El valor puede ser una cadena de token de SAS, una instancia de AzureSasCredential o AzureNamedKeyCredential de azure.core.credentials, una clave de acceso compartido de cuenta o una instancia de una clase TokenCredentials de azure.identity. Si el URI del recurso ya contiene un token de SAS, se omitirá en favor de una credencial explícita.

  • excepto en el caso de AzureSasCredential, donde los tokens de SAS en conflicto generarán un valor ValueError. Si usa una instancia de AzureNamedKeyCredential, "name" debe ser el nombre de la cuenta de almacenamiento y "key" debe ser la clave de la cuenta de almacenamiento.
overwrite
bool

Si el archivo local debe sobrescribirse si ya existe. El valor predeterminado es False , en cuyo caso se generará un ValorError si el archivo ya existe. Si se establece en True, se intentará escribir en el archivo existente. Si se pasa un identificador de secuencia, este valor se omite.

max_concurrency
int

Número de conexiones paralelas con las que se va a descargar.

offset
int

Inicio del intervalo de bytes que se va a usar para descargar una sección del blob. Debe establecerse si se proporciona longitud.

length
int

Número de bytes que se van a leer de la secuencia. Esto es opcional, pero debe proporcionarse para obtener un rendimiento óptimo.

validate_content
bool

Si es true, calcula un hash MD5 para cada fragmento del blob. El servicio de almacenamiento comprueba el hash del contenido que ha llegado con el hash que se envió. Esto es principalmente útil para detectar bitflips en la conexión si el uso de http en lugar de https como https (el valor predeterminado) ya se validará. Tenga en cuenta que este hash MD5 no se almacena con el blob. Tenga en cuenta también que si está habilitado, no se usará el algoritmo de carga eficaz para memoria, ya que calcular el hash MD5 requiere almacenar en búfer bloques completos y, al hacerlo, se anula el propósito del algoritmo eficiente en memoria.

Tipo de valor devuelto

upload_blob_to_url

Carga de datos en una dirección URL determinada

Los datos se cargarán como un blob en bloques.

param str blob_url: el URI completo del blob. Esto también puede incluir un token de SAS.

datos param: los datos que se van a cargar. Puede ser bytes, texto, un objeto iterable o similar a un archivo.

datos de tipo: bytes o str o 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]

Parámetros

credential
valor predeterminado: None

Credenciales con las que se va a autenticar. Esto es opcional si la dirección URL del blob ya tiene un token de SAS. El valor puede ser una cadena de token de SAS, una instancia de AzureSasCredential o AzureNamedKeyCredential de azure.core.credentials, una clave de acceso compartido de cuenta o una instancia de una clase TokenCredentials de azure.identity. Si el URI del recurso ya contiene un token de SAS, se omitirá en favor de una credencial explícita.

  • excepto en el caso de AzureSasCredential, donde los tokens de SAS en conflicto generarán un valor ValueError. Si usa una instancia de AzureNamedKeyCredential, "name" debe ser el nombre de la cuenta de almacenamiento y "key" debe ser la clave de la cuenta de almacenamiento.

credencial paramtype: Optional[Union[str, Dict[str, str], AzureNamedKeyCredential, AzureSasCredential, "TokenCredential"]] # pylint: disable=line-too-long

palabra clave bool overwrite: indica si el blob que se va a cargar debe sobrescribir los datos actuales. Si es True, upload_blob_to_url sobrescribirá los datos existentes. Si se establece en False, se producirá un error en la operación con un resourceExistsError.

palabra clave int max_concurrency: número de conexiones paralelas con las que se va a descargar.

keyword int length: número de bytes que se van a leer de la secuencia. Esto es opcional, pero debe proporcionarse para obtener un rendimiento óptimo.

metadatos de palabra clave dict(str,str): pares nombre-valor asociados al blob como metadatos.

palabra clave bool validate_content: si es true, calcula un hash MD5 para cada fragmento del blob. El servicio de almacenamiento comprueba el hash del contenido que ha llegado con el hash que se envió. Esto es principalmente útil para detectar bitflips en la conexión si el uso de http en lugar de https como https (el valor predeterminado) ya se validará. Tenga en cuenta que este hash MD5 no se almacena con el blob. Tenga en cuenta también que si está habilitado, no se usará el algoritmo de carga eficaz para memoria, ya que calcular el hash MD5 requiere almacenar en búfer bloques completos y, al hacerlo, se anula el propósito del algoritmo eficiente en memoria.

codificación str de palabra clave: codificación que se va a usar si se proporciona texto como entrada. El valor predeterminado es UTF-8.

returns: Dict de propiedad actualizada por blob (Etag y última modificación)

rtype: dict(str, Any)

blob_url
data