Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/backends/__pycache__/consul.cpython-39.pyc
Ðазад
a t�h� � @ s� d Z ddlmZ ddlmZ ddlmZ ddlmZ ddl m Z z ddl Z W n e yb dZ Y n0 e e �ZdZd ZG d d � d e�ZdS ) z�Consul result store backend. - :class:`ConsulBackend` implements KeyValueStoreBackend to store results in the key-value store of Consul. � )� bytes_to_str)� parse_url)�KeyValueStoreBackend)�ImproperlyConfigured)� get_loggerN)� ConsulBackendz^You need to install the python-consul library in order to use the Consul result store backend.c sh e Zd ZdZeZdZdZdZ� fdd�Zdd� Z d d � Z d d � Z d d� Z dd� Z dd� Zdd� Z� ZS )r z'Consul.io K/V store backend for Celery.TZ consistentNc sD t � j|i |�� | jd u r$tt��d | _| jf i t| j��� d S �N) �super�__init__�consulr �CONSUL_MISSING� one_client�_init_from_paramsr �url)�self�args�kwargs�� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/backends/consul.pyr % s zConsulBackend.__init__c K s: t �d||� || _|| _|| _|�dd �r6| �� | _d S )Nz,Setting on Consul client to connect to %s:%dr )�logger�debug�path�hostname�port�get�clientr )r r r Z virtual_host�paramsr r r r 3 s � z ConsulBackend._init_from_paramsc C s | j ptj| j| j| jd�S )N)�hostr � consistency)r r ZConsulr r r )r r r r r A s �zConsulBackend.clientc C s& t |�}| jd u r|S | j� d|� �S )N�/)r r �r �keyr r r �_key_to_consul_keyF s z ConsulBackend._key_to_consul_keyc C sL | � |�}t�d|� z | �� j�|�\}}|d W S tyF Y n0 d S )Nz"Trying to fetch key %s from Consul�Value)r$ r r r �kvr � TypeError)r r# �_�datar r r r J s zConsulBackend.getc c s |D ]}| � |�V qd S r )r )r �keysr# r r r �mgetS s zConsulBackend.mgetc C sh t |�}| �|�}t�d|| j� | �� }|jj|d| jd�}t�d|� t�d|� |jj |||d�S )aM Set a key in Consul. Before creating the key it will create a session inside Consul where it creates a session with a TTL The key created afterwards will reference to the session's ID. If the session expires it will remove the key so that results can auto expire from the K/V store z.Trying to create Consul session %s with TTL %d�delete)�nameZbehavior�ttlzCreated Consul session %szWriting key %s to Consul)r# �value�acquire) r r$ r r �expiresr �session�creater& �put)r r# r/ Z session_namer Z session_idr r r �setW s �� zConsulBackend.setc C s& | � |�}t�d|� | �� j�|�S )NzRemoving key %s from Consul)r$ r r r r& r, r" r r r r, q s zConsulBackend.delete)�__name__� __module__� __qualname__�__doc__r Zsupports_autoexpirer r r r r r$ r r+ r5 r, � __classcell__r r r r r s r )r9 Zkombu.utils.encodingr Zkombu.utils.urlr Zcelery.backends.baser Zcelery.exceptionsr Zcelery.utils.logr r � ImportErrorr6 r �__all__r r r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка