Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/kombu/asynchronous/aws/sqs/__pycache__/connection.cpython-39.pyc
Ðазад
a o�hC, � @ s� d Z ddlmZ ddlZddlmZ ddlmZ ddlm Z ddl m Z dd l m Z dd lmZ dd lmZ d ZG d d� de �Zdd� Zdd� ZdS )zAmazon SQS Connection.� )� annotationsN)� Serializer)� transform)�AsyncAWSQueryConnection)� AWSRequest� )�boto3)� AsyncMessage)� AsyncQueue)�AsyncSQSConnectionc s� e Zd ZdZd6� fdd� Zdd� Zdd � Zd7d d �Zd8d d �Zd9dd�Z dd� Z d:dd�Z d;dd�Z d<dd�Z d=dd �Zd>d d �Zd?d d �Zd@d!d"�ZdAd#d$�ZdBd%d&�ZdCd'd(�ZdDd*d+�ZdEd,d-�ZeZd.d/� ZdFd0d1�ZdGd2d3�ZdHd4d5�Z� Z S )Ir zAsync SQS Connection.r Nc sB t d u rtd��t� j|f||d�|�� |d ur6|ndg| _d S )Nzboto3 is not installed)Z region_name�debugZApproximateReceiveCount)r � ImportError�super�__init__�fetch_message_attributes)�self�sqs_connectionr �regionr �kwargs�� __class__� ��/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/connection.pyr s ��� �zAsyncSQSConnection.__init__c C s^ |� � }|r||d< d|i}i }|�� dkr4d|i}|�� dkrHd|d< tf |||d�|��S ) N�Action�data�get�params�postz0application/x-www-form-urlencoded; charset=utf-8� Content-Type)�method�url�headers)�copy�lowerr )r � operationr � queue_urlr � param_payloadr! r r r �_create_query_request$ s z(AsyncSQSConnection._create_query_requestc C s� |� � }||d< | jjj}|�|�}| jjj}i }|jd }d|� �} | |d< d�|jd |j �} | |d< t � |�� � |d�} |j �d tj�} tf | |d �| ��S ) N�QueueUrlZ jsonVersionzapplication/x-amz-json-r z{}.{}Z targetPrefixz X-Amz-Target)r r! r )r r )r" r �meta� service_model�operation_modelZ _endpoint�host�metadata�format�name�json�dumps�encode�httpr r ZDEFAULT_METHODr ) r r$ r r% r* r+ r r! Z json_version� content_type�targetr& r r r r �_create_json_request5 s0 � ���z'AsyncSQSConnection._create_json_requestc C s� | j j}| j jj}|j} i |p i �|�| i ��} | dkrJ| �|| ||�} n(| dkrb| �|| |�} ntd| � d���| j � � dkr�dnd} |j || | d� | � � } | j | |d �S ) a� Override make_request to support different protocols. botocore has changed the default protocol of communicating with SQS backend from 'query' to 'json', so we need a special implementation of make_request for SQS. More information on this can be found in: https://github.com/celery/kombu/pull/1807. protocol_params: Optional[dict[str, dict]] of per-protocol additional parameters. Supported for the SQS query to json protocol transition. �queryr0 zUnsupported protocol: �.r z presign-url�standard)� signing_type��callback)r Z_request_signerr) r* �protocolr r' r6 � Exceptionr r# �sign�prepareZ_mexe)r Zoperation_namer r% �verbr< �protocol_paramsZsignerr* r= � all_params�requestr: �prepared_requestr r r � make_requestW s& ���z AsyncSQSConnection.make_requestc C s* d|i}|rt |d�|d< | jd||d�S )N� QueueName�dZDefaultVisibilityTimeoutZ CreateQueuer; )r. � get_object)r � queue_name�visibility_timeoutr< r r r r � create_queuey s ��z AsyncSQSConnection.create_queueFc C s | j dd |j|d�S )NZ DeleteQueuer; �� get_status�id)r �queueZforce_deletionr< r r r � delete_queue� s �z AsyncSQSConnection.delete_queuec C s | j j|d�}|d S )N)rG r( )r � get_queue_url)r rP �resr r r rR � s z AsyncSQSConnection.get_queue_url�Allc C s | j dd|i|j|d�S )NZGetQueueAttributes� AttributeNamer; )rI rO )r rP � attributer< r r r �get_queue_attributes� s �z'AsyncSQSConnection.get_queue_attributesc C s* | j di |j|d||ii||d�d�d�S )NZSetQueueAttribute� Attributes)zAttribute.NamezAttribute.Value�r0 r7 )r< rB rM )r rP rV �valuer< r r r �set_queue_attribute� s ��z&AsyncSQSConnection.set_queue_attributer c C s� d|i}i i d�} |d ur |n| j } |r0||d< | rd| d �dt| �i� | d �tdt| �i�� |d urt||d< | jd |d tfg|||| d �S ) NZMaxNumberOfMessages)r7 r0 �VisibilityTimeoutr0 ZAttributeNamesr7 rU ZWaitTimeSecondsZReceiveMessage�Message)r< �parentrB )r �update�list�_query_object_encode�get_listr ) r rP r% Znumber_messagesrK � attributesZwait_time_secondsr< r Z proto_params�attrsr r r �receive_message� s �z"AsyncSQSConnection.receive_messagec C s | � |||�S �N)�delete_message_from_handle�r rP �receipt_handler< r r r �delete_message� s �z!AsyncSQSConnection.delete_messagec C sB ddd� |D �it ddd� |D �i�d�}| jdi |jd||d �S ) N�Entriesc S s g | ]}|j |jd ��qS �)�Id� ReceiptHandle�rO ri ��.0�mr r r � <listcomp>� � z;AsyncSQSConnection.delete_message_batch.<locals>.<listcomp>Z DeleteMessageBatchRequestEntryc S s g | ]}|j |jd ��qS rl ro rp r r r rs � s �rY ZDeleteMessageBatch�POST�rA r< rB �ra rI rO )r rP �messagesr< �p_paramsr r r �delete_message_batch� s ���� �z'AsyncSQSConnection.delete_message_batchc C s | j dd|i||d�S )NZ DeleteMessagern r; )rN rh r r r rg � s �z-AsyncSQSConnection.delete_message_from_handlec C s. d|i}|rt |�|d< | jd||jd|d�S )NZ MessageBodyZ DelaySecondsZ SendMessageru �rA r< )�intrI rO )r rP Zmessage_contentZ delay_secondsr< r r r r � send_message� s �z AsyncSQSConnection.send_messagec C sn i }t |�D ]J\}}d|d � �}|�|� d�|d |� d�|d |� d�|d i� q | jd||jd |d �S ) Nz SendMessageBatchRequestEntry.r z.Idr z .MessageBodyz .DelaySeconds� ZSendMessageBatchru r{ )� enumerater_ rI rO )r rP rx r< r �i�msg�prefixr r r �send_message_batch� s ��z%AsyncSQSConnection.send_message_batchc C s | j d||d�|j|d�S )NZChangeMessageVisibility)rn r\ r; rM )r rP ri rK r< r r r �change_message_visibility� s ��z,AsyncSQSConnection.change_message_visibilityc C s< dd� |D �}d|it d|i�d�}| jdi |jd||d�S ) Nc S s( g | ] }|d j |d j|d d��qS )r r )rm rn r\ ro )rq �tr r r rs � s �zFAsyncSQSConnection.change_message_visibility_batch.<locals>.<listcomp>rk Z(ChangeMessageVisibilityBatchRequestEntryrY Z ChangeMessageVisibilityBatchru rv rw )r rP rx r< �entriesry r r r � change_message_visibility_batch� s � ��z2AsyncSQSConnection.change_message_visibility_batch� c C s( i }|r||d< | j d|dtfg|d�S )NZQueueNamePrefixZ ListQueuesr( r; )rb r )r r� r< r r r r �get_all_queues s �z!AsyncSQSConnection.get_all_queuesc C s | � |t| j||��S rf )r� r �_on_queue_ready)r rJ r< r r r � get_queue s �z AsyncSQSConnection.get_queuec s t � fdd�|D �d �S )Nc 3 s | ]}|j �� �r|V qd S rf )r �endswith)rq �q�r/ r r � <genexpr> rt z5AsyncSQSConnection._on_queue_ready.<locals>.<genexpr>)�next)r r/ Zqueuesr r� r r� s �z"AsyncSQSConnection._on_queue_readyc C s | j dd|jidtfg|d�S )NZListDeadLetterSourceQueuesr( r; )rb r r )r rP r< r r r � get_dead_letter_source_queues s �z0AsyncSQSConnection.get_dead_letter_source_queuesc C s | j d|||d�|j|d�S )NZ AddPermission)�LabelZ AWSAccountIdZ ActionNamer; rM )r rP �labelZaws_account_id� action_namer< r r r �add_permission s ��z!AsyncSQSConnection.add_permissionc C s | j dd|i|j|d�S )NZRemovePermissionr� r; rM )r rP r� r< r r r �remove_permission* s �z$AsyncSQSConnection.remove_permission)r NN)NN)NN)FN)rT N)N)r NNNN)N)N)N)NN)N)N)N)r� N)N)N)N)N) �__name__� __module__� __qualname__�__doc__r r' r6 rF rL rQ rR rW r[ re rj rz rg r} r� r� r� r� r� �lookupr� r� r� r� � __classcell__r r r r r sB " # � � � � � � r c C s" i }t |d| � dd� |�� D �S )Nr� c S s i | ]\}}||�qS r r )rq �k�vr r r � <dictcomp>3 rt z(_query_object_encode.<locals>.<dictcomp>)�_query_object_encode_part�items)r� r r r r ra 0 s ra c C s� |r|� d�n|}t |ttf�rLt|�D ] \}}t| |� |d � �|� q(n>t |t�r~|�� D ] \}}t| |� |� �|� q^n t|�| |< d S )Nr8 r )� isinstancer` �tupler r� �dictr� �str)r r� �partZdottedr� �item�keyrZ r r r r� 6 s r� )r� � __future__r r0 Zbotocore.serializer Zviner Z!kombu.asynchronous.aws.connectionr Zkombu.asynchronous.aws.extr �extr �messager rP r �__all__r ra r� r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка