Website : rimsha.abasa.com
backdoor
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
lib
/
python3
/
dist-packages
/
botocore
/
__pycache__
/
Filename :
client.cpython-310.pyc
back
Copy
o <&�a� � @ s| d dl Z d dlmZmZ d dlmZ d dlmZ d dlm Z d dl m Z d dl m Z d dl mZmZmZmZ d d lmZ d d lmZ d d lmZ d d lmZmZmZm Z m Z m Z m Z m Z d d l!m"Z" d dl#m$Z$m%Z%m&Z& d dl'm(Z( d dl'm)Z) d dl*m+Z+ d dl m,Z, d dlmZ d dlm-Z- e �.e/�Z0e"� Z1G dd� de2�Z3G dd� de2�Z4G dd� de2�Z5G dd� de2�Z6d d � Z7dS ) � N)�waiter� xform_name)�ClientArgsCreator)�AUTH_TYPE_MAPS)�prepare_request_dict)�ClientMethodDocstring)�PaginatorDocstring)�DataNotFoundError�OperationNotPageableError� UnknownSignatureVersionError�*InvalidEndpointDiscoveryConfigurationError)�first_non_none_response)� ServiceModel)� Paginator)�CachedProperty�get_service_module_name�S3RegionRedirector�S3ArnParamHandler�S3EndpointSetter�ensure_boolean�S3ControlArnParamHandler�S3ControlEndpointSetter)�get_global_history_recorder)�EndpointDiscoveryHandler�EndpointDiscoveryManager�,block_endpoint_discovery_required_operations)�standard)�adaptive)�Config)� ClientError)�UNSIGNEDc @ s� e Zd ZdZ d2dd�Z d3dd�Zd4dd �Zd d � Zd d � Zd4dd�Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Zd0d1� ZdS )5� 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) �self�loader�endpoint_resolver� user_agent� event_emitter�retry_handler_factory�retry_config_translator�response_parser_factory�exceptions_factory� config_store� r6 �1/usr/lib/python3/dist-packages/botocore/client.py�__init__9 s zClientCreator.__init__Tc C s� | j jd|d�} t| |d�}| �||�} | �|| �} | �|| �\}} t| j|| | j� d�| j d�} | � | ||||||| | � }| di |��}| � |� | � || || |� | �|| || |� | �||| � |S )Nzchoose-service-name�� service_name��default� signingName)�service_signing_namer5 r6 )r& �emitr �_load_service_model�_create_client_class�_normalize_fips_region�ClientEndpointBridger$ �metadata�getr+ �_get_client_args�_register_retries�_register_s3_events�_register_s3_control_events� _register_endpoint_discovery)r, r: � region_name� is_secure� endpoint_url�verify� credentials� scoped_config� api_version� client_config� responses� service_model�cls�endpoint_bridge� client_args�service_clientr6 r6 r7 � create_clientK s@ � � � � ���zClientCreator.create_clientc C s | � ||�}| �||�S r" )r@ rA )r, r: rQ rT r6 r6 r7 �create_client_classk s z!ClientCreator.create_client_classc C sb | � |�}| �|�}||d< tg}|j�� }| jjd| ||d� t|�}tt |�t |�|�}|S )N�_PY_TO_OP_NAMEzcreating-client-class.%s)�class_attributes� base_classes) �_create_methods�_create_name_mapping� BaseClient� service_id� hyphenizer& r? r �type�str�tuple) r, r: rT r\ �py_name_to_operation_name�basesra � class_namerU r6 r6 r7 rA o s �z"ClientCreator._create_client_classc C s` |d ur,|� dd�� dd�}||kr,tdd�}|r |�|�}n|}t�d||f � |}||fS )Nzfips-� z-fipsT)�use_fips_endpointz�transforming region from %s to %s and setting use_fips_endpoint to true. client should not be configured with a fips psuedo region.)�replacer �merge�logger�warning)r, rK rR �normalized_region_name�config_use_fips_endpointr6 r6 r7 rB } s* �� ����z$ClientCreator._normalize_fips_regionc C s" | j j|d|d�}t||d�}|S )Nz service-2)rQ r9 )r# �load_service_modelr )r, r: rQ � json_modelrT r6 r6 r7 r@ � s � z!ClientCreator._load_service_modelc 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, �client� retry_moder6 r6 r7 rG � s �z ClientCreator._register_retriesc C s< |j jj�d�}d|i}|d ur||d< tjdi |�� d S )N�total_max_attemptsr{ � max_attemptsr6 )ru rv rw rE r �register_retry_handler)r, r{ r~ �kwargsr6 r6 r7 rx � s z+ClientCreator._register_v2_standard_retriesc C s t �|� d S r" )r r )r, r{ r6 r6 r7 ry � 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: %szretry-config-%szneeds-retry.%s)� unique_id)ru rT �endpoint_prefixra rb r# � load_data�_transform_legacy_retriesrv rw r( �build_retry_configrE rm �debugr: r' �create_retry_handler�events�register) r, r{ r� ra �service_event_name�original_configrw � retry_config�handlerr� r6 r6 r7 rz � s. ��� �z&ClientCreator._register_legacy_retriesc C s: |d u rd S |� � }d|v r|� � }|�d�d |d< |S )Nr} � r~ )�copy�pop)r, rw � copied_argsr6 r6 r7 r� � s �z'ClientCreator._transform_legacy_retriesc C s6 |j jj}|d ur|�d�d ur|d S |�d�pdS )Nrs r| rt )ru rv rw rE �get_config_variable)r, r{ r5 �client_retriesr6 r6 r7 �_get_retry_mode� 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)ru rT � endpoint_discovery_operationr� ra rb r� r+ r� �$_normalize_endpoint_discovery_config� _requires_endpoint_discoveryr r r� r ) r, r{ rM rv r� ra �enabled�discover�managerr� r6 r6 r7 rJ � s, � �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)� isinstancerd �lower�stripr �boolr )r, r� r6 r6 r7 r� � s � z2ClientCreator._normalize_endpoint_discovery_configc C s |dkr |j jjS |S )Nr� )ru rT �endpoint_discovery_required)r, r{ r� r6 r6 r7 r� s z*ClientCreator._requires_endpoint_discoveryc C s| |j jjdkr d S t||��� t� �|j j� |j jj}t | j |j j |j jj ||j j |d��|j j� | �|j ||� d S )N�s3�r. �region� s3_configrM � partitionrj )ru rT r: r r� r r� rv rj r r$ rK r� r� �!_set_s3_presign_signature_version�r, r{ rV rM rR rP rj r6 r6 r7 rH s" � �z!ClientCreator._register_s3_eventsc C s^ |j jjdkr d S |j jj}t� �|j j� t| j |j j |j jj ||j j |d��|j j� d S )N� s3controlr� ) ru rT r: rv rj r r� r� r r$ rK r� r� r� r6 r6 r7 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_versionr$ �get_available_endpointsr� rK �construct_endpointr� r� � _default_s3_presign_to_sigv2)r, � client_metarR rP �provided_signature_version�regions�endpoint�signature_versionsr6 r6 r7 r� + s( �� ��z/ClientCreator._set_s3_presign_signature_versionc K s$ dD ] }|� |�rd| 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. :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 )z-queryz -presign-postr� N)�endswith)r, �signature_versionr� �suffixr6 r6 r7 r� O s ��z*ClientCreator._default_s3_presign_to_sigv2c C s: t | j| j| j| j| j| jd�} | �||||||||| � S )N)r5 )r r& r% r) r# r* r+ �get_client_args) r, rT rK rL rM rN rO rP rR rV � args_creatorr6 r6 r7 rF a s � �z ClientCreator._get_client_argsc C s. i }|j D ]}t|�}| �|||�||< q|S r" )�operation_namesr �_create_api_method)r, rT �op_dict�operation_name�py_operation_namer6 r6 r7 r^ l s �z ClientCreator._create_methodsc C s$ i }|j D ] }t|�}|||< q|S r" )r� r )r, rT �mappingr� r� r6 r6 r7 r_ t s z"ClientCreator._create_name_mappingc sH � �fdd�}t ��|_|�� �}t|� | j|jd� dd�}||_|S )Nc s |rt d� ��| �� |�S )Nz$%s() only accepts keyword arguments.)� TypeError�_make_api_call)r, �argsr� �r� r� r6 r7 � _api_call s � z3ClientCreator._create_api_method.<locals>._api_callzresponse = client.%sF)�operation_model� method_namer0 �method_description�example_prefix�include_signature)rd �__name__r� r r& � documentation�__doc__)r, r� r� rT r� r� � docstringr6 r� r7 r� } s �z ClientCreator._create_api_method)NNN)TNNNNNNr" )r� � __module__� __qualname__r� r8 rY rZ rA rB r@ rG rx ry rz r� r� rJ r� r� rH rI r� r� rF r^ r_ r� r6 r6 r6 r7 r! 7 s@ � � $ r! 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 � ZdS )#rC 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 s. || _ || _|| _|| _|p| j| _|| _d S r" )r> r. rP rR �DEFAULT_ENDPOINT�default_endpointr5 )r, r. rP rR r� r> r5 r6 r6 r7 r8 � s z ClientEndpointBridge.__init__Tc C st | � ||�}| �|�}| �d�}| jj||||d�}|s'| jj||d||d�}|r2| �|||||�S | �||||�S )Nrj )�use_dualstack_endpointrj �aws)�partition_namer� rj )�_check_default_region� _resolve_use_dualstack_endpoint�$_resolve_endpoint_variant_config_varr. r� �_create_endpoint�_assume_endpoint)r, r: rK rM rL r� rj �resolvedr6 r6 r7 �resolve� s2 ���� ��z ClientEndpointBridge.resolvec C s. |d ur|S | j r| j jd ur| j jS d S d S r" )rR rK )r, r: rK r6 r6 r7 r� � s �z*ClientEndpointBridge._check_default_regionc C sr | � |||�\}}|d u r!|�d|�d��}| �|||�dg ��}| �||�}| �||�} | j|||| |||d�S )N� sslCommonName�hostname� protocols)r: rK �signing_region� signing_namerM rD r� )�_pick_region_valuesrE � _make_url�_resolve_signature_version�_resolve_signing_name�_create_result) r, r� r: rK rM rL r� r� r� r� r6 r6 r7 r� � s$ � �� �z%ClientEndpointBridge._create_endpointc C s@ | j }d}|rt||�d urt||�S | jd ur | j�|�}|S )NF)rR �getattrr5 r� )r, � config_varrR � config_valr6 r6 r7 r� � s z9ClientEndpointBridge._resolve_endpoint_variant_config_varc C s | � |�}|d ur |S | �d�S )Nr� )�_is_s3_dualstack_moder� )r, r: �s3_dualstack_moder6 r6 r7 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_SERVICESrR r� rP rE )r, r: rR r� r6 r6 r7 r� � s ��z*ClientEndpointBridge._is_s3_dualstack_modec C sr |d u r| j j||d�}| �||ddg�}t�d|||� | �|ddgi�}| j|i d�}| j||||||i d�S ) N)�servicer� �http�httpsz#Assuming an endpoint for %s, %s: %sr� �v4)r� )r: rK r� r� r� rM rD )r� �formatr� rm r� r� r� r� )r, r: rK rM rL r� r� r� r6 r6 r7 r� s( ��� ��z%ClientEndpointBridge._assume_endpointc C s |||||||d�S )N)r: rK r� r� rM r� rD r6 )r, r: rK r� r� rM r� rD r6 r6 r7 r� # s �z#ClientEndpointBridge._create_resultc C s" |r d|v r d}nd}d||f S )Nr� r� z%s://%sr6 )r, r� rL �supported_protocols�schemer6 r6 r7 r� 0 s z ClientEndpointBridge._make_urlc C s0 d|v rd|d v r|d d S | j r| j S |S )N�credentialScoper� )r> )r, r: r� r6 r6 r7 r� 7 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� r6 )r, r� rK rM r� r6 r6 r7 r� B s z(ClientEndpointBridge._pick_region_valuesc C sn t || j| j�}|d ur|S d|v r/|d }|dkr dS d|v r"dS |D ] }|tv r.| S q$t|�d�d��)Nr� r� �s3v4r� )r� )r� rR rP r r rE )r, r: r� �configured_version�potential_versions�knownr6 r6 r7 r� V s$ ���z/ClientEndpointBridge._resolve_signature_version)NNNNN)NNT)r� r� r� r� r� r� r8 r� r� r� r� r� r� r� r� r� r� r� r� r6 r6 r6 r7 rC � s, � � rC c @ s� e Zd Zi Zdd� Zdd� Zdd� Zedd� �Zd d � Z d d � Z d dd�Z dd� Z dd� Z dd� Zdd� Zdd� Zedd� �Zed d � �Zd d � Zd S )!r` c C s\ || _ || _|| _|| _i | _|| _|| _t|| j|j|| j | �| _ | | _ d | _ | � � d S r" )� _serializer� _endpoint�_response_parser�_request_signer�_cacher# �_client_config� ClientMeta�hostr[ ru r* � _exceptions�_register_handlers) r, � serializerr� �response_parserr0 �request_signerrT r- rR r� r4 r6 r6 r7 r8 v s � zBaseClient.__init__c C sJ d| j j�� |f }| jjj|| d�\}}|d ur|S td| jj|f ��)Nz getattr.%s.%s)r{ z!'%s' object has no attribute '%s') �_service_modelra rb ru r� �emit_until_response�AttributeError� __class__r� )r, �item� event_namer� �event_responser6 r6 r7 � __getattr__� s � ���zBaseClient.__getattr__c C s* | j jj�� }| j j�d| | jj� d S )Nzrequest-created.%s)ru rT ra rb r� r� r r� )r, ra r6 r6 r7 r � s �z BaseClient._register_handlersc C � | j jS r" )ru rT �r, r6 r6 r7 r � � zBaseClient._service_modelc C s | j �|�}| j j}t�d|||d�� |jr t�d||� | jj | jj |j |j d�}| j |||d�}| j j�� }| jjjdj||d�||| j|d�\}} | d urV| \} } n | �|||�\} } | jjjd j||d�| | ||d � | jd kr�| �d i ��d �} | j�| �} | | |��| S )N�API_CALL)r� � operation�paramsz Warning: %s.%s() is deprecated)� client_regionrR �has_streaming_input� auth_type)�contextz)before-call.{service_id}.{operation_name}�ra r� )�modelr r r z(after-call.{service_id}.{operation_name})� http_response�parsedr r i, �Error�Code)r r� r: �history_recorder�record� deprecatedrm r� ru rK rv r r �_convert_to_request_dictra rb r� r r� r � _make_requestr? � status_coderE � exceptions� from_code)r, r� � api_paramsr� r: �request_context� request_dictra r� r r� �parsed_response� error_code� error_classr6 r6 r7 r� � s\ ���� � � ��� zBaseClient._make_api_callc C sT z| j �||�W S ty) } z| jjjdj| jj� � |j d�||d� � d }~ww )Nz.after-call-error.{service_id}.{operation_name}r )� exceptionr ) r � make_request� Exceptionru r� r? r� r ra rb �name)r, r� r/ r. �er6 r6 r7 r) � s ����zBaseClient._make_requestNc C sL | � |||�}| j�||�}| jjs|�dd � t|| jj| jj |d� |S )N� host_prefix)rM r/ r ) �_emit_api_paramsr �serialize_to_requestr �inject_host_prefixr� r r r r/ )r, r- r� r r/ r6 r6 r7 r( � s �� �z#BaseClient._convert_to_request_dictc C sf |j }| jj�� }| jjjdj||d�|||d�}t||d�}d}| jjj|j||d�|||d� |S )Nz3provide-client-params.{service_id}.{operation_name}r )r r r r; z4before-parameter-build.{service_id}.{operation_name}) r6 r ra rb ru r� r? r� r )r, r- r� r r� ra rS r r6 r6 r7 r9 � s( �� ���zBaseClient._emit_api_paramsc C s� | � |�s t|d��| j| }dd� }| jd | }t|| jj| jj|dd�|_t dt | jj�|f �}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: L{botocore.paginate.Paginator} :return: A paginator object. )r� c [ s t j| fi |��S r" )r �paginate)r, r� r6 r6 r7 r< s z*BaseClient.get_paginator.<locals>.paginate� page_configF)�paginator_namer0 rT �paginator_configr� z%s.Paginator.%sr< )� can_paginater r[ r r ru r� rT r� rd r rc r r r� r� ) r, r� �actual_operation_namer< r? �paginator_class_name�documented_paginator_clsr� � paginatorr6 r6 r7 � get_paginator s8 �� � � �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 r# rq r r: rQ r r[ )r, r� r= rA r6 r6 r7 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 r# rq r r: rQ r )r, rG r6 r6 r7 �_get_waiter_configY s � � z BaseClient._get_waiter_configc C sd | � � }|s td| ��t�|�}i }|jD ]}||t|�< q||vr)td| ��t�|| || �S )aG 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: %s)rH � ValueErrorr � WaiterModel� waiter_namesr �create_waiter_with_client)r, � waiter_namerv r r� r6 r6 r6 r7 � get_waitere 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 r6 )r )�.0r6 r6 r6 r7 � <listcomp>� s z+BaseClient.waiter_names.<locals>.<listcomp>)rH r rJ rK )r, rv r r6 r6 r7 rK | s zBaseClient.waiter_namesc C s | j d u r | �� | _ | j S r" )r �_load_exceptionsr r6 r6 r7 r+ � s zBaseClient.exceptionsc C s | j �| j�S r" )r* �create_client_exceptionsr r r6 r6 r7 rQ � s �zBaseClient._load_exceptionsr" )r� r� r� r[ r8 r r �propertyr r� r) r( r9 rE r@ rH rN r rK r+ rQ r6 r6 r6 r7 r` l s* 1 � 9 r` c @ s` e Zd ZdZdd� Zedd� �Zedd� �Zedd � �Zed d � �Z ed d � �Z edd� �Z dS )r 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 r" )r� r � _endpoint_urlr �_method_to_api_mapping� _partition)r, r� rR rM rT �method_to_api_mappingr� r6 r6 r7 r8 � s zClientMeta.__init__c C � | j S r" )r r r6 r6 r7 rT � � zClientMeta.service_modelc C r r" )r rK r r6 r6 r7 rK � r zClientMeta.region_namec C rX r" )rT r r6 r6 r7 rM � rY zClientMeta.endpoint_urlc C rX r" )r r r6 r6 r7 rv � rY zClientMeta.configc C rX r" )rU r r6 r6 r7 rW � rY z ClientMeta.method_to_api_mappingc C rX r" )rV r r6 r6 r7 r� � rY zClientMeta.partitionN) r� r� r� r� r8 rS rT rK rM rv rW r� r6 r6 r6 r7 r � s r 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� rE r� �dictrm r� )r: rR rP �service_config�versionr6 r6 r7 r� � s �r� )8�logging�botocorer r � botocore.argsr � botocore.authr �botocore.awsrequestr �botocore.docs.docstringr r �botocore.exceptionsr r r r �botocore.hooksr �botocore.modelr �botocore.paginater �botocore.utilsr r r r r r r r �botocore.historyr �botocore.discoveryr r r �botocore.retriesr r �botocore.configr r r � getLoggerr� rm r% �objectr! rC r` r r� r6 r6 r6 r7 �<module> s@ ( d T ( /