Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/botocore/__pycache__/discovery.cpython-39.pyc
Ðазад
a p�h+ � @ 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� de�ZG dd� de�ZG dd� de�ZdS )� N)� xform_name)� BotoCoreError�HTTPClientError�ConnectionError)�OperationNotFoundError)�CachedPropertyc @ s e Zd ZdS )�EndpointDiscoveryExceptionN)�__name__� __module__� __qualname__� r r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/botocore/discovery.pyr s r c @ s e Zd ZdZdZdS )�EndpointDiscoveryRequiredzD Endpoint 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.Nr 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__. s z EndpointDiscoveryModel.__init__c C s | j j}t|j�S r )r � endpoint_discovery_operationr �name)r �discovery_operationr r r �discovery_operation_name1 s z/EndpointDiscoveryModel.discovery_operation_namec C s& | j j}g }|jr"t|jj�� �}|S r )r r � input_shape�list�members�keys)r r! r& r r r �discovery_operation_keys6 s z/EndpointDiscoveryModel.discovery_operation_keysc C s6 z | j �|�}|j�dd�W S ty0 Y dS 0 d S )Nr F)r �operation_modelr r r )r �operation_namer( r r r �discovery_required_for> s z-EndpointDiscoveryModel.discovery_required_forc sB | j � |�d�s(|�dd � |�dd � t� fdd�|�� D ��S )N� Identifiers� Operationc 3 s" | ]\}}|� v r||fV qd S r r ��.0�k�v�Z input_keysr r � <genexpr>K � zDEndpointDiscoveryModel.discovery_operation_kwargs.<locals>.<genexpr>)r' r �pop�dict�items�r r r r1 r �discovery_operation_kwargsE s z1EndpointDiscoveryModel.discovery_operation_kwargsc C s | � |j|�S r )� _gather_idsr# �r � operation�paramsr r r �gather_identifiersM s z)EndpointDiscoveryModel.gather_identifiersNc C sb |d u r i }|j �� D ]F\}}|j�d�r8|| ||< q|jdkr||v r| �||| |� q|S )NZendpointdiscoveryidZ structure)r% r6 �metadatar � type_namer9 )r �shaper< �ids� member_nameZ member_shaper r r r9 P s z"EndpointDiscoveryModel._gather_ids)N) r r r r r r" r' r* r8 r= r9 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 u r i }|| _ i | _|d u r&tj}|| _|| _t�|�| _t|j j �| _ d S r ) �_cache�_failed_attempts�time�_time�_always_discover�weakref�proxy�_clientr �metar �_model)r �client�cache� current_timeZalways_discoverr r r r ^ s z!EndpointDiscoveryManager.__init__c C s8 |d }| � � }|D ] }|�d�}||d |d< q|S )NZ EndpointsZCachePeriodInMinutes�< � Expiration)rG r )r �response� endpointsrP �endpointZ cache_timer r r �_parse_endpointsm s z)EndpointDiscoveryManager._parse_endpointsc C s" t |t�rtt|�� ��S |S d S r )� isinstancer5 �tuple�sortedr6 )r �valuer r r � _cache_itemu s z$EndpointDiscoveryManager._cache_itemc s0 � j jf i |��}t� fdd�t|�� �D ��S )Nc 3 s | ]\}}� � |�V qd S r )r[ r- �r r r r2 } r3 z=EndpointDiscoveryManager._create_cache_key.<locals>.<genexpr>)rM r8 rX rY r6 r7 r r\ r �_create_cache_key{ s z*EndpointDiscoveryManager._create_cache_keyc C s | j �||�S r )rM r= r: r r r r= s z+EndpointDiscoveryManager.gather_identifiersc K s& | j f i |��}|| jv r"| j|= d S r )r] rD )r r � cache_keyr r r �delete_endpoints� s z)EndpointDiscoveryManager.delete_endpointsc K s@ | j jf i |��}| j j}t| j|�}t�d|� |f i |��S )Nz%Discovering endpoints with kwargs: %s)rM r8 r" �getattrrK �logger�debug)r r r) r! r r r �_describe_endpoints� s z,EndpointDiscoveryManager._describe_endpointsc s. || j vrd S | �� � � fdd�| j | D �S )Nc s g | ]}� |d k r|�qS )rR r )r. �e��nowr r � <listcomp>� r3 zCEndpointDiscoveryManager._get_current_endpoints.<locals>.<listcomp>)rD rG )r �keyr re r �_get_current_endpoints� s z/EndpointDiscoveryManager._get_current_endpointsc K sx | j f i |��}z8| jf i |��}| �|�}|| j|< | j�|d � |W S ttfyr | �� d | j|< Y d S 0 d S )NrQ ) r] rc rV rD rE r4 r r rG )r r r^ rS rT r r r �_refresh_current_endpoints� s z3EndpointDiscoveryManager._refresh_current_endpointsc C s0 || j v r,| �� }|| j | k r$dS | j |= dS )NTF)rE rG )r r^ rf r r r �_recently_failed� s z)EndpointDiscoveryManager._recently_failedc C s |d d S )Nr ZAddressr )r rT r r r �_select_endpoint� s z)EndpointDiscoveryManager._select_endpointc K s� |d }| j �|�}| js0|s0t�d| � d S | jf i |��}| �|�}|rX| �|�S | �|�}|s�| j f i |��}|r�| �|�S t�d|� | j � |d �}|r�| �|�S |r�|r�| j f i |��}|r�| �|�S t � �d S )Nr, zAOptional discovery disabled. Skipping discovery for Operation: %sz%Endpoint Discovery has failed for: %s) rM r* rH ra rb r] ri rl rk rj rD r r )r r r; Zdiscovery_requiredr^ rT Zrecently_failedZ stale_entriesr r r �describe_endpoint� s: �� z*EndpointDiscoveryManager.describe_endpoint)NNT)r r r r rV r[ r] r= r_ rc ri rj rk rl rm r r r r rC ] s rC c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd S ) �EndpointDiscoveryHandlerc C s || _ d S r )�_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)�registerr= Zregister_first�discover_endpoint�handle_retries)r �eventsZ service_idr r r rq � s � �z!EndpointDiscoveryHandler.registerc K s0 |j }|d u rd S | j�||�}d|i|d< d S )N� identifiers� discovery)r ro r= )r r< r �contextr r rA r r r r= � s z+EndpointDiscoveryHandler.gather_identifiersc K sn |j �di ��d�}|d u r d S | jj||d�}|d u rFt�d� d S |�d�sXd| }t�d|� ||_d S )Nrv ru �r, r+ z&Failed to discover and inject endpoint�httpzhttps://z!Injecting discovered endpoint: %s)rw r ro rm ra rb � startswith�url)r �requestr) r rA rU r r r rr � s � z*EndpointDiscoveryHandler.discover_endpointc K s� |d u r d S |\}}|� di �� d�}|� di �� d�}|dkrL|dkrLd S |� di �}|� di �� d �} | d u rvd S | jj|j| d � d S ) NZResponseMetadataZHTTPStatusCode�ErrorZCodei� ZInvalidEndpointExceptionrw rv ru rx r )r ro r_ r ) r Z request_dictrS r; r �_�statusZ error_coderw rA r r r rs � s �z'EndpointDiscoveryHandler.handle_retriesN)r r r r rq r= rr rs r r r r rn � s rn )rF �loggingrI Zbotocorer Zbotocore.exceptionsr r r Zbotocore.modelr Zbotocore.utilsr � getLoggerr ra r r r r �objectr rC rn r r r r �<module> s 0|
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка