Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/kombu/__pycache__/common.cpython-39.pyc
Ðазад
a o�h�5 � @ s� d Z ddlmZ ddlZddlZddlZddlmZ ddlm Z ddl m Z ddl m Z ddlmZmZmZmZ dd lmZmZ d d lmZmZ d d lmZ d d lm Z d dl mZ dZ dZ ee!�Z"da#dd� Z$dd� Z%d;dd�Z&G dd� de�Z'dd� Z(d<d d �Z)d d � Z*d!d"� Z+d#d$� Z,d=d%d&�Z-d>d'd(�Z.d?d)d*�Z/d@d+d,�Z0d-d.� Z1d/d0� Z2e d1d2� �Z3dAd3d4�Z4dBd5d6�Z5dCd7d8�Z6G d9d:� d:�Z7dS )DzCommon Utilities.� )� annotationsN)�deque)�contextmanager)�partial)�count)� NAMESPACE_OID�uuid3�uuid4�uuid5)� ChannelError�RecoverableConnectionError� )�Exchange�Queue)� get_logger)�registry)�uuid) � Broadcast� maybe_declarer � itermessages� send_reply�collect_replies�insured�drain_consumer� eventloopi�� c C s t d u rt� ja t S �N)�_node_idr �int� r r �|/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/kombu/common.py� get_node_id" s r c C sL d� | ||t|��}zttt|��}W n tyF ttt|��}Y n0 |S )Nz{:x}-{:x}-{:x}-{:x})�format�id�strr r � ValueErrorr )Znode_idZ process_idZ thread_id�instanceZent�retr r r � generate_oid) s � r' Tc C s t t� t�� |rt�� nd| �S �Nr )r' r �os�getpid� threading� get_ident)r% �threadsr r r �oid_from3 s �r. c s, e Zd ZdZejd Zd� fdd� Z� ZS ) r a� Broadcast queue. Convenience class used to define broadcast queues. Every queue instance will have a unique name, and both the queue and exchange is configured with auto deletion. Arguments: --------- name (str): This is used as the name of the exchange. queue (str): By default a unique id is used for the queue name for every consumer. You can specify a custom queue name here. unique (bool): Always create a unique queue even if a queue name is supplied. **kwargs (Any): See :class:`~kombu.Queue` for a list of additional keyword arguments supported. ))�queueNNFTc sb |rd� |pdt� �}n|p&dt� � �}t� jf |p6|||||d urH|n t|dd�d�|�� d S )Nz{}.{}Zbcastzbcast.Zfanout)�type)�aliasr/ �name� auto_delete�exchange)r! r �super�__init__r )�selfr2 r/ �uniquer3 r4 r1 �kwargs�� __class__r r r6 R s ��zBroadcast.__init__)NNFTNN)�__name__� __module__� __qualname__�__doc__r �attrsr6 � __classcell__r r r: r r < s �r c C s | |j jjv S r )� connection�client�declared_entities)�entity�channelr r r �declaration_cachedi s rG Fc K s |rt | |fi |��S t| |�S )zDeclare entity (cached).)�_imaybe_declare�_maybe_declare)rE rF �retry� retry_policyr r r r m s r c C s0 | j }|s,|s"td|� d| � ���| �|�} | S )z�Make sure the channel is bound to the entity. :param entity: generic kombu nomenclature, generally an exchange or queue :param channel: channel to bind to the entity :return: the updated entity zCannot bind channel z to entity )�is_boundr �bind)rE rF rL r r r �_ensure_channel_is_boundt s � rN c C s� | }t | |� |d u s |jd u r<| js6td| � d���| j}d }}|jrn| jrn|jjj}t| �}||v rndS |js|t d��| j |d� |d ur�|r�|� |� |d ur�| j |_ dS )Nzchannel is None and entity z not bound.F�channel disconnected)rF T) rN rB rL r rF Zcan_cache_declarationrC rD �hashr Zdeclare�addr2 )rE rF �orig�declared�identr r r rI � s, � rI c K s: t | |�} | jjstd��| jjjj| tfi |��| |�S )NrO )rN rF rB r rC ZensurerI )rE rF rK r r r rH � s ���rH c # s� t � � � fdd�}|g|p g | _| �N t| jjj||dd�D ]&}z� �� V W q> tyb Y q>0 q>W d � n1 sz0 Y dS )z&Drain messages from consumer instance.c s � � | |f� d S r )�append)�body�message��accr r � on_message� s z"drain_consumer.<locals>.on_messageT)�limit�timeout�ignore_timeoutsN)r � callbacksr rF rB rC �popleft� IndexError)Zconsumerr[ r\ r^ rZ �_r rX r r � s � r c K s$ t | jf |g|d�|��|||d�S )zIterator over messages.)ZqueuesrF )r[ r\ r^ )r ZConsumer)�connrF r/ r[ r\ r^ r9 r r r r � s �r c c sN |r t |�pt� D ]6}z| j|d�V W q tjyF |rB|sB� Y q0 qdS )a Best practice generator wrapper around ``Connection.drain_events``. Able to drain events forever, with a limit, and optionally ignoring timeout errors (a timeout of 1 is often used in environments where the socket can get "stuck", and is a best practice for Kombu consumers). ``eventloop`` is a generator. Examples -------- >>> from kombu.common import eventloop >>> def run(conn): ... it = eventloop(conn, timeout=1, ignore_timeouts=True) ... next(it) # one event consumed, or timed out. ... ... for _ in eventloop(conn, timeout=1, ignore_timeouts=True): ... pass # loop forever. It also takes an optional limit parameter, and timeout errors are propagated by default:: for _ in eventloop(connection, limit=1, timeout=1): pass See Also -------- :func:`itermessages`, which is an event loop bound to one or more consumers, that yields any messages received. )r\ N)�ranger Z drain_events�socketr\ )rb r[ r\ r] �ir r r r � s r c K sH |j |f| ||d�t|jd |j�d�tj|j |jd�fi |����S )a� Send reply for request. Arguments: --------- exchange (kombu.Exchange, str): Reply exchange req (~kombu.Message): Original request, a message with a ``reply_to`` property. producer (kombu.Producer): Producer instance retry (bool): If true must retry according to the ``reply_policy`` argument. retry_policy (Dict): Retry settings. **props (Any): Extra properties. )r4 rJ rK Zreply_to�correlation_id)Z routing_keyrf � serializer�content_encoding)�publish�dict� properties�get� serializersZ type_to_name� content_typerh )r4 �req�msgZproducerrJ rK �propsr r r r � s �� ���r c o sv |� dd�}d}zNt| ||g|�R i |��D ] \}}|s@|�� d}|V q,W |rr|�|j� n|rp|�|j� 0 dS )z,Generator collecting replies from ``queue``.�no_ackTFN)� setdefaultr ZackZ after_reply_message_receivedr2 ) rb rF r/ �argsr9 rr �receivedrV rW r r r r s �� �r c C s t jd| |dd� d S )Nz#Connection error: %r. Retry in %ss T)�exc_info)�logger�error)�exc�intervalr r r �_ensure_errback s �r{ c c s* z d V W n | j | j y$ Y n0 d S r )Zconnection_errorsZchannel_errors)rb r r r �_ignore_errors s r| c O sB |r:t | �� ||i |��W d � S 1 s00 Y t | �S )a� Ignore connection and channel errors. The first argument must be a connection object, or any other object with ``connection_error`` and ``channel_error`` attributes. Can be used as a function: .. code-block:: python def example(connection): ignore_errors(connection, consumer.channel.close) or as a context manager: .. code-block:: python def example(connection): with ignore_errors(connection): consumer.channel.close() Note: ---- Connection and channel errors should be properly handled, and not ignored. Using this function is only acceptable in a cleanup phase, like when a connection is lost or at shutdown. N)r| )rb �funrt r9 r r r � ignore_errors' s ,r~ c C s |r ||� d S r r )rB rF � on_reviver r r �revive_connectionI s r� c K s� |pt }| jdd��h}|j|d� |j}tt||d�} |j||f|| d�|��} | |i t||d���\} } | W d � S 1 s�0 Y dS )z�Function wrapper to handle connection errors. Ensures function performing broker commands completes despite intermittent connection failures. T)�block)�errback)r )r� r )rB N)r{ �acquireZensure_connectionZdefault_channelr r� Z autoretryrj ) �poolr} rt r9 r� r �optsrb rF Zreviver �retvalra r r r r N s ��r c @ s@ e Zd ZdZdZdd� Zddd�Zddd �Zd d � Zd d � Z dS )�QoSa� Thread safe increment/decrement of a channels prefetch_count. Arguments: --------- callback (Callable): Function used to set new prefetch count, e.g. ``consumer.qos`` or ``channel.basic_qos``. Will be called with a single ``prefetch_count`` keyword argument. initial_value (int): Initial prefetch count value.. Example: ------- >>> from kombu import Consumer, Connection >>> connection = Connection('amqp://') >>> consumer = Consumer(connection) >>> qos = QoS(consumer.qos, initial_prefetch_count=2) >>> qos.update() # set initial >>> qos.value 2 >>> def in_some_thread(): ... qos.increment_eventually() >>> def in_some_other_thread(): ... qos.decrement_eventually() >>> while 1: ... if qos.prev != qos.value: ... qos.update() # prefetch changed so update. It can be used with any function supporting a ``prefetch_count`` keyword argument:: >>> channel = connection.channel() >>> QoS(channel.basic_qos, 10) >>> def set_qos(prefetch_count): ... print('prefetch count now: %r' % (prefetch_count,)) >>> QoS(set_qos, 10) Nc C s || _ t�� | _|pd| _d S r( )�callbackr+ �RLock�_mutex�value)r7 r� � initial_valuer r r r6 � s z QoS.__init__r c C sD | j �( | jr | jt|d� | _W d � n1 s40 Y | jS )z�Increment the value, but do not update the channels QoS. Note: ---- The MainThread will be responsible for calling :meth:`update` when necessary. r N)r� r� �max�r7 �nr r r �increment_eventually� s 0zQoS.increment_eventuallyc C sP | j �4 | jr,| j|8 _| jdk r,d| _W d � n1 s@0 Y | jS )z�Decrement the value, but do not update the channels QoS. Note: ---- The MainThread will be responsible for calling :meth:`update` when necessary. r N)r� r� r� r r r �decrement_eventually� s $zQoS.decrement_eventuallyc C sH || j krD|}|tkr&t�dt� d}t�d|� | j|d� || _ |S )z#Set channel prefetch_count setting.z(QoS: Disabled: prefetch_count exceeds %rr z basic.qos: prefetch_count->%s)Zprefetch_count)�prev�PREFETCH_COUNT_MAXrw �warning�debugr� )r7 Zpcount� new_valuer r r �set� s � zQoS.setc C s6 | j � | �| j�W d � S 1 s(0 Y dS )z)Update prefetch count with current value.N)r� r� r� )r7 r r r �update� s z QoS.update)r )r ) r< r= r> r? r� r6 r� r� r� r� r r r r r� b s * r� )T)NF)r NN)r NN)NNF)NFN)N)N)NN)8r? � __future__r r) rd r+ � collectionsr � contextlibr � functoolsr � itertoolsr r r r r r Zamqpr r rE r r �logr Z serializationr rm Z utils.uuid�__all__r� r< rw r r r' r. r rG r rN rI rH r r r r r r{ r| r~ r� r r� r r r r �<module> sT - � ( � "
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка