Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/kombu/transport/__pycache__/etcd.cpython-39.pyc
Ðазад
a o�h�! � @ s� d Z ddlmZ ddlZddlZddlmZ ddlmZ ddl m Z ddl m Z ddl mZ dd lmZmZ dd lmZ d d lmZ z ddlZW n ey� dZY n0 ed �ZdZdZG dd� dej�ZG dd� dej �Z dS )a� Etcd Transport module for Kombu. It uses Etcd as a store to transport messages in Queues It uses python-etcd for talking to Etcd's HTTP API Features ======== * Type: Virtual * Supports Direct: *Unreviewed* * Supports Topic: *Unreviewed* * Supports Fanout: *Unreviewed* * Supports Priority: *Unreviewed* * Supports TTL: *Unreviewed* Connection String ================= Connection string has the following format: .. code-block:: 'etcd'://SERVER:PORT � )� annotationsN)� defaultdict)�contextmanager)�Empty)� ChannelError)� get_logger)�dumps�loads)�cached_property� )�virtualzkombu.transport.etcdiK � localhostc s� e Zd ZdZdZdZdZdZdZ� fdd�Z dd � Z e d d � �Z d d � Z dd� Zdd� Zdd� Zd dd�Zdd� Zdd� Zedd� �Z� ZS ) �Channelz+Etcd Channel class which talks to the Etcd.ZkombuN� � c sv t d u rtd��t� j|i |�� | jjjp2| jj}| jjjp@t }t � d||| j � t t�| _t j|t|�d�| _d S )N�Missing python-etcd libraryz Host: %s Port: %s Timeout: %s��host�port)�etcd� ImportError�super�__init__� connection�clientr � default_port�hostname� DEFAULT_HOST�logger�debug�timeoutr �dict�queues�Client�int)�self�args�kwargsr r �� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/kombu/transport/etcd.pyr > s zChannel.__init__c C s | j � d|� �S )z�Create and return the `queue` with the proper prefix. Arguments: --------- queue (str): The name of the queue. �/)�prefix)r% �queuer* r* r+ � _key_prefixM s zChannel._key_prefixc c s~ t �| j|�}| j|_t�d|j� �� |jd| j d� z$dV W t�d|j� �� |� � n t�d|j� �� |� � 0 dS )ay Try to acquire a lock on the Queue. It does so by creating a object called 'lock' which is locked by the current session.. This way other nodes are not able to write to the lock object which means that they have to wait before the lock is released. Arguments: --------- queue (str): The name of the queue. zAcquiring lock T)�blocking�lock_ttlNzReleasing lock ) r �Lockr � lock_value�_uuidr r �name�acquirer1 �release)r% r. �lockr* r* r+ � _queue_lockV s �zChannel._queue_lockc K s� || j |< | �|��� z(| jj| �|�ddd�W W d � S tjy� t�d|� d�� | jj | �|�d� Y W d � S 0 W d � n1 s�0 Y dS )z�Create a new `queue` if the `queue` doesn't already exist. Arguments: --------- queue (str): The name of the queue. TN)�key�dir�valuezQueue "z" already exists�r: ) r" r9 r �writer/ r Z EtcdNotFiler r �read)r% r. �_r* r* r+ � _new_queuen s �zChannel._new_queuec K s4 z| j �| �|�� W dS tjy. Y dS 0 dS )z�Verify that queue exists. Returns ------- bool: Should return :const:`True` if the queue exists or :const:`False` otherwise. TFN)r r? r/ r ZEtcdKeyNotFound)r% r. r' r* r* r+ � _has_queue~ s zChannel._has_queuec O s | j �|d� | �|� dS )zpDelete a `queue`. Arguments: --------- queue (str): The name of the queue. N)r" �pop�_purge)r% r. r& r@ r* r* r+ �_delete� s zChannel._deletec K s^ | � |��@ | �|�}| jj|t|�dd�s<td|�d���W d � n1 sP0 Y dS )z�Put `message` onto `queue`. This simply writes a key to the Etcd store Arguments: --------- queue (str): The name of the queue. payload (dict): Message data which will be dumped to etcd. T)r: r< �appendzCannot add key z to etcdN)r9 r/ r r> r r )r% r. �payloadr@ r: r* r* r+ �_put� s �z Channel._putc C s | � |��� | �|�}t�d|| j� zv| jj|d| j| jd�}|du rNt� �|j d }t�d� |d �� t |d �}| jj |d d � |W W d � S t ttjfy� } z&t�d t|�� d |� �� W Y d}~n d}~0 0 t� �W d � n1 �s 0 Y dS ) a[ Get the first available message from the queue. Before it does so it acquires a lock on the store so only one node reads at the same time. This is for read consistency Arguments: --------- queue (str): The name of the queue. timeout (int): Optional seconds to wait for a response. z Fetching key %s with index %sT)r: � recursive�indexr N���zRemoving key {}r: r< r= z _get failed: �:)r9 r/ r r rJ r r? r r � _children�formatr �delete� TypeError� IndexErrorr � EtcdException�type)r% r. r r: �result�itemZ msg_content�errorr* r* r+ �_get� s$ � 0z Channel._getc C sX | � |��: | �|�}t�d|� �� | jj|dd�W d � S 1 sJ0 Y dS )z�Remove all `message`s from a `queue`. Arguments: --------- queue (str): The name of the queue. zPurging queue at key T)r: rI N)r9 r/ r r r rO )r% r. r: r* r* r+ rD � s zChannel._purgec C s� | � |��z d}z<| �|�}t�d|| j� | jj|d| jd�}t|j�}W n t y^ Y n0 t�d||| j� |W d � S 1 s�0 Y dS )z~Return the size of the `queue`. Arguments: --------- queue (str): The name of the queue. r z)Fetching key recursively %s with index %sT)r: rI rJ z$Found %s keys under %s with index %sN) r9 r/ r r rJ r r? �lenrM rP )r% r. �sizer: rT r* r* r+ �_size� s$ �� �z Channel._sizec C s t �� � dt�� � �S )N�.)�socket� gethostname�os�getpid)r% r* r* r+ r3 � s zChannel.lock_value)N)�__name__� __module__� __qualname__�__doc__r- rJ r Z session_ttlr1 r r/ r r9 rA rB rE rH rW rD rZ r r3 � __classcell__r* r* r( r+ r 5 s& " r c s~ e Zd ZdZeZeZdZdZdZ e j j j edg�d�Z erZe j jejf Ze j jejf Z� fdd�Zd d � Zd d � Z� ZS ) � Transportz!Etcd storage Transport for Kombu.r � python-etcd� �direct)Z exchange_typec s& t du rtd��t� j|i |�� dS )z(Create a new instance of etcd.Transport.Nr )r r r r )r% r& r' r( r* r+ r s zTransport.__init__c C sX |j jp | j}|j jpt}t�d||� ztj|t |�d� W dS t yR Y n0 dS )z Verify the connection works.z Verify Etcd connection to %s:%sr TF) r r r r r r r r r# r$ � ValueError)r% r r r r* r* r+ �verify_connection s zTransport.verify_connectionc C sd z<ddl }|jj�� D ]"}|�d�r|�d�d W S qW n" ttfy^ t�d� Y dS 0 dS )z�Return the version of the etcd library. .. note:: python-etcd has no __version__. This is a workaround. r Nrf z==r z'Unable to find the python-etcd version.�Unknown) Zpip.commands.freeze�commands�freeze� startswith�splitr rQ r �warning)r% �pip�xr* r* r+ �driver_version s zTransport.driver_version)r` ra rb rc r � DEFAULT_PORTr Z driver_typeZ driver_nameZpolling_intervalr re Z implements�extend� frozensetr Zconnection_errorsrR Zchannel_errorsr rj rs rd r* r* r( r+ re � s" ��� re ) rc � __future__r r^ r\ � collectionsr � contextlibr r. r Zkombu.exceptionsr Z kombu.logr Zkombu.utils.jsonr r Zkombu.utils.objectsr � r r r r rt r r re r* r* r* r+ �<module> s* ?
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка