File: //usr/local/lib/python3.9/site-packages/celery/backends/__pycache__/cosmosdbsql.cpython-39.pyc
a
X>hy � @ s� d Z ddlmZ ddlmZ ddlmZ ddlmZ ddl m
Z
ddl m Z zDdd l
Z
dd
lmZ dd lmZmZmZ dd lmZ dd
lmZ W n. ey� d Z
Z Z Z Z ZZY n0 dZdZdZe
e �Z G dd� de �Z d S )z3The CosmosDB/SQL backend for Celery (experimental).� )�cached_property)� bytes_to_str)�
_parse_url)�ImproperlyConfigured)�
get_logger� )�KeyValueStoreBackendN)�DocumentClient)�ConnectionPolicy�ConsistencyLevel�
PartitionKind)� HTTPFailure)� RetryOptions)�CosmosDBSQLBackendi� i� c s� e Zd ZdZd � fdd� Zedd� �Zedd� �Zd d
� Z d d � Z
ed
d� �Z edd� �Z dd� Z
edd� �Zdd� Zdd� Zdd� Zdd � Z� ZS ) r z CosmosDB/SQL backend for Celery.Nc
s� t � j|i |�� td u r"td��| jj} | �|�\| _| _|pF| d | _ |pT| d | _
zt t |ph| d �| _
W n ty� td��Y n0 |p�| d | _|p�| d | _d S )NzIYou need to install the pydocumentdb library to use the CosmosDB backend.Zcosmosdbsql_database_nameZcosmosdbsql_collection_nameZ cosmosdbsql_consistency_levelz"Unknown CosmosDB consistency levelZ cosmosdbsql_max_retry_attemptsZ cosmosdbsql_max_retry_wait_time)�super�__init__� pydocumentdbr Zapp�confr � _endpoint�_key�_database_name�_collection_name�getattrr �_consistency_level�AttributeError�_max_retry_attempts�_max_retry_wait_time)
�self�urlZ
database_nameZcollection_name�consistency_levelZmax_retry_attemptsZmax_retry_wait_time�args�kwargsr �� __class__� �E/usr/local/lib/python3.9/site-packages/celery/backends/cosmosdbsql.pyr ! s6 ����
��zCosmosDBSQLBackend.__init__c C sZ t |�\}}}}}}}|r |s&td��|s.d}|dkr:dnd}|� d|� d|� �}||fS )Nz Invalid URLi� �https�httpz://�:)r r )�clsr �_�host�port�password�schemeZendpointr$ r$ r% r M s z CosmosDBSQLBackend._parse_urlc C sJ t � }t| j| jd�|_t| jd| ji|| jd�}| �|� | � |� |S )z�Return the CosmosDB/SQL client.
If this is the first call to the property, the client is created and
the database and collection are initialized if they don't yet exist.
)Zmax_retry_attempt_countZmax_wait_time_in_secondsZ masterKey)�connection_policyr )
r
r r r r r r r � _create_database_if_not_exists� _create_collection_if_not_exists)r r/ �clientr$ r$ r% �_client[ s ��
zCosmosDBSQLBackend._clientc
C sX z|� d| ji� W n0 tyD } z|jtkr0� W Y d }~nd }~0 0 t�d| j� d S )N�idz Created CosmosDB database %s)ZCreateDatabaser r
� status_code� ERROR_EXISTS�LOGGER�info�r r2 �exr$ r$ r% r0 s s
�z1CosmosDBSQLBackend._create_database_if_not_existsc
C sl z$|� | j| jdgtjd�d�� W n0 tyT } z|jtkr@� W Y d }~n d }~0 0 t� d| j
| j� d S )Nz/id)�paths�kind)r4 � partitionKeyz!Created CosmosDB collection %s/%s) ZCreateCollection�_database_linkr r ZHashr
r5 r6 r7 r8 r r9 r$ r$ r% r1 } s ���
�z3CosmosDBSQLBackend._create_collection_if_not_existsc C s
d| j S )Nzdbs/)r �r r$ r$ r% r> � s z!CosmosDBSQLBackend._database_linkc C s | j d | j S )Nz/colls/)r> r r? r$ r$ r% �_collection_link� s z#CosmosDBSQLBackend._collection_linkc C s | j d | S )Nz/docs/)r@ �r �keyr$ r$ r% �_get_document_link� s z%CosmosDBSQLBackend._get_document_linkc C s |r |� � rtd��d|iS )Nz(Key cannot be none, empty or whitespace.r= )�isspace�
ValueError)r) rB r$ r$ r% �_get_partition_key� s z%CosmosDBSQLBackend._get_partition_keyc
C s| t |�}t�d| j| j|� z | j�| �|�| �|��}W n2 t yl } z|j
t krV� W Y d}~dS d}~0 0 |� d�S dS )zxRead the value stored at the given key.
Args:
key: The key for which to read the value.
z"Getting CosmosDB document %s/%s/%sN�value)
r r7 �debugr r r3 Z ReadDocumentrC rF r
r5 �ERROR_NOT_FOUND�get)r rB �documentr: r$ r$ r% rJ � s
��
zCosmosDBSQLBackend.getc C s> t |�}t�d| j| j|� | j�| j||d�| �|�� dS )z�Store a value for a given key.
Args:
key: The key at which to store the value.
value: The value to store.
z#Creating CosmosDB document %s/%s/%s)r4 rG N) r r7 rH r r r3 ZCreateDocumentr@ rF )r rB rG r$ r$ r% �set� s
��zCosmosDBSQLBackend.setc s � fdd�|D �S )zqRead all the values for the provided keys.
Args:
keys: The list of keys to read.
c s g | ]}� � |��qS r$ )rJ )�.0rB r? r$ r% �
<listcomp>� � z+CosmosDBSQLBackend.mget.<locals>.<listcomp>r$ )r �keysr$ r? r% �mget� s zCosmosDBSQLBackend.mgetc C s: t |�}t�d| j| j|� | j�| �|�| �|�� dS )zlDelete the value at a given key.
Args:
key: The key of the value to delete.
z#Deleting CosmosDB document %s/%s/%sN) r r7 rH r r r3 ZDeleteDocumentrC rF rA r$ r$ r% �delete� s
��zCosmosDBSQLBackend.delete)NNNNNN)�__name__�
__module__� __qualname__�__doc__r � classmethodr r r3 r0 r1 r> r@ rC rF rJ rL rQ rR �
__classcell__r$ r$ r" r% r s2 �,
r ) rV Z kombu.utilsr Zkombu.utils.encodingr Zkombu.utils.urlr Zcelery.exceptionsr Zcelery.utils.logr �baser r Z pydocumentdb.document_clientr Zpydocumentdb.documentsr
r r Zpydocumentdb.errorsr
Zpydocumentdb.retry_optionsr � ImportError�__all__rI r6 rS r7 r r$ r$ r$ r% �<module> s0 ���