⚝
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 :
endpoint.cpython-310.pyc
o YZa5 @ s d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZ d dl m Z d dl m Z m Z mZ d dlmZ d dlmZ d dlmZ d d lmZ eeZe Zd Zd Z d d Z G dd de Z G dd de Z dS ) N)create_request_object)HTTPClientError)URLLib3Session)is_valid_endpoint_urlis_valid_ipv6_endpoint_urlget_environ_proxies)first_non_none_response)get_global_history_recorder) StreamingBody)parsers< c C sz | j | jd|jid}|d dkr| j|d< |S |jr"| j|d< |S |jr6|d d}t| j||d< |S | j|d< |S )a Convert an HTTP response object to a request dict. This converts the requests library's HTTP response object to a dictionary. :type http_response: botocore.vendored.requests.model.Response :param http_response: The HTTP response from an AWS service request. :rtype: dict :return: A response dictionary which will contain the following keys: * headers (dict) * status_code (int) * body (string or file-like object) operation_name)headers status_codecontextr , bodyr zcontent-length) r r namecontenthas_event_stream_outputrawhas_streaming_outputgetr ) http_responseoperation_model response_dictlength r 3/usr/lib/python3/dist-packages/botocore/endpoint.pyconvert_to_response_dict( s" r c @ sz e Zd ZdZ dddZdd Zdd Zd d d Zd d Zd d Z dd Z dd Z dd Z dd Z dddZdd ZdS ) Endpointa, Represents an endpoint for a particular service in a specific region. Only an endpoint can make requests. :ivar service: The Service object that describes this endpoints service. :ivar host: The fully qualified endpoint hostname. :ivar session: The session object. Nc C sR || _ || _|| _t | _|d u rt }|| _|| _ | j d u r't | _ d S d S N) _endpoint_prefix_event_emitterhost threadingLock_lockr ResponseParserFactory_response_parser_factory http_sessionr )selfr% endpoint_prefix event_emitterresponse_parser_factoryr+ r r r __init__U s zEndpoint.__init__c C s d| j | jf S )Nz%s(%s))r# r% )r, r r r __repr__b s zEndpoint.__repr__c C s t d|| | ||S )Nz%Making request for %s with params: %s)loggerdebug _send_request)r, r request_dictr r r make_requeste s zEndpoint.make_requestc C s\ t |}|r't|j|jg|_|jj }dj||j d}| j j |||j d | |}|S )Nz&request-created.{service_id}.{op_name}) service_idop_name)requestr ) r anyr r stream_output service_modelr7 hyphenizeformatr r$ emitprepare_request)r, paramsr r9 r7 event_nameprepared_requestr r r create_requestj s zEndpoint.create_requestc C s0 | D ]\}}t|tjr|d||< qd S )Nzutf-8)items isinstancesix text_typeencode)r, r keyvaluer r r _encode_headersz s zEndpoint._encode_headersc C s | |j | S r" )rL r preparer, r9 r r r r@ s zEndpoint.prepare_requestc C s d}| ||}|d }| |||\}}| |||||r>|d7 }| | ||}| |||\}}| |||||s |d urTd|d v rT|d }||d d d< |d urZ||S )N r ResponseMetadata RetryAttempts)rD _get_response _needs_retry reset_stream) r, r5 r attemptsr9 r success_response exception total_retriesr r r r4 s6 zEndpoint._send_requestc C sv | ||\}}d d ||d}|d ur"|\}}||d< t|||d< |jj } | jjd| |jf fi | ||fS )N)r parsed_responser rW rY r zresponse-received.%s.%s)_do_get_responser r< r7 r= r$ r? r ) r, r9 r r rV rW kwargs_to_emitr rY r7 r r r rR s. zEndpoint._get_responsec C sZ z;t d| td|j|j|j|j|jd |j j }d||j f }| j j||d}t|}|d u r:| |}W n2 tyQ } z d |fW Y d }~S d }~w tym } zt jddd d |fW Y d }~S d }~ww t||}| } |j| d < td | |jd } | j| } | ||j} |jd kr| || || td | || fd fS )NzSending http request: %s HTTP_REQUEST)methodr streamingurlr zbefore-send.%s.%s)r9 z-Exception received when sending HTTP request.T)exc_infor^ HTTP_RESPONSEprotocolr PARSED_RESPONSE) r2 r3 history_recorderrecordr] r has_streaming_inputr_ r r< r7 r= r r$ r? r _sendr Exceptionr copyr metadatar* create_parserparse output_shaper _add_modeled_error_fields) r, r9 r r7 rB responsesr er http_response_record_dictrb parserrY r r r rZ sV zEndpoint._do_get_responsec C sT | di d}|d u rd S |j}||}|d u r d S |||}|| d S )NErrorCode)r r< shape_for_error_coderl update) r, r rY r rr error_coder< error_shape modeled_parser r r rn s z"Endpoint._add_modeled_error_fieldsc C sb |j j }d||jf }| jj||| ||||d}t|} | d u r$dS td| t | dS )Nzneeds-retry.%s.%s)responseendpoint operationrU caught_exceptionr5 Fz3Response received to retry, sleeping for %s secondsT) r< r7 r= r r$ r? r r2 r3 timesleep) r, rU r r5 rz r} r7 rB ro handler_responser r r rS s$ zEndpoint._needs_retryc C s | j |S r" )r+ sendrN r r r rg s zEndpoint._send)NNr" )__name__ __module__ __qualname____doc__r0 r1 r6 rD rL r@ r4 rR rZ rn rS rg r r r r r! K s / r! c @ s@ e Zd Zdd Zddeeeddddf ddZdd Zdd Z dS ) EndpointCreatorc C s || _ d S r" )r$ )r, r. r r r r0 s zEndpointCreator.__init__Nc C sr t |st|std| | d u r| |} |j} td| | ||| | ||| | | d}t|| | j ||dS )NzInvalid endpoint: %szSetting %s timeout as %s)timeoutproxiesverifymax_pool_connectionssocket_options client_certproxies_config)r- r. r/ r+ ) r r ValueError _get_proxiesr- r2 r3 _get_verify_valuer! r$ )r, r< region_name endpoint_urlr r/ r r http_session_clsr r r r r- r+ r r r create_endpoint s2 z EndpointCreator.create_endpointc C s t |S r" )r )r, r_ r r r r 9 s z EndpointCreator._get_proxiesc C s |d ur|S t jddS )NREQUESTS_CA_BUNDLET)osenvironr )r, r r r r r > s z!EndpointCreator._get_verify_value) r r r r0 DEFAULT_TIMEOUTMAX_POOL_CONNECTIONSr r r r r r r r r s $ r )!r loggingr~ r& rG botocore.awsrequestr botocore.exceptionsr botocore.httpsessionr botocore.utilsr r r botocore.hooksr botocore.historyr botocore.responser botocorer getLoggerr r2 rd r r r objectr! r r r r r <module> s* # G