⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.133
Server IP:
185.119.109.197
Server:
Linux managedhosting.chostar.me 5.15.0-160-generic #170-Ubuntu SMP Wed Oct 1 10:06:56 UTC 2025 x86_64
Server Software:
Apache
PHP Version:
8.1.33
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3
/
dist-packages
/
botocore
/
__pycache__
/
View File Name :
client.cpython-310.pyc
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 de2Z3G dd de2Z4G dd de2Z5G dd de2Z6d d Z7dS ) N)waiter xform_name)ClientArgsCreator)AUTH_TYPE_MAPS)prepare_request_dict)ClientMethodDocstring)PaginatorDocstring)DataNotFoundErrorOperationNotPageableError UnknownSignatureVersionError*InvalidEndpointDiscoveryConfigurationError)first_non_none_response) ServiceModel) Paginator)CachedPropertyget_service_module_nameS3RegionRedirectorS3ArnParamHandlerS3EndpointSetterensure_booleanS3ControlArnParamHandlerS3ControlEndpointSetter)get_global_history_recorder)EndpointDiscoveryHandlerEndpointDiscoveryManager,block_endpoint_discovery_required_operations)standard)adaptive)Config) ClientError)UNSIGNEDc @ s e Zd ZdZ d2ddZ d3ddZd4dd Zd d Zd d Zd4ddZ 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) selfloaderendpoint_resolver user_agent event_emitterretry_handler_factoryretry_config_translatorresponse_parser_factoryexceptions_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_namedefault signingName)service_signing_namer5 r6 )r& emitr _load_service_model_create_client_class_normalize_fips_regionClientEndpointBridger$ metadatagetr+ _get_client_args_register_retries_register_s3_events_register_s3_control_events _register_endpoint_discovery)r, r: region_name is_secure endpoint_urlverify credentials scoped_config api_version client_config responses service_modelclsendpoint_bridge client_argsservice_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 typestrtuple) r, r: rT r\ py_name_to_operation_namebasesra class_namerU r6 r6 r7 rA o s z"ClientCreator._create_client_classc C s` |d ur,| dd dd}||kr,tdd}|r ||}n|}td||f |}||fS )Nzfips- z-fipsT)use_fips_endpointztransforming region from %s to %s and setting use_fips_endpoint to true. client should not be configured with a fips psuedo region.)replacer mergeloggerwarning)r, rK rR normalized_region_nameconfig_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 )Nmoder r legacy)metaconfigretries _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 jjd}d|i}|d ur||d< tjdi | d S )Ntotal_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}| }| jd}|sd S | |j jj }| j || di | di |}t d|j jj | j||}d| } |j jjd| || d d S )N_retryretry 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_handlereventsregister) r, r{ r ra service_event_nameoriginal_configrw retry_confighandlerr r6 r6 r7 rz s. z&ClientCreator._register_legacy_retriesc C s: |d u rd S | }d|v r| }|dd |d< |S )Nr} r~ )copypop)r, rw copied_argsr6 r6 r7 r s z'ClientCreator._transform_legacy_retriesc C s6 |j jj}|d ur|dd ur|d S |dpdS )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| jd}| |}|rS| ||rS|du }t ||d}t |} | || d S | dt d S )NFendpoint_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 enableddiscovermanagerr r6 r6 r7 rJ s, z*ClientCreator._register_endpoint_discoveryc C sL t |tr| }|dkr|S |dv rt|S nt |tr!|S t|d)z?Config must either be a boolean-string or string-literal 'auto'auto)truefalse) config_value) isinstancerd lowerstripr 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 )Ns3r. region s3_configrM partitionrj )ru rT r: r r r r rv rj r r$ rK r r !_set_s3_presign_signature_versionr, 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 | jd|j}|jdkr |j|vr d S | jd|j}|d }d|vr2d S |jd| j d S )Nr z aws-globalsignatureVersionszchoose-signer.s3) !_get_configured_signature_versionr$ get_available_endpointsr rK construct_endpointr r _default_s3_presign_to_sigv2)r, client_metarR rP provided_signature_versionregionsendpointsignature_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_dictoperation_namepy_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_descriptionexample_prefixinclude_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!ddZ 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_ENDPOINTdefault_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|||| |||dS )N sslCommonNamehostname 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 | dS )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| jdi d}|dv r4dS d S d S )Nr r )TTruer 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}td||| | |ddgi}| j|i d}| j||||||i dS ) N)servicer httphttpsz#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 |||||||dS )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_protocolsschemer6 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 )NcredentialScoper )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|dd)Nr r s3v4r )r )r rR rP r r rE )r, r: r configured_versionpotential_versionsknownr6 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 ddZ 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 ClientMetahostr[ 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_responseAttributeError __class__r )r, item event_namer event_responser6 r6 r7 __getattr__ s zBaseClient.__getattr__c C s* | j jj }| j jd| | 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}td|||d |jr td|| | 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 )NAPI_CALL)r operationparamsz 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_responseparsedr r i, ErrorCode)r r r: history_recorderrecord 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_namedocumented_paginator_clsr paginatorr6 r6 r7 get_paginator s8 zBaseClient.get_paginatorc C sj d| j vr)z| j| jjd| jjd }|| 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 | jS 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|tr,|d}|r,td| | |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_configversionr6 r6 r7 r s r )8loggingbotocorer 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 ( /