Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/backends/__pycache__/couchdb.cpython-39.pyc
Ðазад
a t�hw � @ st d Z ddlmZ ddlmZ ddlmZ ddlmZ z ddl Z W n e yV dZ Y n0 dZ d Z G d d � d e�Z dS ) z CouchDB result store backend.� )� bytes_to_str)� _parse_url)�ImproperlyConfigured� )�KeyValueStoreBackendN)� CouchBackendzKYou need to install the pycouchdb library to use the CouchDB result backendc sn e Zd ZdZdZdZdZdZdZdZ d� fdd� Z d d � Z e d d � �Z d d� Zdd� Zdd� Zdd� Z� ZS )r z�CouchDB backend. Raises: celery.exceptions.ImproperlyConfigured: if module :pypi:`pycouchdb` is not available. �default�http� localhosti` Nc s� t � j|i |�� || _td u r(tt��d } } } } }} |rlt|�\} }}}}} } | rh| �d�nd } |pt| j| _|p�| j | _ t |p�| j �| _ | p�| j | _ |p�| j | _ |p�| j| _d | _d S )N�/)�super�__init__�url� pycouchdbr �ERR_LIB_MISSINGr �strip�scheme�host�int�port� container�username�password� _connection) �selfr �args�kwargsZuschemeZuhostZuport�unameZupassZ ucontainer�_�� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/backends/couchdb.pyr $ s zCouchBackend.__init__c C s� | j rF| jrF| j� d| j � d| j� d| j� d| j� � }tj|dd�}n$| j� d| j� d| j� �}t�|�}z|�| j�W S tj j y� |� | j� Y S 0 dS )z Connect to the CouchDB server.z://�:�@�basic)Z authmethodN) r r r r r r �ServerZdatabaser � exceptions�NotFound�create)r Z conn_string�serverr! r! r" �_get_connection9 s * z CouchBackend._get_connectionc C s | j d u r| �� | _ | j S �N)r r+ �r r! r! r" � connectionG s zCouchBackend.connectionc C s8 t |�}z| j�|�d W S tjjy2 Y d S 0 d S )N�value)r r. �getr r' r( �r �keyr! r! r" r0 M s zCouchBackend.getc C s^ t |�}||d�}z| j�|� W n6 tjjyX | j�|�}||d< | j�|� Y n0 d S )N)Z_idr/ r/ )r r. �saver r' �Conflictr0 )r r2 r/ �datar! r! r" �setT s zCouchBackend.setc s � fdd�|D �S )Nc s g | ]}� � |��qS r! )r0 )�.0r2 r- r! r" � <listcomp>` � z%CouchBackend.mget.<locals>.<listcomp>r! )r �keysr! r- r" �mget_ s zCouchBackend.mgetc C s | j �|� d S r, )r. �deleter1 r! r! r" r< b s zCouchBackend.delete)N)�__name__� __module__� __qualname__�__doc__r r r r r r r r+ �propertyr. r0 r6 r; r< � __classcell__r! r! r r" r s r )r@ Zkombu.utils.encodingr Zkombu.utils.urlr Zcelery.exceptionsr �baser r � ImportError�__all__r r r! r! r! r" �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка