Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/kombu/asynchronous/aws/__pycache__/connection.cpython-39.pyc
Ðазад
a o�h�" � @ s� d Z ddlmZ ddlmZ ddlmZ ddlmZm Z ddl m Z m Z m Z ddlmZmZmZ dd � Zd ZG d d � d �ZG d d� d�ZG dd� d�ZG dd� de�ZdS )zAmazon AWS Connection.� )� annotations)�message_from_bytes)� MIMEMessage)�promise� transform)� AWSRequest� get_cert_path� get_response)�Headers�Request� get_clientc C s d� dd� | D ��}t|�� �S )Nz c s s | ]}d j |� V qdS )z{}: {}N)�format)�.0�h� 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/connection.py� <genexpr> � z'message_from_headers.<locals>.<genexpr>)�joinr �encode)�hdr�bsr r r �message_from_headers s r )�AsyncHTTPSConnection�AsyncConnectionc @ s^ e Zd ZdZdd� Zdd� Zddd�Zd d � Zed d � �Z ed d� �Z edd� �Z dd� Z dS )�AsyncHTTPResponsezAsync HTTP Response.c C s || _ d | _d| _d S )N� )�response�_msg�version)�selfr r r r �__init__ s zAsyncHTTPResponse.__init__c O s | j jS �N)r �body)r �args�kwargsr r r �read s zAsyncHTTPResponse.readNc C s | j j�||�S r" )r �headers�get)r �name�defaultr r r � getheader# s zAsyncHTTPResponse.getheaderc C s t | jj�� �S r" )�listr r' �items�r r r r � getheaders& s z AsyncHTTPResponse.getheadersc C s" | j d u r tt| �� ��| _ | j S r" )r r r r/ r. r r r �msg) s zAsyncHTTPResponse.msgc C s | j jS r" )r �coder. r r r �status/ s zAsyncHTTPResponse.statusc C s | j jr| j jjS dS )N� )r �error�messager. r r r �reason3 s zAsyncHTTPResponse.reasonc C s t | j�S r" )�reprr r. r r r �__repr__9 s zAsyncHTTPResponse.__repr__)N) �__name__� __module__� __qualname__�__doc__r! r& r+ r/ �propertyr0 r2 r6 r8 r r r r r s r c @ s� e Zd ZdZeZeZdZdZdZ ddd�Z d!d d �Z d"d d �Z d d� Z d#dd�Zdd� Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � ZdS )$r zAsync HTTP Connection.�GET�/N�P i� )�http�https� 4@c C s" g | _ || _|| _|pt� | _d S r" )r' �timeout�strictr � http_client)r rE rD rF r r r r! H s z AsyncHTTPSConnection.__init__c C s` || _ || _|d ur@z |j}W n ty6 || _Y n 0 |� | _|d ur\| j�t|�� �� d S r" ) �path�methodr& �AttributeErrorr# r' �extendr, r- )r rH rG r# r' r& r r r �requestN s z AsyncHTTPSConnection.requestc C s2 t | j�}| j| j| j|| j| j| jdtd�d�S )NT)rH r' r# �connect_timeout�request_timeoutZ validate_cert�ca_certs)r r' r rG rH r# rD r )r r' r r r � getrequest[ s �z AsyncHTTPSConnection.getrequestc C s& | � � }|�t| j|�� | j�|�S r" )rO Zthenr �ResponserF Z add_request)r �callbackrK r r r � getresponseb s z AsyncHTTPSConnection.getresponsec C s d S r" r )r �levelr r r �set_debuglevelg s z#AsyncHTTPSConnection.set_debuglevelc C s d S r" r r. r r r �connectj s z AsyncHTTPSConnection.connectc C s d S r" r r. r r r �closem s zAsyncHTTPSConnection.closec C s || _ || _d S r" )rH rG )r rH rG r r r � putrequestp s z AsyncHTTPSConnection.putrequestc C s | j �||f� d S r" )r' �append)r �header�valuer r r � putheadert s z AsyncHTTPSConnection.putheaderc C s d S r" r r. r r r � endheadersw s z AsyncHTTPSConnection.endheadersc C s | j r| j |7 _ n|| _ d S r" )r# )r �datar r r �sendz s zAsyncHTTPSConnection.sendc C s d| � � �d�S )Nz<AsyncHTTPConnection: �>)rO r. r r r r8 � s z AsyncHTTPSConnection.__repr__)NrC N)NN)N)r9 r: r; r< r r rP rH rG r# Z default_portsr! rK rO rR rT rU rV rW r[ r\ r^ r8 r r r r r = s& r c @ s, e Zd ZdZd dd�Zdd� Zd dd�ZdS ) r zAsync AWS Connection.Nc K s || _ |pt� | _d S r" )�sqs_connectionr � _httpclient)r r` rF r% r r r r! � s zAsyncConnection.__init__c C s t | jd�S )N)rF )r ra r. r r r �get_http_connection� s z#AsyncConnection.get_http_connectionc C s^ |pt � }| �� }t|�r6|||j|j|j|j|� n$|�|j|j|j|j� |j |d� |S )N�rQ ) r rb �callablerH rG r# r' rK �urlrR )r rK ZsenderrQ �connr r r �_mexe� s � � zAsyncConnection._mexe)N)NN)r9 r: r; r< r! rb rg r r r r r � s r c s� e Zd ZdZdZdZdZdZdZdZ dZ eee fZ eee fZ d � fd d � Z d d d �Zd!dd�Zd"dd�Zd#dd�Zdd� Zdd� Zdd � Zd d � Z� ZS )$�AsyncAWSQueryConnectionzAsync AWS Query Connection.�� i� iW i� i� i� i� Nc s" |si }t � j||fi |�� d S r" )�superr! )r r` rF Zhttp_client_paramsr% �� __class__r r r! � s �z AsyncAWSQueryConnection.__init__c C s� |� � }|�|pi �di �� |r*||d< | jj}d} d|i} |�� dkrVd} d|i} tf ||d�| ��} |j|| | d � | �� } | j | |d �S ) N�query�Action�standardr] r( z presign-url�params)rH re )� signing_typerc ) �copy�updater( r` Z_request_signer�lowerr �sign�preparerg ) r � operationZparams_rG �verbrQ �protocol_paramsrp Zsignerrq Z param_payloadrK �prepared_requestr r r � make_request� s z$AsyncAWSQueryConnection.make_requestr? �POSTc C s( | j ||||t| j||p| ||�|d�S �N)rQ ry )r{ r �_on_list_ready) r rw rp �markersrG �parentrx rQ ry r r r �get_list� s ��z AsyncAWSQueryConnection.get_listr> c C s& | j ||||t| j||p| |�|d�S r} )r{ r � _on_obj_ready�r rw rp rG r� rx rQ ry r r r � get_object� s ��z"AsyncAWSQueryConnection.get_objectc C s& | j ||||t| j||p| |�|d�S r} )r{ r �_on_status_readyr� r r r � get_status� s ��z"AsyncAWSQueryConnection.get_statusc C s` | j jj}|j| jkr0t|�|�|j�\}}|S |j| jv sH|j| j v rLg S | � ||� � ��d S r" ) r` �meta� service_modelr2 �STATUS_CODE_OKr �operation_modelr �STATUS_CODES_TIMEOUT�STATUS_CODES_SERVER_ERRORS� _for_statusr& )r r� r rw r r� �_�parsedr r r r~ � s � � �z&AsyncAWSQueryConnection._on_list_readyc C sD | j jj}|j| jkr0t|�|�|j�\}}|S | �||� � ��d S r" ) r` r� r� r2 r� r r� r r� r& )r r� rw r r� r� r� r r r r� � s �z%AsyncAWSQueryConnection._on_obj_readyc C sF | j jj}|j| jkr2t|�|�|j�\}}|jS | � ||� � ��d S r" ) r` r� r� r2 r� r r� r r1 r� r& )r r� rw r r� Zhttpresr� r r r r� s �z(AsyncAWSQueryConnection._on_status_readyc C s$ |sdnd}t d�||j|j|��S )Nz Empty bodyz HTTP Errorz Request {} HTTP {} {} ({}))� Exceptionr r2 r6 )r r r# �contextr r r r� s �z#AsyncAWSQueryConnection._for_status)NN)NN)r? Nr| NN)r? Nr> NN)r? Nr> NN)r9 r: r; r< r� ZSTATUS_CODE_REQUEST_TIMEOUTZ)STATUS_CODE_NETWORK_CONNECT_TIMEOUT_ERRORZSTATUS_CODE_INTERNAL_ERRORZSTATUS_CODE_BAD_GATEWAYZ%STATUS_CODE_SERVICE_UNAVAILABLE_ERRORZSTATUS_CODE_GATEWAY_TIMEOUTr� r� r! r{ r� r� r� r~ r� r� r� � __classcell__r r rk r rh � s: �� � � rh N)r< � __future__r �emailr Zemail.mime.messager Zviner r Zkombu.asynchronous.aws.extr r r Zkombu.asynchronous.httpr r r r �__all__r r r rh r r r r �<module> s %G
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка