File: //opt/alt/python37/lib/python3.7/site-packages/botocore/__pycache__/discovery.cpython-37.pyc
B
�P�eC+ � @ s� d dl Z d dlZd dlZd dlmZ d dlmZmZmZ d dl m
Z
d dl m Z e �
e�ZG dd� de�ZG dd � d e�ZG d
d � d e�Zd d
� ZG dd� d�ZG dd� d�ZG dd� d�ZdS )� N)�
xform_name)�
BotoCoreError�ConnectionError�HTTPClientError)�OperationNotFoundError)�CachedPropertyc @ s e Zd ZdS )�EndpointDiscoveryExceptionN)�__name__�
__module__� __qualname__� r r �C/opt/alt/python37/lib/python3.7/site-packages/botocore/discovery.pyr s r c @ s e Zd ZdZdZdS )�EndpointDiscoveryRequiredzBEndpoint Discovery is disabled but is required for this operation.zAEndpoint Discovery is not enabled but this operation requires it.N)r r
r �__doc__�fmtr r r r
r s r c @ s e Zd ZdZdZdS )� EndpointDiscoveryRefreshFailedz=Endpoint Discovery failed to the refresh the known endpoints.z<Endpoint Discovery failed to refresh the required endpoints.N)r r
r r r r r r r
r # s r c K s | j }|r|�d�rt� �d S )N�required)�endpoint_discovery�getr )�model�kwargsr r r r
�,block_endpoint_discovery_required_operations) s r c @ sN e Zd Zdd� Zedd� �Zedd� �Zdd� Zd d
� Zd d � Z ddd�Z
d
S )�EndpointDiscoveryModelc C s
|| _ d S )N)�_service_model)�self�
service_modelr r r
�__init__0 s z EndpointDiscoveryModel.__init__c C s | j j}t|j�S )N)r � endpoint_discovery_operationr �name)r �discovery_operationr r r
�discovery_operation_name3 s z/EndpointDiscoveryModel.discovery_operation_namec C s& | j j}g }|jr"t|jj�� �}|S )N)r r � input_shape�list�members�keys)r r r$ r r r
�discovery_operation_keys8 s
z/EndpointDiscoveryModel.discovery_operation_keysc C s4 y| j �|�}|j�dd�S tk
r. dS X d S )Nr F)r �operation_modelr r r )r �operation_namer& r r r
�discovery_required_for@ s z-EndpointDiscoveryModel.discovery_required_forc s> | j � |�d�s(|�dd � |�dd � � fdd�|�� D �S )N� Identifiers� Operationc s i | ]\}}|� kr||�qS r r )�.0�k�v)�
input_keysr r
�
<dictcomp>O s zEEndpointDiscoveryModel.discovery_operation_kwargs.<locals>.<dictcomp>)r% r �pop�items)r r r )r. r
�discovery_operation_kwargsI s
z1EndpointDiscoveryModel.discovery_operation_kwargsc C s | � |j|�S )N)� _gather_idsr! )r � operation�paramsr r r
�gather_identifiersQ s z)EndpointDiscoveryModel.gather_identifiersNc C sf |d kr i }xT|j �� D ]F\}}|j�d�r:|| ||< q|jdkr||kr| �||| |� qW |S )NZendpointdiscoveryidZ structure)r# r1 �metadatar � type_namer3 )r �shaper5 �ids� member_nameZ member_shaper r r
r3 T s z"EndpointDiscoveryModel._gather_ids)N) r r
r r r r r% r( r2 r6 r3 r r r r
r / s r c @ sn e Zd Zddd�Zdd� Zdd� Zd d
� Zd d � Zd
d� Zdd� Z dd� Z
dd� Z dd� Z dd� Z
dd� ZdS ) �EndpointDiscoveryManagerNTc C sP |d kr i }|| _ i | _|d kr&tj}|| _|| _t�|�| _t|j j
�| _ d S )N) �_cache�_failed_attempts�time�_time�_always_discover�weakref�proxy�_clientr �metar �_model)r �client�cache� current_timeZalways_discoverr r r
r d s z!EndpointDiscoveryManager.__init__c C s< |d }| � � }x&|D ] }|�d�}||d |d< qW |S )NZ EndpointsZCachePeriodInMinutes�< �
Expiration)r@ r )r �response� endpointsrI �endpointZ
cache_timer r r
�_parse_endpointsu s
z)EndpointDiscoveryManager._parse_endpointsc C s" t |t�rtt|�� ��S |S d S )N)�
isinstance�dict�tuple�sortedr1 )r �valuer r r
� _cache_item} s
z$EndpointDiscoveryManager._cache_itemc s, � j jf |�}t� fdd�t|�� �D ��S )Nc 3 s | ]\}}� � |�V qd S )N)rU )r+ r, r- )r r r
� <genexpr>� s z=EndpointDiscoveryManager._create_cache_key.<locals>.<genexpr>)rF r2 rR rS r1 )r r r )r r
�_create_cache_key� s z*EndpointDiscoveryManager._create_cache_keyc C s | j �||�S )N)rF r6 )r r4 r5 r r r
r6 � s z+EndpointDiscoveryManager.gather_identifiersc K s" | j f |�}|| jkr | j|= d S )N)rW r= )r r � cache_keyr r r
�delete_endpoints� s
z)EndpointDiscoveryManager.delete_endpointsc K s8 | j jf |�}| j j}t| j|�}t�d|� |f |�S )Nz%Discovering endpoints with kwargs: %s)rF r2 r �getattrrD �logger�debug)r r r' r r r r
�_describe_endpoints� s
z,EndpointDiscoveryManager._describe_endpointsc s. || j krd S | �� � � fdd�| j | D �S )Nc s g | ]}� |d k r|�qS )rK r )r+ �e)�nowr r
�
<listcomp>� s zCEndpointDiscoveryManager._get_current_endpoints.<locals>.<listcomp>)r= r@ )r �keyr )r_ r
�_get_current_endpoints� s
z/EndpointDiscoveryManager._get_current_endpointsc K sn | j f |�}y2| jf |�}| �|�}|| j|< | j�|d � |S ttfk
rh | �� d | j|< d S X d S )NrJ ) rW r] rO r= r> r0 r r r@ )r r rX rL rM r r r
�_refresh_current_endpoints� s
z3EndpointDiscoveryManager._refresh_current_endpointsc C s0 || j kr,| �� }|| j | k r$dS | j |= dS )NTF)r> r@ )r rX r_ r r r
�_recently_failed� s
z)EndpointDiscoveryManager._recently_failedc C s |d d S )Nr ZAddressr )r rM r r r
�_select_endpoint� s z)EndpointDiscoveryManager._select_endpointc K s� |d }| j �|�}| js0|s0t�d| � d S | jf |�}| �|�}|rT| �|�S | �|�}|s|| j f |�}|r|| �|�S t�d|� | j
� |d �}|r�| �|�S |r�|r�| j f |�}|r�| �|�S t � �d S )Nr* zAOptional discovery disabled. Skipping discovery for Operation: %sz%Endpoint Discovery has failed for: %s)
rF r( rA r[ r\ rW rb re rd rc r= r r )r r r4 Zdiscovery_requiredrX rM Zrecently_failedZ
stale_entriesr r r
�describe_endpoint� s6
z*EndpointDiscoveryManager.describe_endpoint)NNT)r r
r r rO rU rW r6 rY r] rb rc rd re rf r r r r
r< c s
r< c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) �EndpointDiscoveryHandlerc C s
|| _ d S )N)�_manager)r �managerr r r
r � s z!EndpointDiscoveryHandler.__init__c C s: |� d| | j� |�d| | j� |� d| | j� d S )Nzbefore-parameter-build.%szrequest-created.%szneeds-retry.%s)�registerr6 Zregister_first�discover_endpoint�handle_retries)r �eventsZ
service_idr r r
rj � s
z!EndpointDiscoveryHandler.registerc K s0 |j }|d krd S | j�||�}d|i|d< d S )N� identifiers� discovery)r rh r6 )r r5 r �contextr r r: r r r
r6 � s
z+EndpointDiscoveryHandler.gather_identifiersc K sn |j �di ��d�}|d kr d S | jj||d�}|d krFt�d� d S |�d�sXd| }t�d|� ||_d S )Nro rn )r* r) z&Failed to discover and inject endpoint�httpzhttps://z!Injecting discovered endpoint: %s)rp r rh rf r[ r\ �
startswith�url)r �requestr' r r: rN r r r
rk � s
z*EndpointDiscoveryHandler.discover_endpointc
K s� |d kr d S |\}}|� di �� d�}|� di �� d�}|dkrL|dkrLd S |� di �}|� di �� d �} | d krvd S | jj|j| d
� d S ) NZResponseMetadataZHTTPStatusCode�ErrorZCodei� ZInvalidEndpointExceptionrp ro rn )r* r) r )r rh rY r )
r Z request_dictrL r4 r �_�statusZ
error_coderp r: r r r
rl s z'EndpointDiscoveryHandler.handle_retriesN)r r
r r rj r6 rk rl r r r r
rg � s
rg )�loggingr? rB Zbotocorer Zbotocore.exceptionsr r r Zbotocore.modelr Zbotocore.utilsr � getLoggerr r[ r r r r r r< rg r r r r
�<module>
s
4~