o wvXj@sdZddlmZmZddlmZddlmZddlm Z ddl m Z ddl m Z zdd lmZdd lmZdd lmZdd lmZWneySd ZZZZYnwd Ze eZGddde Zd S)z0The Azure Storage Block Blob backend for Celery.)absolute_importunicode_literals)cached_property) bytes_to_str)ImproperlyConfigured) get_logger)KeyValueStoreBackendN)AzureMissingResourceHttpError)BlockBlobService)ExponentialRetry)AzureBlockBlobBackendcsfeZdZdZ     dfdd ZedddZedd Zd d Z d d Z ddZ ddZ Z S)r z,Azure Storage Block Blob backend for Celery.Nc svtt|j|i|tdurtd|jj}|||_|p"|d|_ |p)|d|_ |p0|d|_ |p7|d|_ dS)NzOYou need to install the azure-storage library to use the AzureBlockBlob backendazureblockblob_container_name(azureblockblob_retry_initial_backoff_sec#azureblockblob_retry_increment_base!azureblockblob_retry_max_attempts) superr __init__ azurestoragerappconf _parse_url_connection_string_container_name_retry_initial_backoff_sec_retry_increment_base_retry_max_attempts) selfurlcontainer_nameretry_initial_backoff_secretry_increment_baseretry_max_attemptsargskwargsr __class__[/var/www/html/myproject/venv/lib/python3.10/site-packages/celery/backends/azureblockblob.pyrs& zAzureBlockBlobBackend.__init__azureblockblob://cCs |t|d}|std|S)Nz Invalid URL)lenr)clsrprefixconnection_stringr'r'r(r@sz AzureBlockBlobBackend._parse_urlcCsJt|jd}|j|jdd}|rtd|jt|j|j|j dj |_ |S)zReturn the Azure Storage Block Blob service. If this is the first call to the property, the client is created and the container is created if it doesn't yet exist. )r-F)r fail_on_existz'Created Azure Blob Storage container %s)initial_backoffincrement_base max_attempts) r rcreate_containerrLOGGERinfor rrrretry)rclientcreatedr'r'r(_clientHs zAzureBlockBlobBackend._clientcCsBt|}td|j|z |j|j|jWSty YdSw)zxRead the value stored at the given key. Args: key: The key for which to read the value. zGetting Azure Block Blob %s/%sN)rr3debugrr8get_blob_to_textcontentr rkeyr'r'r(get`s zAzureBlockBlobBackend.getcCs*t|}td|j||j|j||S)zStore a value for a given key. Args: key: The key at which to store the value. value: The value to store. z"Creating Azure Block Blob at %s/%s)rr3r9rr8create_blob_from_text)rr=valuestater'r'r(setqszAzureBlockBlobBackend.setcsfdd|DS)zqRead all the values for the provided keys. Args: keys: The list of keys to read. csg|]}|qSr')r>).0r=rr'r( sz.AzureBlockBlobBackend.mget..r')rkeysr'rDr(mgetszAzureBlockBlobBackend.mgetcCs,t|}td|j||j|j|dS)zlDelete the value at a given key. Args: key: The key of the value to delete. z"Deleting Azure Block Blob at %s/%sN)rr3r9rr8 delete_blobr<r'r'r(deletes zAzureBlockBlobBackend.delete)NNNNN)r))__name__ __module__ __qualname____doc__r classmethodrrr8r>rBrGrI __classcell__r'r'r%r(r s #   r )rM __future__rr kombu.utilsrkombu.utils.encodingrcelery.exceptionsrcelery.utils.logrbaser azure.storagestorager azure.commonr azure.storage.blobr azure.storage.common.retryr ImportError__all__rJr3r r'r'r'r(s(