Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/backends/__pycache__/cosmosdbsql.cpython-39.pyc
Ðазад
a t�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__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/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 Zdocumentr: 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 rK rP rQ � __classcell__r$ r$ r" r% r s2 �, r ) rU 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 rR r7 r r$ r$ r$ r% �<module> s0 ���
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка