]h) vddlZddlmZmZmZmZmZmZmZm Z m Z ddl m Z ddl mZddlmZddlmZddlmZdd lmZdd lmZdd lmZmZmZdd lmZmZdd l m!Z!ddl"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(ddl)m*Z*ddl+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFmGZGmHZHmIZImJZJmKZKmLZLmMZMddlNmOZOe r ddlPmQZQmRZRmSZSe ZT d"deUde eeeefdee eUeeUeUfdddfdedeeUeff dZVdedeeWdeddfdZX d"deUde eUeeWfdee eUeeUeUfdddfdeddf d ZYgd!ZZy)#N) AnyAnyStrcastDictIOIterableOptionalUnion TYPE_CHECKING)VERSION) BlobClient)ContainerClient)BlobServiceClient)BlobLeaseClient)StorageStreamDownloader)BlobQueryReader)generate_account_sasgenerate_container_sasgenerate_blob_sas)ExponentialRetry LinearRetry)PartialBatchErrorException) LocationMode ResourceTypesAccountSasPermissionsStorageErrorCodeUserDelegationKeyServices)RehydratePriority)"BlobType BlockStateStandardBlobTierPremiumPageBlobTierBlobImmutabilityPolicyModeSequenceNumberAction PublicAccessBlobAnalyticsLoggingMetricsRetentionPolicy StaticWebsiteCorsRuleContainerPropertiesBlobProperties FilteredBlobLeasePropertiesContentSettingsCopyProperties BlobBlock PageRange AccessPolicyContainerSasPermissionsBlobSasPermissionsCustomerProvidedEncryptionKeyContainerEncryptionScopeBlobQueryErrorDelimitedJsonDialectDelimitedTextDialectQuickQueryDialect ArrowDialect ArrowTypeObjectReplicationPolicyObjectReplicationRuleImmutabilityPolicy) BlobPrefix)AzureNamedKeyCredentialAzureSasCredentialTokenCredentialblob_urldata credentialrDrErFkwargsreturnc tj||5}tt|jd|tj d|cdddS#1swYyxYw)a Upload data to a given URL The data will be uploaded as a block blob. :param str blob_url: The full URI to the blob. This can also include a SAS token. :param data: The data to upload. This can be bytes, text, an iterable or a file-like object. :type data: bytes or str or Iterable :param credential: The credentials with which to authenticate. This is optional if the blob URL already has a SAS token. The value can be a SAS token string, an instance of a AzureSasCredential or AzureNamedKeyCredential from azure.core.credentials, an account shared access key, or an instance of a TokenCredentials class from azure.identity. If the resource URI already contains a SAS token, this will be ignored in favor of an explicit credential - except in the case of AzureSasCredential, where the conflicting SAS tokens will raise a ValueError. If using an instance of AzureNamedKeyCredential, "name" should be the storage account name, and "key" should be the storage account key. :type credential: ~azure.core.credentials.AzureNamedKeyCredential or ~azure.core.credentials.AzureSasCredential or ~azure.core.credentials.TokenCredential or str or dict[str, str] or None :keyword bool overwrite: Whether the blob to be uploaded should overwrite the current data. If True, upload_blob_to_url will overwrite any existing data. If set to False, the operation will fail with a ResourceExistsError. :keyword int max_concurrency: The number of parallel connections with which to download. :keyword int length: Number of bytes to read from the stream. This is optional, but should be supplied for optimal performance. :keyword dict(str,str) metadata: Name-value pairs associated with the blob as metadata. :keyword bool validate_content: If true, calculates an MD5 hash for each chunk of the blob. The storage service checks the hash of the content that has arrived with the hash that was sent. This is primarily valuable for detecting bitflips on the wire if using http instead of https as https (the default) will already validate. Note that this MD5 hash is not stored with the blob. Also note that if enabled, the memory-efficient upload algorithm will not be used, because computing the MD5 hash requires buffering entire blocks, and doing so defeats the purpose of the memory-efficient algorithm. :keyword str encoding: Encoding to use if text is supplied as input. Defaults to UTF-8. :returns: Blob-updated property dict (Etag and last modified) :rtype: dict(str, Any) rI)rH blob_typeN)r from_blob_urlr upload_blobr! BLOCKBLOB)rGrHrIrJclients a/var/www/core.comfia.cic-ware.com/crm/lib/python3.12/site-packages/azure/storage/blob/__init__.pyupload_blob_to_urlrUJsXl  ! !(z Bgf3tJ'33fI[I[f_efgggs 1AArShandlec J|jdi|}|j|y)z Download data to specified open file-handle. :param BlobClient client: The BlobClient to download with. :param Stream handle: A Stream to download the data into. NrO) download_blobreadinto)rSrVrJstreams rT_download_to_streamr[s%"V ! ! +F +F OOFoutputc |jdd}tj||5}t|dr#t |t t t|fi|nR|s.tjj|rtd|dt|d5}t ||fi|ddddddy#1swYxYw#1swYyxYw) a Download the contents of a blob to a local file or stream. :param str blob_url: The full URI to the blob. This can also include a SAS token. :param output: Where the data should be downloaded to. This could be either a file path to write to, or an open IO handle to write to. :type output: str or writable stream. :param credential: The credentials with which to authenticate. This is optional if the blob URL already has a SAS token or the blob is public. The value can be a SAS token string, an instance of a AzureSasCredential or AzureNamedKeyCredential from azure.core.credentials, an account shared access key, or an instance of a TokenCredentials class from azure.identity. If the resource URI already contains a SAS token, this will be ignored in favor of an explicit credential - except in the case of AzureSasCredential, where the conflicting SAS tokens will raise a ValueError. If using an instance of AzureNamedKeyCredential, "name" should be the storage account name, and "key" should be the storage account key. :type credential: ~azure.core.credentials.AzureNamedKeyCredential or ~azure.core.credentials.AzureSasCredential or ~azure.core.credentials.TokenCredential or str or dict[str, str] or None :keyword bool overwrite: Whether the local file should be overwritten if it already exists. The default value is `False` - in which case a ValueError will be raised if the file already exists. If set to `True`, an attempt will be made to write to the existing file. If a stream handle is passed in, this value is ignored. :keyword int max_concurrency: The number of parallel connections with which to download. :keyword int offset: Start of byte range to use for downloading a section of the blob. Must be set if length is provided. :keyword int length: Number of bytes to read from the stream. This is optional, but should be supplied for optimal performance. :keyword bool validate_content: If true, calculates an MD5 hash for each chunk of the blob. The storage service checks the hash of the content that has arrived with the hash that was sent. This is primarily valuable for detecting bitflips on the wire if using http instead of https as https (the default) will already validate. Note that this MD5 hash is not stored with the blob. Also note that if enabled, the memory-efficient upload algorithm will not be used, because computing the MD5 hash requires buffering entire blocks, and doing so defeats the purpose of the memory-efficient algorithm. :rtype: None overwriteFrMwritez The file 'z' already exists.wbN) poprrPhasattrr[rrbytesospathisfile ValueErroropen)rGr]rIrJr_rS file_handles rTdownload_blob_from_urlrksh ;.I  ! !(z BCf 67 # RY(? J6 J!7 :fX5F!GHHfd# C{#FKB6B C CC  C C CCs$A,CB5$C5B> :CC )8rUrkrrrr!rrrrrrr"r#r$r&r%rBr'r(r)r*r+r,r-r.rCr/r0r1r2r3r4r5r=r6r7rrrr8r rrrrr9r:r;r<r>r?rr@rAr)N)[retypingrrrrrrr r r _versionr _blob_clientr_container_clientr_blob_service_clientr_leaser _downloadr_quick_query_helperr_shared_access_signaturerrr_shared.policiesrr_shared.response_handlersr_shared.modelsrrrrrr_generated.modelsr _modelsr!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4r5r6r7r8r9r:r;r<r=r>r?r@rArB_list_blobs_helperrCazure.core.credentialsrDrErF __version__strrUrdr[rk__all__rOr\rTrs XXX$.3#.0ee;A1#########H+cc |@7g7g  "V*, -7gsDcN4MOcevvwx7g 7g  #s(^ 7gt BuIQU|@<C<C #r%y. !<CsDcN4MOcevvwx<C <C  <C~9 r\