File: //usr/lib/python3.6/site-packages/botocore/__pycache__/endpoint.cpython-36.pyc
3
�T_�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 eje�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 jd�}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 i, �bodyr zcontent-length) r r �nameZcontent�has_event_stream_output�raw�has_streaming_output�getr
)�
http_response�operation_model�
response_dictZlength� r � /usr/lib/python3.6/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 || _ || _|| _tj� | _|d kr,tj� }|| _|| _ | j d krJt
� | _ d S )N) �_endpoint_prefix�_event_emitter�host� threadingZLock�_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 jd||� | j||�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�|_|jjj� }dj||j d�}| j
j |||j d� | j |�}|S )Nz&request-created.{service_id}.{op_name})�
service_idZop_name)�requestr )
r �anyr r Z
stream_output�
service_modelr1 � hyphenize�formatr r �emit�prepare_request)r& Zparamsr r2 r1 �
event_nameZprepared_requestr r r �create_requesth s
zEndpoint.create_requestc C s4 x.|j � D ]"\}}t|tj�r
|jd�||< q
W d S )Nzutf-8)�items�
isinstancer Z text_type�encode)r& r �key�valuer r r �_encode_headersx s zEndpoint._encode_headersc C s | j |j� |j� S )N)r@ r Zprepare)r& r2 r r r r8 ~ s zEndpoint.prepare_requestc C s� d}| j ||�}|d }| j|||�\}}xD| j|||||�rn|d7 }|j� | j ||�}| j|||�\}}q,W |d k r�d|d kr�|d }||d d d< |d k r�|�n|S d S )N� r ZResponseMetadataZ
RetryAttempts)r: �
_get_response� _needs_retryZ reset_stream) r& r/ r �attemptsr2 r �success_response� exceptionZ
total_retriesr r r r. � s( zEndpoint._send_requestc
C sr | j ||�\}}d d ||d�}|d k rD|\}}||d< t||�|d< |jjj� } | jjd| |jf f|� ||fS )N)r �parsed_responser rF rG r zresponse-received.%s.%s)�_do_get_responser r4 r1 r5 r r7 r )
r& r2 r r rE rF Zkwargs_to_emitr rG r1 r r r rB � s zEndpoint._get_responsec
C sL yvt jd|� tjd|j|j|j|j|jd�� |j j
j � }d||j f }| j
j||d�}t|�}|d krt| j|�}W nT tk
r� } zd |fS d }~X n2 tk
r� } zt jddd� d |fS d }~X nX t||�}|j� } |j| d < tjd
| � |jd }
| jj|
�} | j||j�} |jd k�r4| j || || � tjd
| � || fd fS )NzSending http request: %sZ HTTP_REQUEST)�methodr � streaming�urlr zbefore-send.%s.%s)r2 z-Exception received when sending HTTP request.T)�exc_inforJ Z
HTTP_RESPONSE�protocoli, ZPARSED_RESPONSE) r, r- �history_recorder�recordrI r Zhas_streaming_inputrK r r4 r1 r5 r r r7 r �_sendr � Exceptionr �copyr Zmetadatar$ Z
create_parser�parseZ output_shaper �_add_modeled_error_fields)
r& r2 r r1 r9 � responsesr �er Zhttp_response_record_dictrM �parserrG r r r rH � sD
zEndpoint._do_get_responsec C sT |j di �j d�}|d kr d S |j}|j|�}|d kr:d S |j||�}|j|� d S )N�ErrorZCode)r r4 Zshape_for_error_coderS �update) r& r rG r rW Z
error_coder4 Z error_shapeZ
modeled_parser r r rT � s
z"Endpoint._add_modeled_error_fieldsc
C sf |j jj� }d||jf }| jj||| ||||d�}t|�} | d krHdS tjd| � t j
| � dS d S )Nzneeds-retry.%s.%s)�responseZendpointZ operationrD �caught_exceptionr/ Fz3Response received to retry, sleeping for %s secondsT) r4 r1 r5 r r r7 r r, r- �timeZsleep)
r& rD r r/ rZ r[ r1 r9 rU Zhandler_responser r r rC � s
zEndpoint._needs_retryc C s | j j|�S )N)r% �send)r& r2 r r r rP s zEndpoint._send)NN)N)NN)�__name__�
__module__� __qualname__�__doc__r* r+ r0 r: r@ r8 r. rB rH rT rC rP r r r r r I s
/
r c @ s> e Zd Zdd� Zddeeedddfdd�Zdd� Zdd � Z dS )
�EndpointCreatorc C s
|| _ d S )N)r )r& r( r r r r* s zEndpointCreator.__init__Nc C sh t |�std| ��| d kr&| j|�} |j} tjd| |� ||| | j|�||
| d�}
t|| | j||
d�S )NzInvalid endpoint: %szSetting %s timeout as %s)�timeout�proxies�verify�max_pool_connections�socket_options� client_cert)r' r( r) r% ) r �
ValueError� _get_proxiesr' r, r- �_get_verify_valuer r )r& r4 Z region_nameZ endpoint_urlre r) rc rf Zhttp_session_clsrd rg rh r' r% r r r �create_endpoint s&
z EndpointCreator.create_endpointc C s t |�S )N)r )r& rK r r r rj 5 s z EndpointCreator._get_proxiesc C s |d k r |S t jjdd�S )NZREQUESTS_CA_BUNDLET)�os�environr )r& re r r r rk : s z!EndpointCreator._get_verify_value)
r^ r_ r` r* �DEFAULT_TIMEOUT�MAX_POOL_CONNECTIONSr rl rj rk r r r r rb s rb )!rm Zloggingr\ r" Zbotocore.vendoredr Zbotocore.awsrequestr Zbotocore.exceptionsr Zbotocore.httpsessionr Zbotocore.utilsr r Zbotocore.hooksr Zbotocore.historyr Zbotocore.responser
Zbotocorer Z getLoggerr^ r, rN ro rp r �objectr rb r r r r �<module> s(
# H