Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/kombu/asynchronous/aws/sqs/__pycache__/queue.cpython-39.pyc
Ðазад
a o�h2 � @ sH d Z ddlmZ ddlmZ ddlmZ dgZdd� ZG d d� d�Z d S ) z Amazon SQS queue implementation.� )� annotations)� transform� )� AsyncMessage� AsyncQueuec C s t | �dkr| d S dS )z4Get the first item in a list, or None if list empty.r r N)�len)�rs� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/kombu/asynchronous/aws/sqs/queue.py� list_first s r c @ s e Zd ZdZddefdd�Zdd� Ze Z Z Z Z Z Z Z Z Z ZZd0dd �Zd1d d �Zd2d d�Zdd� Zd3dd�Zdd� Zd4dd�Zd5dd�Zd6dd�Zd7dd �Zd8d d �Z d d � Z d9d"d#�Z d:d$d%�Z d;d&d'�Z d<d(d)�Z!d=d*d+�Z"d>d.d/�Z#dS )?r zAsync SQS Queue.Nc C s || _ || _|| _d | _d S �N)� connection�url� message_class�visibility_timeout)�selfr r r r r r �__init__ s zAsyncQueue.__init__c O s t � �d S r )�NotImplementedError)r �args�kwargsr r r �_NA s zAsyncQueue._NA�Allc C s | j �| ||�S r )r Zget_queue_attributes)r � attributes�callbackr r r �get_attributes s �zAsyncQueue.get_attributesc C s | j �| |||�S r )r Zset_queue_attribute)r � attribute�valuer r r r � set_attribute% s �zAsyncQueue.set_attribute�VisibilityTimeoutc C s | � |t| j||t��S r �r r �_coerce_field_value�int)r r �_attrr r r � get_timeout* s ��zAsyncQueue.get_timeoutc C s ||| �S r r )r �key�type�responser r r r 1 s z AsyncQueue._coerce_field_valuec C s | � d|t| j|��S )Nr )r r �_on_timeout_set)r r r r r r � set_timeout4 s ��zAsyncQueue.set_timeoutc C s |r || _ | j S r )r )r r r r r r' < s zAsyncQueue._on_timeout_setc C s | j �| ||||�S r )r �add_permission)r �labelZaws_account_id� action_namer r r r r) A s �zAsyncQueue.add_permissionc C s | j �| ||�S r )r �remove_permission)r r* r r r r r, G s z AsyncQueue.remove_permissionc C s | j d||tt|�d�S )Nr )�wait_time_secondsr )� get_messagesr r )r r r- r r r r �readJ s �zAsyncQueue.readc C s" | j j| |�� |t| j||�d�S �N)r )r � send_messageZget_body_encodedr �_on_message_sent)r �messageZ delay_secondsr r r r �writeR s �zAsyncQueue.writec C s | j j| ||d�S r0 )r Zsend_message_batch�r �messagesr r r r � write_batchX s �zAsyncQueue.write_batchc C s |j |_ |j|_|S r )�id�md5)r Z orig_messageZ new_messager r r r2 ] s zAsyncQueue._on_message_sentr c C s | j j| |||||d�S )N)Znumber_messagesr r r- r )r Zreceive_message)r Z num_messagesr r r- r r r r r. b s �zAsyncQueue.get_messagesc C s | j �| ||�S r )r �delete_message)r r3 r r r r r: l s zAsyncQueue.delete_messagec C s | j j| ||d�S r0 )r �delete_message_batchr5 r r r r; o s �z AsyncQueue.delete_message_batchc C s | j j| ||d�S r0 )r � change_message_visibility_batchr5 r r r r< t s �z*AsyncQueue.change_message_visibility_batchc C s | j j| |d�S r0 )r Z delete_queue)r r r r r �deletey s zAsyncQueue.delete� �ApproximateNumberOfMessagesc C s | j |t| j||t�d�S r0 r )r Z page_sizeZvtimeoutr r" r r r �count| s ��zAsyncQueue.count)r N)N)Nr )N)N)N)NNN)NN)N)r NNNN)N)N)N)N)r> r> Nr? )$�__name__� __module__� __qualname__�__doc__r r r Z count_slow�dumpZ save_to_fileZsave_to_filename�saveZ save_to_s3Z load_from_s3Zload_from_fileZload_from_filename�load�clearr r r# r r( r' r) r, r/ r4 r7 r2 r. r: r; r< r= r@ r r r r r sN ����� � � � �N) rD � __future__r Zviner r3 r Z_all__r r r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка