Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/kombu/transport/__pycache__/native_delayed_delivery.cpython-39.pyc
Ðазад
a o�h� � @ s� d Z ddlmZ ddlmZmZmZmZ ddlm Z e e �Z dZ e d Z dZdd d �d d �Zd d dd�dd�Zd ddd�dd�Zdd d d�dd�ZdS )z:Native Delayed Delivery API. Only relevant for RabbitMQ. � )� annotations)� Connection�Exchange�Queue�binding)� get_logger� � Zcelery_delayed_delivery�int�str)�level�returnc C s | dk rt d��d| � �S )z=Generates the delayed queue/exchange name based on the level.r z#level must be a non-negative numberZcelery_delayed_)� ValueError)r � r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/kombu/transport/native_delayed_delivery.py� level_name s r r �None)� connection� queue_typer c C s^ |dkr|dkrt d��| �� }d}tddd�D ]�}t|�}|dkrPt|d �nd }t|d d ��|�}|�� |d td |�d |dkr�|ntd�}|dkr�d|d< t ||d��|�} | �� | � ||� d| }q0d}tddd�D ]L}t|�}|dk�rt|d �nd }t|d d ��|�} | � ||� d| }q�ttd d ��|�} | �� | � td�|� d S )z:Declares all native delayed delivery exchanges and queues.ZclassicZquorumz+queue_type must be either classic or quorumz1.#� ���r r NZtopic)�typezreject-publish� i� )z x-queue-typez x-overflowz x-message-ttlzx-dead-letter-exchangez at-least-oncezx-dead-letter-strategy)�queue_argumentsz*.z0.#) r �channel�ranger r �bindZdeclare�pow� CELERY_DELAYED_DELIVERY_EXCHANGEr �bind_to) r r r � routing_keyr Z current_levelZ next_levelZdelayed_exchanger Z delayed_queueZnext_level_exchangeZdelivery_exchanger r r �4declare_native_delayed_delivery_exchanges_and_queues s^ �� ��� �� ��r! r )r �queuer c C s� | � � }|�|�}t� }|jr:|�t|j|j|jd�� n |jrF|j}|D ]l}|j�|�}|j dkrzt � d|j � d�� qJ|j� d�r�|jn d|j� �}|jt|d� |j|j |d� qJdS ) a� Bind a queue to the native delayed delivery exchange. When a message arrives at the delivery exchange, it must be forwarded to the original exchange and queue. To accomplish this, the function retrieves the exchange or binding objects associated with the queue and binds them to the delivery exchange. :param connection: The connection object used to create and manage the channel. :type connection: Connection :param queue: The queue to be bound to the native delayed delivery exchange. :type queue: Queue Warning: ------- If a direct exchange is detected, a warning will be logged because native delayed delivery does not support direct exchanges. )r � arguments�directz Exchange z� is a direct exchange and native delayed delivery do not support direct exchanges. ETA tasks published to this exchange will block the worker until the ETA arrives.�#z#.)r N)r r �set�exchange�addr r Zbinding_arguments�bindingsr �logger�warn�name� startswithr r )r r" r r) Z binding_entryr' r r r r �.bind_queue_to_native_delayed_delivery_exchangeO s. � � �r. )� countdownr r c C s8 | dk rt d��|s t d��d�t| d���d|� � S )zRCalculate the routing key for publishing a delayed message based on the countdown.r z#countdown must be a positive numberz routing_key must be non-empty�.Z028b)r �join�list)r/ r r r r �calculate_routing_key~ s r3 N)�__doc__� __future__r Zkombur r r r Z kombu.logr �__name__r* ZMAX_NUMBER_OF_BITS_TO_USEZ MAX_LEVELr r r! r. r3 r r r r �<module> s 6/
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка