File: //usr/local/CyberCP/lib64/python3.10/site-packages/botocore/__pycache__/client.cpython-310.pyc
o
�h�� � @ s� d dl Z d dlmZmZ d dlmZ d dlmZ d dlm Z d dl
m Z d dl m
Z
d dlmZ d d lmZmZmZ d d
lmZmZ d d lmZmZmZmZm Z d d l m Z d d
l m Z d dl!m"Z"m#Z# d dl$m%Z% d dl&m'Z' d dl(m)Z)m*Z* d dl+m,Z, d dl-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4 d dlm5Z5 d dl-m6Z6 d dl-m7Z7 d dl-m8Z8 d dl-m9Z9 d dl-m:Z: d dlm;Z; e<d�Z=e �>e?�Z@e � ZAG d d � d �ZBG d d � d �ZCG d d!� d!�ZDG d"d#� d#�ZEd$d%� ZFdS )&� N)�waiter�
xform_name)�ClientArgsCreator)�AUTH_TYPE_MAPS)�prepare_request_dict)�maybe_compress_request)�Config)�RefreshableCredentials)�EndpointDiscoveryHandler�EndpointDiscoveryManager�,block_endpoint_discovery_required_operations)�ClientMethodDocstring�PaginatorDocstring)�DataNotFoundError�*InvalidEndpointDiscoveryConfigurationError�OperationNotPageableError�UnknownServiceError� UnknownSignatureVersionError)�get_global_history_recorder)�first_non_none_response)�apply_request_checksum�resolve_checksum_context)� ServiceModel)� Paginator)�adaptive�standard)�UserAgentString)�CachedProperty�EventbridgeSignerSetter�S3ControlArnParamHandlerv2�S3ExpressIdentityResolver�S3RegionRedirectorv2�ensure_boolean�get_service_module_name)� ClientError)�S3ArnParamHandler)�S3ControlArnParamHandler)�S3ControlEndpointSetter)�S3EndpointSetter)�S3RegionRedirector)�UNSIGNED)�v2�v3�v3https�v4�s3�s3v4c @ s e Zd ZdZ d:dd�Z d;dd�Zd<dd �Zd
d � Zd d
� Zd<dd�Z d<dd�Z
dd� Z dd� Z dd� Z
dd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Z d:d&d'�Zd(d)� Z d:d*d+�Zd,d-� Zd.d/� Zd0d1� Zd2d3� Zd4d5� Z d6d7� Z d8d9� Z dS )=�
ClientCreatorz%Creates client objects for a service.Nc C s@ || _ || _|| _|| _|| _|| _|| _|| _| | _|
| _ d S �N)
�_loader�_endpoint_resolver� _user_agent�_event_emitter�_retry_handler_factory�_retry_config_translator�_response_parser_factory�_exceptions_factory�
_config_store�_user_agent_creator) �self�loader�endpoint_resolver�
user_agent�
event_emitter�retry_handler_factory�retry_config_translator�response_parser_factory�exceptions_factory� config_store�user_agent_creator� rH �B/usr/local/CyberCP/lib/python3.10/site-packages/botocore/client.py�__init__W s
zClientCreator.__init__Tc C s& | j jd|d�} t| |d�}| �||�} z| �||�}
| j�d�}W n ty5 d }
d }t� d|� Y nw | �
|| �}| � || �\}} t | j
|| | j�d�| j| j�d�d�}| �| ||||||| ||
|
|� }|d i |��}| �|� | j|d d | |d � | j|d
� | j|d
� | �||| � |S ) Nzchoose-service-name�� service_name��default�
partitionszSNo endpoints ruleset found for service %s, falling back to legacy endpoint routing.� signingName�signatureVersion)�service_signing_namerF �service_signature_version)�client�endpoint_bridge� endpoint_url�
client_config�
scoped_config�rT rH )r6 �emitr �_load_service_model� _load_service_endpoints_rulesetr3 � load_datar �logger�info�_create_client_class�_normalize_fips_region�ClientEndpointBridger4 �metadata�getr; �_get_client_args�_register_retries�_register_s3_events�_register_s3express_events�_register_s3_control_events� _register_endpoint_discovery)r= rL � region_name� is_securerV �verify� credentialsrX � api_versionrW �
auth_token� responses�
service_model�endpoints_ruleset_data�partition_data�clsrU � client_args�service_clientrH rH rI �
create_clients sz
� � �� �
��
�
� �zClientCreator.create_clientc C s | � ||�}| �||�S r2 )r[ r` )r= rL ro rr rH rH rI �create_client_class� s z!ClientCreator.create_client_classc C sd | � |�}| �|�}||d< tg}|j�� }| jjd|� �||d� t|�}tt |�t
|�|�}|S )N�_PY_TO_OP_NAMEzcreating-client-class.)�class_attributes� base_classes) �_create_methods�_create_name_mapping�
BaseClient�
service_id� hyphenizer6 rZ r# �type�str�tuple) r= rL rr r{ �py_name_to_operation_name�basesr� �
class_nameru rH rH rI r` � s
�z"ClientCreator._create_client_classc C sf |d ur/|� dd�� dd�}||kr/tdd�}|r |�|�}n|}t�d|� d|� d�� |}||fS ) Nzfips-� z-fipsT)�use_fips_endpointztransforming region from z to zb and setting use_fips_endpoint to true. client should not be configured with a fips psuedo region.)�replacer �merger^ �warning)r= rk rW �normalized_region_name�config_use_fips_endpointrH rH rI ra � s$ �
���z$ClientCreator._normalize_fips_regionc C s" | j j|d|d�}t||d�}|S )Nz service-2�ro rK )r3 �load_service_modelr )r= rL ro �
json_modelrr rH rH rI r[ � s
� z!ClientCreator._load_service_modelc C s | j j|d|d�S )Nzendpoint-rule-set-1r� )r3 r� )r= rL ro rH rH rI r\ � s �z-ClientCreator._load_service_endpoints_rulesetc C s^ |j jjd }|dkr| �|� d S |dkr"| �|� | �|� d S |dkr-| �|� d S d S )N�moder r �legacy)�meta�config�retries� _register_v2_standard_retries� _register_v2_adaptive_retries�_register_legacy_retries)r= rT �
retry_moderH rH rI rf � s
�z ClientCreator._register_retriesc C s< |j jj�d�}d|i}|d ur||d< tjdi |�� d S )N�total_max_attemptsrT � max_attemptsrH )r� r� r� rd r �register_retry_handler)r= rT r� �kwargsrH rH rI r� s
z+ClientCreator._register_v2_standard_retriesc C s t �|� d S r2 )r r� )r= rT rH rH rI r� s z+ClientCreator._register_v2_adaptive_retriesc
C s� |j jj}|j jj}|�� }| j�d�}|sd S | �|j jj �}| j
� ||� di �|� di �|�}t
�d|j jj� | j�||�}d|� �} |j jjd|� �|| d� d S )N�_retry�retry� definitionsz*Registering retry handlers for service: %sz
retry-config-z needs-retry.)� unique_id)r� rr �endpoint_prefixr� r� r3 r] �_transform_legacy_retriesr� r� r8 �build_retry_configrd r^ �debugrL r7 �create_retry_handler�events�register)
r= rT r� r� �service_event_name�original_configr� � retry_config�handlerr� rH rH rI r�
s0
���
�z&ClientCreator._register_legacy_retriesc C s: |d u rd S |� � }d|v r|� � }|�d�d |d< |S )Nr� � r� )�copy�pop)r= r� � copied_argsrH rH rI r� ) s �z'ClientCreator._transform_legacy_retriesc C s6 |j jj}|d ur|�d�d ur|d S |�d�pdS )Nr� r� r� )r� r� r� rd �get_config_variable)r= rT rF �client_retriesrH rH rI �_get_retry_mode4 s
z ClientCreator._get_retry_modec
C s� |d urd S |j jjd u rd S |j j}|j jj�� }d}|r'|jd ur'|j}n | jr0| j�d�}| � |�}|rS| �
||�rS|du }t ||d�}t |�} | �
||� d S |�
dt� d S )NF�endpoint_discovery_enabledT)�always_discoverzbefore-parameter-build)r� rr � endpoint_discovery_operationr� r� r� r� r; r� �$_normalize_endpoint_discovery_config� _requires_endpoint_discoveryr r
r� r )
r= rT rV r� r� r� �enabled�discover�managerr� rH rH rI rj = s2 �
��z*ClientCreator._register_endpoint_discoveryc C sL t |t�r|�� �� }|dkr|S |dv rt|�S nt |t�r!|S t|d��)z?Config must either be a boolean-string or string-literal 'auto'�auto)�true�false)� config_value)�
isinstancer� �lower�stripr" �boolr )r= r� rH rH rI r� \ s
�
z2ClientCreator._normalize_endpoint_discovery_configc C s |dkr |j jjS |S )Nr� )r� rr �endpoint_discovery_required)r= rT r� rH rH rI r� i s
z*ClientCreator._requires_endpoint_discoveryc C s4 |j jjdkr d S t| j|j j|d��|j j� d S )Nr� )r? �regionrV )r� rr rL r r4 rk r� r� )r= rT rU rV rH rH rI � _register_eventbridge_eventsn s �z*ClientCreator._register_eventbridge_eventsc C s$ |j jjdkr d S t|t��� d S )Nr/ )r� rr rL r r r� �r= rT rU rV rW rX rH rH rI rh y s z(ClientCreator._register_s3express_eventsc C sF |j jjdkr d S td |��� | �|j ||� |j j�d| j� d S )Nr/ zbefore-parameter-build.s3)r� rr rL r! r� �!_set_s3_presign_signature_versionr� �_inject_s3_input_parametersr� rH rH rI rg � s ��z!ClientCreator._register_s3_eventsc C s& |j jjdkr d S t� �|j j� d S )N� s3control)r� rr rL r r� r� r� rH rH rI ri � s z)ClientCreator._register_s3_control_eventsc C sx t d||�}|d ur d S | j�d|j�}|jdkr |j|vr d S | j�d|j�}|d }d|vr2d S |j�d| j� d S )Nr/ z
aws-global�signatureVersionszchoose-signer.s3) �!_get_configured_signature_versionr4 �get_available_endpoints� partitionrk �construct_endpointr� r� � _default_s3_presign_to_sigv2)r= � client_metarW rX �provided_signature_version�regions�endpoint�signature_versionsrH rH rI r� � s( ��
��z/ClientCreator._set_s3_presign_signature_versionc K s2 i |d< d}|D ]}||v r|| |d |< qd S )N� input_params)�Bucket�Delete�Key�PrefixrH )r= �params�contextr� �inject_parameters�inject_parameterrH rH rI r� � s ���z)ClientCreator._inject_s3_input_parametersc K sD |� d�rdS |� d�r|� S dD ]}|�|�r d|� � S qdS )a@
Returns the 's3' (sigv2) signer if presigning an s3 request. This is
intended to be used to set the default signature version for the signer
to sigv2. Situations where an asymmetric signature is required are the
exception, for example MRAP needs v4a.
:type signature_version: str
:param signature_version: The current client signature version.
:type signing_name: str
:param signing_name: The signing name of the service.
:return: 's3' if the request is an s3 presign request, None otherwise
�v4aNz v4-s3express)z-queryz
-presign-postr/ )�
startswith�endswith)r= �signature_versionr� �suffixrH rH rI r� � s
��z*ClientCreator._default_s3_presign_to_sigv2c
C sD t | j| j| j| j| j| j| jd�}
|
�||||||||| |
| | � S )N)rF rG ) r r6 r5 r9 r3 r: r; r< �get_client_args)r= rr rk rl rV rm rn rX rW rU rp rs rt � args_creatorrH rH rI re � s. � �z ClientCreator._get_client_argsc C s. i }|j D ]}t|�}| �|||�||< q|S r2 )�operation_namesr �_create_api_method)r= rr �op_dict�operation_name�py_operation_namerH rH rI r} s
�z ClientCreator._create_methodsc C s$ i }|j D ]
}t|�}|||< q|S r2 )r� r )r= rr �mappingr� r� rH rH rI r~ s
z"ClientCreator._create_name_mappingc sJ � �fdd�}t ��|_|�� �}t|� | j|jd�� �dd�}||_|S )Nc s |r t �� d���| �� |�S )Nz"() only accepts keyword arguments.)� TypeError�_make_api_call)r= �argsr� �r� r� rH rI � _api_call, s
� z3ClientCreator._create_api_method.<locals>._api_callzresponse = client.F)�operation_model� method_namerA �method_description�example_prefix�include_signature)r� �__name__r� r
r6 �
documentation�__doc__)r= r� r� rr r� r� � docstringrH r� rI r� ) s
�z ClientCreator._create_api_method)NNNN)TNNNNNNNr2 ) r� �
__module__� __qualname__r� rJ rx ry r` ra r[ r\ rf r� r� r� r� r� rj r� r� r� rh rg ri r� r� r� re r} r~ r� rH rH rH rI r1 T sb
�
�
L
�
� + ' r1 c @ s� e Zd ZdZdZddgZ d#dd�Z d$d d
�Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd � Zd d � Zd d � Zd!d"� ZdS )%rb a� Bridges endpoint data and client creation
This class handles taking out the relevant arguments from the endpoint
resolver and determining which values to use, taking into account any
client configuration options and scope configuration options.
This class also handles determining what, if any, region to use if no
explicit region setting is provided. For example, Amazon S3 client will
utilize "us-east-1" by default if no region can be resolved.z {service}.{region}.amazonaws.comr/ z
s3-controlNc C s4 || _ || _|| _|| _|p| j| _|| _|| _d S r2 )rR r? rX rW �DEFAULT_ENDPOINT�default_endpointrF rS )r= r? rX rW r� rR rF rS rH rH rI rJ U s
z ClientEndpointBridge.__init__Tc C st | � ||�}| �|�}| �d�}| jj||||d�}|s'| jj||d||d�}|r2| �|||||�S | �||||�S )Nr� )�use_dualstack_endpointr� �aws)�partition_namer� r� )�_check_default_region� _resolve_use_dualstack_endpoint�$_resolve_endpoint_variant_config_varr? r� �_create_endpoint�_assume_endpoint)r= rL rk rV rl r� r� �resolvedrH rH rI �resolveg s8 ��� �
��z ClientEndpointBridge.resolvec C � | j jS r2 )r? �uses_builtin_data�r= rH rH rI �resolver_uses_builtin_data� s z/ClientEndpointBridge.resolver_uses_builtin_datac C s. |d ur|S | j r| j jd ur| j jS d S d S r2 )rW rk )r= rL rk rH rH rI r � s
�z*ClientEndpointBridge._check_default_regionc C sf | � |||�\}}|d u r| �|�d�||�dg ��}| �||�}| �||�}| j|||||||d�S )N�hostname� protocols)rL rk �signing_region� signing_namerV rc r� )�_pick_region_values� _make_urlrd �_resolve_signature_version�_resolve_signing_name�_create_result) r= r rL rk rV rl r r� r rH rH rI r � s, �
�� �z%ClientEndpointBridge._create_endpointc C s@ | j }d}|rt||�d urt||�S | jd ur | j�|�}|S )NF)rW �getattrrF r� )r= �
config_varrW �
config_valrH rH rI r � s
z9ClientEndpointBridge._resolve_endpoint_variant_config_varc C s | � |�}|d ur |S | �d�S )Nr� )�_is_s3_dualstack_moder )r= rL �s3_dualstack_moderH rH rI r � s
�z4ClientEndpointBridge._resolve_use_dualstack_endpointc C sl || j vrd S | j}|d ur |jd ur d|jv r |jd S | jd ur2| j�di ��d�}|dv r4dS d S d S )Nr� r/ )T�Truer� T)� _DUALSTACK_CUSTOMIZED_SERVICESrW r/ rX rd )r= rL rW r� rH rH rI r � s
��z*ClientEndpointBridge._is_s3_dualstack_modec C s~ |d u r| j j||d�}| �||ddg�}t�d|� d|� d|� �� | �|ddgi�}| j|i d �}| j||||||i d
�S ) N)�servicer� �http�httpszAssuming an endpoint for z, z: r� r. )r )rL rk r r r� rV rc )r� �formatr r^ r� r r r )r= rL rk rV rl r
r� r rH rH rI r � s. �
��
��z%ClientEndpointBridge._assume_endpointc C s |||||||d�S )N)rL rk r r rV r� rc rH )r= rL rk r r rV r� rc rH rH rI r � s �z#ClientEndpointBridge._create_resultc C s$ |r d|v r d}nd}|� d|� �S )Nr r z://rH )r= r
rl �supported_protocols�schemerH rH rI r
s z ClientEndpointBridge._make_urlc C s0 d|v rd|d v r|d d S | j r| j S |S )N�credentialScoper )rR )r= rL r rH rH rI r s z*ClientEndpointBridge._resolve_signing_namec C s@ |}|d u r |d }|}d|v r d|d v r |d d }||fS )N� endpointNamer# r� rH )r= r rk rV r rH rH rI r ! s z(ClientEndpointBridge._pick_region_valuesc C s� t || j| j�}|d ur|S |�dg �}| jd ur"| jtvr"| jg}d|v r?|dkr,dS d|v r2dS |D ]
}|tv r>| S q4t|d��)Nr� r/ r0 r. )r� )r� rW rX rd rS �_LEGACY_SIGNATURE_VERSIONSr r )r= rL r �configured_version�potential_versions�knownrH rH rI r 7 s.
�
���z/ClientEndpointBridge._resolve_signature_version)NNNNNN�NNT)r� r� r� r� r� r rJ r r r r r r r r r r r r r rH rH rH rI rb G s2
�
�'
rb c @ s� e Zd Zi Z d(dd�Zdd� Zdd� Zdd � Zed
d � �Z d d
� Z
dd� Z d)dd�Z dd� Z
d*dd�Zdd� Zdd� Zd d � Zd d � Zed d!� �Zed"d#� �Zd$d%� Zd&d'� ZdS )+r Nc
C s� || _ || _| | _|| _|| _i | _|| _|| _t|| j|j || j
| �| _ |
| _ d | _
| | _| jd u r<t�� �| j�| _| �� d S r2 )� _serializer� _endpoint�_ruleset_resolver�_response_parser�_request_signer�_cacher3 �_client_config�
ClientMeta�hostrz r� r: � _exceptionsr< r �from_environment�with_client_config�_register_handlers)
r= �
serializerr� �response_parserrA �request_signerrr r> rW r� rE �endpoint_ruleset_resolverrG rH rH rI rJ a s2 �
�� zBaseClient.__init__c C sX | j j�� }d|� d|� �}| jjj|| d�\}}|d ur |S td| jj� d|� d���)Nzgetattr.�.rY �'z' object has no attribute ') �_service_modelr� r� r� r� �emit_until_response�AttributeError� __class__r� )r= �itemr� �
event_namer� �event_responserH rH rI � __getattr__� s
��zBaseClient.__getattr__c C s | j �� dS )z'Closes underlying endpoint connections.N)r+ �closer rH rH rI rE � s zBaseClient.closec C s, | j jj�� }| j j�d|� �| jj� d S )Nzrequest-created.)r� rr r� r� r� r� r. r� )r= r� rH rH rI r6 � s �z BaseClient._register_handlersc C r r2 )r� rr r rH rH rI r= � � zBaseClient._service_modelc C s� | j �|�}| j j}t�d|||d�� |jr t�d||� | jj | jj
|j |j d�}| j
|||d�}| �|||�\}}}|rC||d< | j|||||d�} t| ||� | j j�� }
| jjjd|
� d |� �|| | j|d
�\} } | d urw| \}
}nt| jj
| |� t| � | �|| |�\}
}| jjjd |
� d |� �|
|||d � |
jd
kr�|�di �}|�d�p�|�d�}| j � |�}|||��|S )N�API_CALL)r � operationr� z Warning: %s.%s() is deprecated)�
client_regionrW �has_streaming_input� auth_type)�
api_paramsr� r� �endpoint_properties)rL r� rV r� �headersz before-call.r; )�modelr� r9 r� z after-call.)�
http_response�parsedrO r� i, �Error�QueryErrorCode�Code) r= r� rL �history_recorder�record�
deprecatedr^ r� r� rk r� rJ rK �_emit_api_params�_resolve_endpoint_ruleset�_convert_to_request_dictr r� r� r� r> r. r r �
_make_requestrZ � status_coderd �
exceptions� from_code)r= r� rL r� rL �request_contextrV �additional_headers�
properties� request_dictr� r� rC r �parsed_response�
error_info�
error_code� error_classrH rH rI r� � s� ����� ���
�
���
�
zBaseClient._make_api_callc
C sV z| j �||�W S ty* } z| jjjd| jj�� � d|j � �||d� � d }~ww )Nzafter-call-error.r; )� exceptionr� )
r+ � make_request� Exceptionr� r� rZ r= r� r� �name)r= r� rb r_ �erH rH rI r[ � s ���zBaseClient._make_requestTc C s` | j �||�}| jjs|�dd � |d ur |d �|� |r$| j�� }nd }t||||d� |S )N� host_prefixrN )rV r@ r� ) r* �serialize_to_requestr0 �inject_host_prefixr� �updater< � to_stringr ) r= rL r� rV r� rN �set_user_agent_headerrb r@ rH rH rI rZ s" � �z#BaseClient._convert_to_request_dictc C sf |j }| jj�� }| jjjd|� d|� �|||d�}t||d�}| jjjd|� d|� �|||d� |S )Nzprovide-client-params.r; )r� rO r� rM zbefore-parameter-build.)rj r= r� r� r� r� rZ r )r= rL r� r� r� r� rq rH rH rI rX $ s � �zBaseClient._emit_api_paramsFc
C s� | j du r| jj}i }i }nC| j j|||d�}|j}|j}|j}|j�d�} | durQ| j �| �}
|
\} } | |d< d| v rA|rA| d= d|v rM|d � | � n| |d< |||fS )a� Returns endpoint URL and list of additional headers returned from
EndpointRulesetResolver for the given operation and params. If the
ruleset resolver is not available, for example because the service has
no endpoints ruleset file, the legacy endpoint resolver's value is
returned.
Use ignore_signing_region for generating presigned URLs or any other
situation where the signing region information from the ruleset
resolver should be ignored.
Returns tuple of URL and headers dictionary. Additionally, the
request_context dict is modified in place with any signing information
returned from the ruleset resolver.
N)r� � call_argsr_ � authSchemesrK r� �signing)
r, r� rV r� �urlrN ra rd �auth_schemes_to_signing_ctxro )
r= r� r� r_ �ignore_signing_regionrV r` rM �
endpoint_info� auth_schemes� auth_inforK �signing_contextrH rH rI rY = s2
� �
z$BaseClient._resolve_endpoint_rulesetc
C s� | � |�s
t|d��| j| }dd� }| jd | }t|| jj| jj|dd�|_t | jj�}|� d|� �}t
|t fd|i�}| j �
|�}|t| |�||�} | S ) a Create a paginator for an operation.
:type operation_name: string
:param operation_name: The operation name. This is the same name
as the method name on the client. For example, if the
method name is ``create_foo``, and you'd normally invoke the
operation as ``client.create_foo(**kwargs)``, if the
``create_foo`` operation can be paginated, you can use the
call ``client.get_paginator("create_foo")``.
:raise OperationNotPageableError: Raised if the operation is not
pageable. You can use the ``client.can_paginate`` method to
check if an operation is pageable.
:rtype: ``botocore.paginate.Paginator``
:return: A paginator object.
)r� c [ s t j| fi |��S r2 )r �paginate)r= r� rH rH rI r| � s z*BaseClient.get_paginator.<locals>.paginate� page_configF)�paginator_namerA rr �paginator_configr� z .Paginator.r| )� can_paginater rz r/ r r� r� rr r� r# r� r r= r� r )
r= r� �actual_operation_namer| r �service_module_name�paginator_class_name�documented_paginator_clsr� � paginatorrH rH rI �
get_paginatorq s>
�� � � ���zBaseClient.get_paginatorc C sj d| j vr)z| j�| jjd| jj�d }|| j d< W n ty( i | j d< Y nw | j| }|| j d v S )aM Check if an operation can be paginated.
:type operation_name: string
:param operation_name: The operation name. This is the same name
as the method name on the client. For example, if the
method name is ``create_foo``, and you'd normally invoke the
operation as ``client.create_foo(**kwargs)``, if the
``create_foo`` operation can be paginated, you can use the
call ``client.get_paginator("create_foo")``.
:return: ``True`` if the operation can be paginated,
``False`` otherwise.
r} z paginators-1�
pagination)r/ r3 r� r= rL ro r rz )r= r� r} r� rH rH rI r� � s
�� �
zBaseClient.can_paginatec C sX d| j vr'z| j�| jjd| jj�}|| j d< W n ty& i | j d< Y nw | j d S )N�
waiter_configz waiters-2)r/ r3 r� r= rL ro r )r= r� rH rH rI �_get_waiter_config� s
� �
z BaseClient._get_waiter_configc C sh | � � }|s
td|� ���t�|�}i }|jD ]}||t|�< q||vr+td|� ���t�|| || �S )aK Returns an object that can wait for some condition.
:type waiter_name: str
:param waiter_name: The name of the waiter to get. See the waiters
section of the service docs for a list of available waiters.
:returns: The specified waiter object.
:rtype: ``botocore.waiter.Waiter``
zWaiter does not exist: )r� �
ValueErrorr � WaiterModel� waiter_namesr �create_waiter_with_client)r= � waiter_namer� rO r� rj rH rH rI �
get_waiter� s
�zBaseClient.get_waiterc C s* | � � }|sg S t�|�}dd� |jD �S )z(Returns a list of all available waiters.c S s g | ]}t |��qS rH )r )�.0rj rH rH rI �
<listcomp>� s z+BaseClient.waiter_names.<locals>.<listcomp>)r� r r� r� )r= r� rO rH rH rI r� � s
zBaseClient.waiter_namesc C s | j d u r
| �� | _ | j S r2 )r3 �_load_exceptionsr rH rH rI r] � s
zBaseClient.exceptionsc C s | j �| j�S r2 )r: �create_client_exceptionsr= r rH rH rI r� s �zBaseClient._load_exceptionsc C r )z�
This private interface is subject to abrupt breaking changes, including
removal, in any botocore release.
)r. � _credentialsr rH rH rI �_get_credentials s zBaseClient._get_credentials)NNr) )F)r� r� r� rz rJ rD rE r6 �propertyr= r� r[ rZ rX rY r� r� r� r� r r� r] r� r� rH rH rH rI r X s:
�*
T
�
�4A
r c @ s` e Zd ZdZdd� Zedd� �Zedd� �Zedd � �Zed
d � �Z ed d
� �Z
edd� �Z dS )r1 a~ Holds additional client methods.
This class holds additional information for clients. It exists for
two reasons:
* To give advanced functionality to clients
* To namespace additional client attributes from the operation
names which are mapped to methods at runtime. This avoids
ever running into collisions with operation names.
c C s( || _ || _|| _|| _|| _|| _d S r2 )r� r0 �
_endpoint_urlr= �_method_to_api_mapping�
_partition)r= r� rW rV rr �method_to_api_mappingr� rH rH rI rJ s
zClientMeta.__init__c C � | j S r2 )r= r rH rH rI rr . � zClientMeta.service_modelc C r r2 )r0 rk r rH rH rI rk 2 rF zClientMeta.region_namec C r� r2 )r� r rH rH rI rV 6 r� zClientMeta.endpoint_urlc C r� r2 )r0 r rH rH rI r� : r� zClientMeta.configc C r� r2 )r� r rH rH rI r� > r� z ClientMeta.method_to_api_mappingc C r� r2 )r� r rH rH rI r� B r� zClientMeta.partitionN) r� r� r� r� rJ r� rr rk rV r� r� r� rH rH rH rI r1 s
r1 c C s\ |r
|j dur
|j S |dur,|�| �}|dur,t|t�r,|�d�}|r,t�d| |� |S dS )z�
Gets the manually configured signature version.
:returns: the customer configured signature version, or None if no
signature version was configured.
Nr� zWSwitching signature version for service %s to version %s based on config file override.)r� rd r� �dictr^ r� )rL rW rX �service_config�versionrH rH rI r� G s
�r� )G�logging�botocorer r �
botocore.argsr �
botocore.authr �botocore.awsrequestr �botocore.compressr �botocore.configr �botocore.credentialsr �botocore.discoveryr
r r �botocore.docs.docstringr
r �botocore.exceptionsr r r r r �botocore.historyr �botocore.hooksr �botocore.httpchecksumr r �botocore.modelr �botocore.paginater �botocore.retriesr r �botocore.useragentr �botocore.utilsr r r r r! r" r# r$ r% r& r' r( r) r* � frozensetr% � getLoggerr� r^ rU r1 rb r r1 r� rH rH rH rI �<module> sX $ �
v < 6