Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/botocore/__pycache__/endpoint.cpython-39.pyc
Ðазад
a p�h�5 � @ s� d dl Z d dlZd dlZd dlZd dlmZ d dlmZ d dlm Z d dl m Z d dl m Z mZ d dlmZ d dlmZ d d lmZ d d lmZ e�e�Ze� Zd Zd Z d d� Z G dd� de �Z G dd� de �Z dS )� N)�six)�create_request_object)�HTTPClientError)�URLLib3Session)�is_valid_endpoint_url�get_environ_proxies)�first_non_none_response)�get_global_history_recorder)� StreamingBody)�parsers�< � c C st | j | jd|jid�}|d dkr.| j|d< nB|jr@| j|d< n0|jrf|d �d�}t| j|�|d< n | j|d< |S )a� Convert an HTTP response object to a request dict. This converts the requests library's HTTP response object to a dictionary. :type http_response: botocore.vendored.requests.model.Response :param http_response: The HTTP response from an AWS service request. :rtype: dict :return: A response dictionary which will contain the following keys: * headers (dict) * status_code (int) * body (string or file-like object) �operation_name)�headers� status_code�contextr �, �bodyr zcontent-length) r r �name�content�has_event_stream_output�raw�has_streaming_output�getr )� http_response�operation_model� response_dict�length� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/botocore/endpoint.py�convert_to_response_dict& s �� r c @ sv e Zd ZdZddd�Zdd� Zdd� Zd d d �Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z d dd�Zdd� ZdS ) �Endpointa, Represents an endpoint for a particular service in a specific region. Only an endpoint can make requests. :ivar service: The Service object that describes this endpoints service. :ivar host: The fully qualified endpoint hostname. :ivar session: The session object. Nc C sN || _ || _|| _t�� | _|d u r,t�� }|| _|| _ | j d u rJt � | _ d S �N) �_endpoint_prefix�_event_emitter�host� threading�Lock�_lockr ZResponseParserFactory�_response_parser_factory� http_sessionr )�selfr% �endpoint_prefix� event_emitter�response_parser_factoryr* r r r �__init__S s zEndpoint.__init__c C s d| j | jf S )Nz%s(%s))r# r% )r+ r r r �__repr__` s zEndpoint.__repr__c C s t �d||� | �||�S )Nz%Making request for %s with params: %s)�logger�debug� _send_request)r+ r � request_dictr r r � make_requestc s �zEndpoint.make_requestc C s\ t |�}|rNt|j|jg�|_|jj�� }dj||j d�}| j j |||j d� | � |�}|S )Nz&request-created.{service_id}.{op_name})� service_idZop_name)�requestr ) r �anyr r Z stream_output� service_modelr6 � hyphenize�formatr r$ �emit�prepare_request)r+ �paramsr r7 r6 � event_name�prepared_requestr r r �create_requesth s � � � zEndpoint.create_requestc C s0 |� � D ]"\}}t|tj�r|�d�||< qd S )Nzutf-8)�items� isinstancer � text_type�encode)r+ r �key�valuer r r �_encode_headersx s zEndpoint._encode_headersc C s | � |j� |�� S r" )rH r �prepare�r+ r7 r r r r= ~ s zEndpoint.prepare_requestc C s� d}| � ||�}|d }| �|||�\}}| �|||||�rl|d7 }|�� | � ||�}| �|||�\}}q*|d ur�d|d v r�|d }||d d d< |d ur�|�n|S d S )N� r ZResponseMetadataZ RetryAttempts)rA � _get_response� _needs_retryZ reset_stream) r+ r4 r �attemptsr7 r �success_response� exceptionZ total_retriesr r r r3 � s4 � ��� ��zEndpoint._send_requestc C sv | � ||�\}}d d ||d�}|d urD|\}}||d< t||�|d< |jj�� } | jjd| |jf fi |�� ||fS )N)r �parsed_responser rP rQ r zresponse-received.%s.%s)�_do_get_responser r9 r6 r: r$ r< r ) r+ r7 r r rO rP Zkwargs_to_emitr rQ r6 r r r rL � s. ��� ���zEndpoint._get_responsec C s\ zvt �d|� t�d|j|j|j|j|jd�� |j j � � }d||j f }| j j||d�}t|�}|d u rt| �|�}W nd ty� } zd |fW Y d }~S d }~0 ty� } z"t jddd� d |fW Y d }~S d }~0 0 t||�}|�� } |j| d < t�d | � |jd } | j�| �} | �||j�} |jd k�rD| � || || � t�d | � || fd fS )NzSending http request: %sZ HTTP_REQUEST)�methodr � streaming�urlr zbefore-send.%s.%s)r7 z-Exception received when sending HTTP request.T)�exc_inforT Z HTTP_RESPONSE�protocolr ZPARSED_RESPONSE) r1 r2 �history_recorder�recordrS r Zhas_streaming_inputrU r r9 r6 r: r r$ r< r �_sendr � Exceptionr �copyr �metadatar) Z create_parser�parseZ output_shaper �_add_modeled_error_fields) r+ r7 r r6 r? � responsesr �er Zhttp_response_record_dictrW �parserrQ r r r rR � sN � � � � � zEndpoint._do_get_responsec C sT |� di �� d�}|d u r d S |j}|�|�}|d u r:d S |�||�}|�|� d S )N�ErrorZCode)r r9 Zshape_for_error_coder^ �update) r+ r rQ r rb Z error_coder9 Z error_shapeZ modeled_parser r r r_ � s z"Endpoint._add_modeled_error_fieldsc C sf |j j�� }d||jf }| jj||| ||||d�}t|�} | d u rHdS t�d| � t � | � dS d S )Nzneeds-retry.%s.%s)�responseZendpointZ operationrN �caught_exceptionr4 Fz3Response received to retry, sleeping for %s secondsT) r9 r6 r: r r$ r< r r1 r2 �time�sleep) r+ rN r r4 re rf r6 r? r` Zhandler_responser r r rM � s$ ��� zEndpoint._needs_retryc C s | j �|�S r" )r* �sendrJ r r r rZ s zEndpoint._send)NN)N)NN)�__name__� __module__� __qualname__�__doc__r/ r0 r5 rA rH r= r3 rL rR r_ rM rZ r r r r r! I s � / � r! c @ s@ e Zd Zdd� Zddeeeddddf dd�Zdd� Zdd � Z dS ) �EndpointCreatorc C s || _ d S r" )r$ )r+ r- r r r r/ s zEndpointCreator.__init__Nc C sj t |�std| ��| d u r&| �|�} |j} t�d| |� ||| | �|�|| | | d�}t|| | j||d�S )NzInvalid endpoint: %szSetting %s timeout as %s)�timeout�proxies�verify�max_pool_connections�socket_options� client_cert�proxies_config)r, r- r. r* ) r � ValueError� _get_proxiesr, r1 r2 �_get_verify_valuer! r$ )r+ r9 Z region_nameZ endpoint_urlrq r. ro rr Zhttp_session_clsrp rs rt ru r, r* r r r �create_endpoint s, � �z EndpointCreator.create_endpointc C s t |�S r" )r )r+ rU r r r rw 7 s z EndpointCreator._get_proxiesc C s |d ur |S t j�dd�S )N�REQUESTS_CA_BUNDLET)�os�environr )r+ rq r r r rx < s z!EndpointCreator._get_verify_value) rj rk rl r/ �DEFAULT_TIMEOUT�MAX_POOL_CONNECTIONSr ry rw rx r r r r rn s � #rn )!r{ �loggingrg r& Zbotocore.vendoredr Zbotocore.awsrequestr Zbotocore.exceptionsr Zbotocore.httpsessionr Zbotocore.utilsr r Zbotocore.hooksr Zbotocore.historyr Zbotocore.responser Zbotocorer � getLoggerrj r1 rX r} r~ r �objectr! rn r r r r �<module> s( # H
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка