Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/botocore/__pycache__/client.cpython-39.pyc
Ðазад
a p�h*� � @ s| d dl Z d dlZd dlmZmZ d dlmZ d dlmZ d dl m Z d dl m Z d dl m Z d dlmZmZmZmZmZ d d lmZ d d lmZ d d lmZ d d lmZm Z m Z m Z m Z m Z m!Z!m"Z" d dlmZ d d lm#Z# d dl$m%Z% d dl&m'Z' d dl(m)Z)m*Z*m+Z+ d dl,m-Z- d dl,m.Z. e �/e0�Z1e'� Z2G dd� de3�Z4G dd� de3�Z5G dd� de3�Z6G dd� de3�Z7dd � Z8dS ) � N)�waiter� xform_name)�ClientArgsCreator)�AUTH_TYPE_MAPS)�prepare_request_dict)�ClientMethodDocstring)�PaginatorDocstring)� ClientError�DataNotFoundError�OperationNotPageableError� UnknownSignatureVersionError�*InvalidEndpointDiscoveryConfigurationError)�first_non_none_response)� ServiceModel)� Paginator)�CachedProperty�get_service_module_name�S3RegionRedirector�S3ArnParamHandler�S3EndpointSetter�ensure_boolean�S3ControlArnParamHandler�S3ControlEndpointSetter)�UNSIGNED)�Config)�get_global_history_recorder)�EndpointDiscoveryHandler�EndpointDiscoveryManager�,block_endpoint_discovery_required_operations)�standard)�adaptivec @ s� e Zd ZdZd0dd�Zd1dd�Zd2dd �Zd d � Zd3d d �Zdd� 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/� ZdS )4� 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_emitterZretry_handler_factoryZretry_config_translatorZresponse_parser_factory�exceptions_factory� config_store� r3 �/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/botocore/client.py�__init__6 s zClientCreator.__init__Tc C s� | j jd|d�} t| |d�}| �||�} | �|| �} t| j|| | j�d�d�} | � | ||||||| | � }| f i |��}| � |� | � || || |� | � || || |� | � ||| � |S )Nzchoose-service-name�� service_name��defaultZ signingName��service_signing_name)r& �emitr �_load_service_model�_create_client_class�ClientEndpointBridger$ �metadata�get�_get_client_args�_register_retries�_register_s3_events�_register_s3_control_events� _register_endpoint_discovery)r, r7 � region_name� is_secure� endpoint_url�verify� credentials� scoped_config� api_version� client_config� responses� service_model�cls�endpoint_bridgeZ client_argsZservice_clientr3 r3 r4 � create_clientH s8 � � � ���zClientCreator.create_clientc C s | � ||�}| �||�S r" )r= r> )r, r7 rM rP r3 r3 r4 �create_client_classe 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_attributesZ base_classes) �_create_methods�_create_name_mapping� BaseClient� service_id� hyphenizer& r< r �type�str�tuple) r, r7 rP rV Zpy_name_to_operation_name�basesrZ � class_namerQ r3 r3 r4 r> i s �z"ClientCreator._create_client_classc C s" | j j|d|d�}t||d�}|S )Nz service-2)rM r6 )r# �load_service_modelr )r, r7 rM Z json_modelrP r3 r3 r4 r= w s � z!ClientCreator._load_service_modelc C sV |j jjd }|dkr"| �|� n0|dkr@| �|� | �|� n|dkrR| �|� d S )N�moder r �legacy)�meta�config�retries� _register_v2_standard_retries� _register_v2_adaptive_retries�_register_legacy_retries)r, �client� retry_moder3 r3 r4 rC } s z ClientCreator._register_retriesc C s< |j jj�d�}d|i}|d ur(||d< tjf i |�� d S )N�total_max_attemptsrj � max_attempts)rd re rf rA r �register_retry_handler)r, rj rm �kwargsr3 r3 r4 rg � s z+ClientCreator._register_v2_standard_retriesc C s t �|� d S r" )r rn )r, rj r3 r3 r4 rh � s z+ClientCreator._register_v2_adaptive_retriesc C s� |j jj}|j jj}|�� }| j�d�}|s0d S | �|j jj �}| j � ||� di �|� di �|�}t �d|j jj� | j�||�}d| } |j jjd| || d� d S )NZ_retry�retryZ definitionsz*Registering retry handlers for service: %szretry-config-%szneeds-retry.%s)� unique_id)rd rP �endpoint_prefixrZ r[ r# Z load_data�_transform_legacy_retriesre rf r( Zbuild_retry_configrA �logger�debugr7 r' Zcreate_retry_handler�events�register) r, rj rr rZ Zservice_event_nameZoriginal_configrf Z retry_config�handlerrq r3 r3 r4 ri � s. ����z&ClientCreator._register_legacy_retriesc C s: |d u r d S |� � }d|v r6|� � }|�d�d |d< |S )Nrl � rm )�copy�pop)r, rf Z copied_argsr3 r3 r4 rs � s �z'ClientCreator._transform_legacy_retriesc C s6 |j jj}|d ur(|�d�d ur(|d S |�d�p4dS )Nrb rk rc )rd re rf rA �get_config_variable)r, rj r2 Zclient_retriesr3 r3 r4 �_get_retry_mode� s �z ClientCreator._get_retry_modec C s� |d ur d S |j jjd u r d S |j j}|j jj�� }d}|rN|jd urN|j}n| jr`| j�d�}| � |�}|r�| � ||�r�|du }t ||d�}t |�} | � ||� n |� dt� d S )NF�endpoint_discovery_enabledT)Zalways_discoverzbefore-parameter-build)rd rP Z endpoint_discovery_operationrv rZ r[ r~ r+ r| �$_normalize_endpoint_discovery_config� _requires_endpoint_discoveryr r rw r ) r, rj rI re rv rZ �enabled�discover�managerrx r3 r3 r4 rF � s, � �z*ClientCreator._register_endpoint_discoveryc C sP t |t�r4|�� �� }|dkr"|S |dv rBt|�S nt |t�rB|S t|d��dS )z?Config must either be a boolean-string or string-literal 'auto'�auto)�true�false)Z config_valueN)� isinstancer] �lower�stripr �boolr )r, r� r3 r3 r4 r � s z2ClientCreator._normalize_endpoint_discovery_configc C s |dkr|j jjS |S )Nr� )rd rP Zendpoint_discovery_required)r, rj r� r3 r3 r4 r� � s z*ClientCreator._requires_endpoint_discoveryc C sp |j jjdkrd S t||��� t� �|j j� t| j|j j |j j j ||j j d��|j j� | � |j ||� d S )N�s3�r. �regionZ s3_configrI � partition)rd rP r7 r rw r rv r r$ rG re r� r� �!_set_s3_presign_signature_version�r, rj rR rI rN rL r3 r3 r4 rD � s ���z!ClientCreator._register_s3_eventsc C sR |j jjdkrd S t� �|j j� t| j|j j|j j j ||j j d��|j j� d S )NZ s3controlr� ) rd rP r7 r rw rv r r$ rG re r� r� r� r3 r3 r4 rE � s ��z)ClientCreator._register_s3_control_eventsc C sx t d||�}|d urd S | j�d|j�}|jdkr@|j|vr@d S | j�d|j�}|d }d|vrdd S |j�d| j� d S )Nr� � aws-global�signatureVersionszchoose-signer.s3) �!_get_configured_signature_versionr$ Zget_available_endpointsr� rG �construct_endpointrv rw � _default_s3_presign_to_sigv2)r, Z client_metarN rL Zprovided_signature_versionZregions�endpointZsignature_versionsr3 r3 r4 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_versionro �suffixr3 r3 r4 r� - s z*ClientCreator._default_s3_presign_to_sigv2c C s: t | j| j| j| j| j| jd�} | �||||||||| � S )N)r2 )r r& r% r) r# r* r+ Zget_client_args) r, rP rG rH rI rJ rK rL rN rR Z args_creatorr3 r3 r4 rB ? s � �z ClientCreator._get_client_argsc C s. i }|j D ] }t|�}| �|||�||< q |S r" )�operation_namesr �_create_api_method)r, rP Zop_dict�operation_name�py_operation_namer3 r3 r4 rW J s � z ClientCreator._create_methodsc C s$ i }|j D ]}t|�}|||< q |S r" )r� r )r, rP �mappingr� r� r3 r3 r4 rX R 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, �argsro �r� r� r3 r4 � _api_call] s �z3ClientCreator._create_api_method.<locals>._api_callzresponse = client.%sF)�operation_model� method_namer0 Zmethod_descriptionZexample_prefix�include_signature)r] �__name__r� r r& � documentation�__doc__)r, r� r� rP r� r� � docstringr3 r� r4 r� [ s �z ClientCreator._create_api_method)NNN)TNNNNNN)N)N)r� � __module__� __qualname__r� r5 rS rT r> r= rC rg rh ri rs r} rF r r� rD rE r� r� rB rW rX r� r3 r3 r3 r4 r! 4 s< � � $ r! c @ s� e Zd ZdZdZddgZd dd�Zd d d �Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd � Zd d � ZdS )!r? 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. rL rN �DEFAULT_ENDPOINT�default_endpoint)r, r. rL rN r� r; r3 r3 r4 r5 � s z ClientEndpointBridge.__init__Tc C sZ | � ||�}| j�||�}|s0| jj||dd�}|rF| �|||||�S | �||||�S d S )NZaws)Zpartition_name)�_check_default_regionr. r� �_create_endpoint�_assume_endpoint)r, r7 rG rI rH �resolvedr3 r3 r4 �resolve� s �� ��z ClientEndpointBridge.resolvec C s* |d ur |S | j r&| j jd ur&| j jS d S r" )rN rG )r, r7 rG r3 r3 r4 r� � s z*ClientEndpointBridge._check_default_regionc C s� |d u}| � |||�\}}|d u rl| �|�rD| �|||d ||�}n(|�d|�d��}| �|||�dg ��}| �||�} | �||�} | j|||| ||| d�S )NZ dnsSuffixZ sslCommonName�hostnameZ protocols)r7 rG �signing_region� signing_namerI r@ r� )�_pick_region_values�_is_s3_dualstack_mode�_create_dualstack_endpointrA � _make_url�_resolve_signature_version�_resolve_signing_name�_create_result) r, r� r7 rG rI rH �explicit_regionr� r� r� r� r3 r3 r4 r� � s0 � � �� �z%ClientEndpointBridge._create_endpointc C sn || j vrdS | j}|d ur:|jd ur:d|jv r:|jd S | jd u rHdS | j�di ��dd�}|dv rjdS dS )NFZuse_dualstack_endpointr� )T�Truer� T)�_DUALSTACK_ENABLED_SERVICESrN r� rL rA )r, r7 rN r� r3 r3 r4 r� � s � �z*ClientEndpointBridge._is_s3_dualstack_modec C s2 |s|dkrd}dj |||d�}| �||ddg�S )Nr� z us-east-1z){service}.dualstack.{region}.{dns_suffix})�servicer� � dns_suffix�http�https)�formatr� )r, r7 rG r� rH r� r� r3 r3 r4 r� � s �z/ClientEndpointBridge._create_dualstack_endpointc C sr |d u r*| j j||d�}| �||ddg�}t�d|||� | �|ddgi�}| j|i d�}| j||||||i d�S ) N)r� r� r� r� z#Assuming an endpoint for %s, %s: %sr� �v4)r� )r7 rG r� r� r� rI r@ )r� r� r� rt ru r� r� r� )r, r7 rG rI rH r� r� r� r3 r3 r4 r� � s( ��� ��z%ClientEndpointBridge._assume_endpointc C s |||||||d�S )N)r7 rG r� r� rI r� r@ r3 )r, r7 rG r� r� rI r� r@ r3 r3 r4 r� � s �z#ClientEndpointBridge._create_resultc C s" |rd|v rd}nd}d||f S )Nr� r� z%s://%sr3 )r, r� rH Zsupported_protocols�schemer3 r3 r4 r� s z ClientEndpointBridge._make_urlc C s0 d|v r d|d v r |d d S | j r,| j S |S )N�credentialScoper� r: )r, r7 r� r3 r3 r4 r� s � z*ClientEndpointBridge._resolve_signing_namec C s@ |}|d u r8|d }|}d|v r8d|d v r8|d d }||fS )NZ endpointNamer� r� r3 )r, r� rG rI r� r3 r3 r4 r� s � z(ClientEndpointBridge._pick_region_valuesc C sr t || j| j�}|d ur |S d|v r^|d }|dkr8dS d|v rDdS |D ]}|tv rH| S qHt|�d�d��d S )Nr� r� Zs3v4r� )r� )r� rN rL r r rA )r, r7 r� Zconfigured_versionZpotential_versionsZknownr3 r3 r4 r� + s" � �z/ClientEndpointBridge._resolve_signature_version)NNNN)NNT)r� r� r� r� r� r� r5 r� r� r� r� r� r� r� r� r� r� r� r3 r3 r3 r4 r? w s( � � r? 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 )!rY c C s\ || _ || _|| _|| _i | _|| _|| _t|| j|j|| j | �| _ | | _ d | _ | � � d S r" )� _serializer� _endpointZ_response_parser�_request_signer�_cacher# �_client_config� ClientMeta�hostrU rd r* � _exceptions�_register_handlers) r, � serializerr� Zresponse_parserr0 �request_signerrP r- rN r� r1 r3 r3 r4 r5 K s �zBaseClient.__init__c C sN d| j j�� |f }| jjj|| d�\}}|d ur6|S td| jj|f ��d S )Nz getattr.%s.%s)rj z!'%s' object has no attribute '%s') �_service_modelrZ r[ rd rv �emit_until_response�AttributeError� __class__r� )r, �item� event_namerx �event_responser3 r3 r4 � __getattr__\ s �� ��zBaseClient.__getattr__c C s* | j jj�� }| j j�d| | jj� d S )Nzrequest-created.%s)rd rP rZ r[ rv rw r� rx )r, rZ r3 r3 r4 r� k s �z BaseClient._register_handlersc C s | j jS r" )rd rP �r, r3 r3 r4 r� s s 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 ur�| \} } n| �|||�\} } | jjjd j||d�| | ||d � | jd k�r| �d i ��d �} | j�| �} | | |��n| S d S )NZAPI_CALL)r� Z operation�paramsz Warning: %s.%s() is deprecated)Z client_regionrN �has_streaming_input� auth_type)�contextz)before-call.{service_id}.{operation_name}�rZ r� )�modelr� r� r� z(after-call.{service_id}.{operation_name})� http_response�parsedr� r� i, �ErrorZCode)r� r� r7 �history_recorder�record� deprecatedrt ru rd rG re r� r� �_convert_to_request_dictrZ r[ rv r� r� r� � _make_requestr< � status_coderA � exceptionsZ from_code)r, r� � api_paramsr� r7 �request_context� request_dictrZ rx r� r� Zparsed_responseZ error_codeZ error_classr3 r3 r4 r� w s\ ���� �� ��� zBaseClient._make_api_callc C sd z| j �||�W S ty^ } z6| jjjdj| jj� � |j d�||d� � W Y d }~n d }~0 0 d S )Nz.after-call-error.{service_id}.{operation_name}r� )� exceptionr� ) r� Z make_request� Exceptionrd rv r< r� r� rZ r[ �name)r, r� r� r� �er3 r3 r4 r� � s ��zBaseClient._make_requestNc C sL | � |||�}| j�||�}| jjs0|�dd � t|| jj| jj |d� |S )N� host_prefix)rI r/ r� ) �_emit_api_paramsr� Zserialize_to_requestr� Zinject_host_prefixr{ r r� r� r/ )r, r� r� r� r� r3 r3 r4 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� r8 z4before-parameter-build.{service_id}.{operation_name}) r� r� rZ r[ rd rv r< r� r )r, r� r� r� r� rZ rO r� r3 r3 r4 r� � s( �� ���zBaseClient._emit_api_paramsc C s� | � |�st|d��n�| j| }dd� }| jd | }t|| jj| jj|dd�|_t dt | jj�|f �}t |t fd|i�}| j �|�}|t| |�||�}|S d 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, ro r3 r3 r4 r� � s z*BaseClient.get_paginator.<locals>.paginate� page_configF)Zpaginator_namer0 rP �paginator_configr� z%s.Paginator.%sr� N)� can_paginater rU r� r rd rv rP r� r] r r\ r r� r� �getattr) r, r� �actual_operation_namer� r� Zpaginator_class_nameZdocumented_paginator_clsr� Z paginatorr3 r3 r4 � get_paginator� s8 �� � � �zBaseClient.get_paginatorc C sj d| j vrRz*| j�| jjd| jj�d }|| j d< W n tyP i | j d< Y n0 | 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-1Z pagination)r� r# ra r� r7 rM r rU )r, r� r� r� r3 r3 r4 r� s �� zBaseClient.can_paginatec C sX d| j vrNz&| j�| jjd| jj�}|| j d< W n tyL i | j d< Y n0 | j d S )N� waiter_configz waiters-2)r� r# ra r� r7 rM r )r, r� r3 r3 r4 �_get_waiter_config. s � z BaseClient._get_waiter_configc C sd | � � }|std| ��t�|�}i }|jD ]}||t|�< q,||vrRtd| ��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)r� � ValueErrorr � WaiterModel� waiter_namesr Zcreate_waiter_with_client)r, Z waiter_namere r� r� r� r3 r3 r4 � 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 r3 )r )�.0r� r3 r3 r4 � <listcomp>Z � z+BaseClient.waiter_names.<locals>.<listcomp>)r� r r r )r, re r� r3 r3 r4 r Q s zBaseClient.waiter_namesc C s | j d u r| �� | _ | j S r" )r� �_load_exceptionsr� r3 r3 r4 r� \ s zBaseClient.exceptionsc C s | j �| j�S r" )r* Zcreate_client_exceptionsr� r� r3 r3 r4 r b s �zBaseClient._load_exceptions)N)r� r� r� rU r5 r� r� �propertyr� r� r� r� r� r� r� r� r r r r� r r3 r3 r3 r4 rY A s( 1 � 9 rY 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" )rv r� � _endpoint_urlr� �_method_to_api_mapping� _partition)r, rv rN rI rP �method_to_api_mappingr� r3 r3 r4 r5 t s zClientMeta.__init__c C s | j S r" )r� r� r3 r3 r4 rP } s zClientMeta.service_modelc C s | j jS r" )r� rG r� r3 r3 r4 rG � s zClientMeta.region_namec C s | j S r" )r r� r3 r3 r4 rI � s zClientMeta.endpoint_urlc C s | j S r" )r� r� r3 r3 r4 re � s zClientMeta.configc C s | j S r" )r r� r3 r3 r4 r � s z ClientMeta.method_to_api_mappingc C s | j S r" )r r� r3 r3 r4 r� � s zClientMeta.partitionN) r� r� r� r� r5 r rP rG rI re r r� r3 r3 r3 r4 r� g s r� c C s\ |r|j dur|j S |durX|�| �}|durXt|t�rX|�d�}|rXt�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� rA r� �dictrt ru )r7 rN rL Zservice_config�versionr3 r3 r4 r� � s �r� )9�logging� functoolsZbotocorer r Z botocore.argsr Z botocore.authr Zbotocore.awsrequestr Zbotocore.docs.docstringr r Zbotocore.exceptionsr r r r r Zbotocore.hooksr Zbotocore.modelr Zbotocore.paginater Zbotocore.utilsr r r r r r r r r Zbotocore.configr Zbotocore.historyr Zbotocore.discoveryr r r Zbotocore.retriesr r � getLoggerr� rt r� �objectr! r? rY r� r� r3 r3 r3 r4 �<module> s> ( E K (/
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка