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
Identificador URI completo del blob. Esto también puede incluir un token de SAS.
- output
- str o <xref:<xref:writable stream>>
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
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
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
Azure SDK for Python