a xd@sdZddlmZddlmZddlmZddlmZddl m Z z2ddl m m Zdd lmZmZdd l mZWneydZYn0d ZeeZGd d d e ZdS)z0The Azure Storage Block Blob backend for Celery.)cached_property) bytes_to_str)ImproperlyConfigured) get_logger)KeyValueStoreBackendN)ResourceExistsErrorResourceNotFoundError)BlobServiceClient)AzureBlockBlobBackendcs\eZdZdZdfdd ZedddZedd Zd d Z d d Z ddZ ddZ Z S)r z,Azure Storage Block Blob backend for Celery.Ncs`tj|i|tdus$tjdkr,td|jj}|||_|pJ|d|_ | dd|_ dS)NZ12zWYou need to install the azure-storage-blob v12 library touse the AzureBlockBlob backendZazureblockblob_container_nameZazureblockblob_base_path) super__init__ azurestorage __version__rZappconf _parse_url_connection_string_container_nameget base_path)selfurlZcontainer_nameargskwargsr __class__V/var/www/html/Ranjet/env/lib/python3.9/site-packages/celery/backends/azureblockblob.pyrs zAzureBlockBlobBackend.__init__azureblockblob://cCs |t|d}|std|S)Nz Invalid URL)lenr)clsrprefixZconnection_stringrrrr0sz AzureBlockBlobBackend._parse_urlcCs\t|j}z |j|jdd|jd}Wn tyLd|jd}Yn0t||S)zReturn the Azure Storage Blob service client. If this is the first call to the property, the client is created and the container is created if it doesn't yet exist. )namezContainer created with name .zContainer with name z* already.exists. This will not be created.)r Zfrom_connection_stringrZcreate_containerrrLOGGERinfo)rclientmsgrrr_blob_service_client8s   z*AzureBlockBlobBackend._blob_service_clientcCs`t|}td|j||jj|j|j|d}z| WSt yZYdS0dS)zwRead the value stored at the given key. Args: key: The key for which to read the value. zGetting Azure Block Blob %s/%s containerblobN) rr%debugrr)get_blob_clientrZ download_blobreadalldecoder rkey blob_clientrrrrLs  zAzureBlockBlobBackend.getcCsNt|}td|jd||jj|j|j|d}|j|dddS)zStore a value for a given key. Args: key: The key at which to store the value. value: The value to store. zCreating azure blob at /r*T) overwriteN)rr%r-rr)r.rZ upload_blob)rr2valuer3rrrset_s zAzureBlockBlobBackend.setcsfdd|DS)zqRead all the values for the provided keys. Args: keys: The list of keys to read. csg|]}|qSr)r).0r2rrr xz.AzureBlockBlobBackend.mget..r)rkeysrr9rmgetqszAzureBlockBlobBackend.mgetcCsHt|}td|jd||jj|j|j|d}|dS)zlDelete the value at a given key. Args: key: The key of the value to delete. zDeleting azure blob at r4r*N)rr%r-rr)r.rZ delete_blobr1rrrdeletezs zAzureBlockBlobBackend.delete)NN)r)__name__ __module__ __qualname____doc__r classmethodrrr)rr7r=r> __classcell__rrrrr s   r )rBZ kombu.utilsrZkombu.utils.encodingrZcelery.exceptionsrZcelery.utils.logrbaserZazure.storage.blobZstorager,rZazure.core.exceptionsrr r ImportError__all__r?r%r rrrrs