⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.144
Server IP:
157.245.143.252
Server:
Linux www 6.11.0-9-generic #9-Ubuntu SMP PREEMPT_DYNAMIC Mon Oct 14 13:19:59 UTC 2024 x86_64
Server Software:
nginx/1.26.0
PHP Version:
8.3.11
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3
/
dist-packages
/
botocore
/
__pycache__
/
View File Name :
endpoint.cpython-312.pyc
Pe9@ d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ d dlm Z d dl m Z d dl m Z d dlmZ d dlmZ d dlmZ d d lmZ d d lmZmZmZ ej4 e Z e Z d Z d Z d Z G d d Z! G d d Z"y) N)parsers)create_request_object)HTTPClientError)get_global_history_recorder)first_non_none_response)handle_checksum_body)URLLib3Session) StreamingBody)get_environ_proxiesis_valid_endpoint_urlis_valid_ipv6_endpoint_url< c R | j | j d|j id}|d dk\ r| j |d< |S |j r| j |d< |S |j r/|d j 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_dictlengths 3/usr/lib/python3/dist-packages/botocore/endpoint.pyconvert_to_response_dictr" * s " !(($00 o 2 2 M ]#s* - 5 5 f 0 0 - 1 1 f - - y)--.>? -m.?.? H f !. 5 5 f c e Zd ZdZ ddZd Zd Zd ZddZd Z d Z d Z d Z dd Z d Zd Zd Zd Z ddZd Zy)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 || _ || _ || _ t j | _ |t j }|| _ || _ | j t | _ y y N) _endpoint_prefix_event_emitterhost threadingLock_lockr ResponseParserFactory_response_parser_factory http_sessionr )selfr* endpoint_prefix event_emitterresponse_parser_factoryr0 s r! __init__zEndpoint.__init__X sj !0 + ^^% " *&-&C&C&E #(?% ( $ . 0D %r# c : | j d| j dS )N())r( r* r1 s r! __repr__zEndpoint.__repr__k s ''($))A66r# c 8 | j j y r' )r0 closer9 s r! r< zEndpoint.closen s !r# c T t j d|| | j || S )Nz%Making request for %s with params: %s)loggerdebug _send_request)r1 r request_dicts r! make_requestzEndpoint.make_requestq s, 3 !!,@@r# c ` t | }|rt |j |j g |_ |j j j }dj ||j }| j j |||j | j | }|S )Nz&request-created.{service_id}.{op_name}) service_idop_name)requestr ) r anyr r stream_output service_modelrD hyphenizeformatr r) emitprepare_request)r1 paramsr rF rD event_nameprepared_requests r! create_requestzEndpoint.create_requesty s '/ $'#88#;;%G ! )66AAKKMJAHH%/C/C I J $ $ . 3 3 % //8 r# c ~ |j D ]* \ }}t |t s|j d ||< , y )Nzutf-8)items isinstancestrencode)r1 r keyvalues r! _encode_headerszEndpoint._encode_headers s2 !--/JC%% $||G 4 *r# c X | j |j |j S r' )rY r preparer1 rF s r! rM zEndpoint.prepare_request s! W__- r# c t j j }t j j |d }||z }|t j | z |z }|j d S )Nz%a, %d %b %Y %H:%M:%S %Z)secondsz%Y%m%dT%H%M%SZ)datetimeutcnowstrptime timedeltastrftime)r1 response_received_timestamp date_header read_timeoutlocal_timestampdate_conversionestimated_skewttls r! _calculate_ttlzEndpoint._calculate_ttl sv #++224"++44 3 )+FF 6 7 || ,--r# c $ |d j j d }|j d }|r9|s6 t j j }| j ||| |d< y y y # t $ r t j dd Y y w xY w)Nr Datehas_streaming_inputrj z9Exception received when updating retries context with TTLTexc_info)r r r_ r` rk Exceptionr> r? )r1 retries_contextrf success_responseresponse_date_headerrn rd s r! _set_ttlzEndpoint._set_ttl s / 2 : : > >v F - 1 12G H (; .6.?.?.F.F.H+)-)<)</( *& )< O ! s 4A, , BBc |j di }||d< d|vr t t j |d< |r#|d j }| j ||| y y )Nretriesattemptz invocation-id client_config) setdefaultrU uuiduuid4rf ru )r1 r rx rs rr rf s r! _update_retries_contextz Endpoint._update_retries_context sd !,,Y;%, " / 1/24::</@OO , "?3@@L MM/<9I J r# c d}|d }| j || | j || }| j ||| \ }}| j ||||| rf|dz }| j ||| |j | j || }| j ||| \ }}| j ||||| rf|d|d v r|dz }||d d d< |||S )N r ResponseMetadata RetryAttempts)r} rQ _get_response _needs_retry reset_stream) r1 rA r attemptsr rF rs exception total_retriess r! r@ zEndpoint._send_request s: y) $$Wh7%%lOD&*&8&8 _g' #) MH ( ((<L M ")),HG*.*<*< '+ ' i! ( ("&6q&99 %qLM Q 2 3 O# #r# c | j ||| \ }}d d ||d}||\ }}||d< t || |d< |j j j } | j j d| d|j fi | ||fS )N)r parsed_responser r r r zresponse-received..)_do_get_responser" rI rD rJ r) rL r ) r1 rF r r rs r kwargs_to_emitr r rD s r! r zEndpoint._get_response s '+&;&; _g' #) " # " '-= *M?0?N, -.F /N? + %22==GGI Ao.B.B-C D **r# c t j d| t j d|j |j |j |j |j d |j j j }d| d|j }| j j || }t | }|| j! | }t' || } t) || || | j+ } |j, | d < t j d | |j. d } | j0 j3 | } | j5 | |j6 } |j8 d k\ r| j; | | || t j d| || fd fS # t" $ r}d |fcY d }~S d }~wt$ $ r%}t j dd d |fcY d }~S d }~ww xY w)NzSending http request: %s HTTP_REQUEST)methodr streamingurlr z before-send.r )rF z-Exception received when sending HTTP request.Tro r HTTP_RESPONSEprotocolr PARSED_RESPONSE) r> r? history_recorderrecordr r rn r r rI rD rJ r r) rL r _sendr rq r" r copyr metadatar/ create_parserparse output_shaper _add_modeled_error_fields)r1 rF r r rD rO responsesr er http_response_record_dictr parserr s r! r zEndpoint._do_get_response s LL3W = # # %nn &!0!D!D";; #LL )66AAKKMJ' |1_5I5I4JKJ ++00W0MI 3I >M $ $ 7 3 1 ? %2$6$6$8! 0 0 " 1JK"++J7..<<XF ,, ?77 $ $ + * * 1?C /55U !9 LL?$ !9 s0 CF+ + G.4F=7G.= G. G)#G.)G.c |j di j d }|y |j }|j | }|y |j || }|j | y )NErrorCode)r rI shape_for_error_coder update) r1 r r r r error_coderI error_shape modeled_parses r! r z"Endpoint._add_modeled_error_fieldsF sl %(("599&A '55 #88D ]K@ }-r# c & |j j j }d| d|j }| j j ||| |||| }t | } | yt j d| t j | y)Nz needs-retry.r )responseendpoint operationr caught_exceptionrA Fz3Response received to retry, sleeping for %s secondsT) rI rD rJ r r) rL r r> r? timesleep) r1 r r rA r r rD rO r handler_responses r! r zEndpoint._needs_retryX s %22==GGI #J<q 1E1E0FG '',, % -% - 39= # LLE JJ' (r# c 8 | j j | S r' )r0 sendr\ s r! r zEndpoint._sendx s %%g..r# )NNr' )__name__ __module__ __qualname____doc__r5 r: r< rB rQ rY rM rk ru r} r@ r r r r r r# r! r% r% M sl !% 1&7"A *5 ! . "K'$R+8=6~.. @/r# r% c 8 e Zd Zd Zddeeeddddf dZd Zd Z y)EndpointCreatorc || _ y r' )r) )r1 r3 s r! r5 zEndpointCreator.__init__} s +r# Nc & t | st | st d|z | | j | } |j } t j d| | ||| | j | || | | }t || | j || S )NzInvalid endpoint: %szSetting %s timeout as %s)timeoutproxiesverifymax_pool_connectionssocket_options client_certproxies_config)r2 r3 r4 r0 ) r r ValueError _get_proxiesr2 r> r? _get_verify_valuer% r) )r1 rI region_name endpoint_urlr r4 r r http_session_clsr r r r r2 r0 s r! create_endpointz EndpointCreator.create_endpoint s % ,\: 3l BC C ?'' 5G'77 / 'J'))&1!5)#) + --$;% r# c t | S r' )r )r1 r s r! r z EndpointCreator._get_proxies s #3''r# c J ||S t j j dd S )NREQUESTS_CA_BUNDLET)osenvironr )r1 r s r! r z!EndpointCreator._get_verify_value s' M zz~~ 2D99r# ) r r r r5 DEFAULT_TIMEOUTMAX_POOL_CONNECTIONSr r r r r r# r! r r | s4 , $ 1') V( :r# r )#r_ loggingr r+ r r{ botocorer botocore.awsrequestr botocore.exceptionsr botocore.historyr botocore.hooksr botocore.httpchecksumr botocore.httpsessionr botocore.responser botocore.utilsr r r getLoggerr r> r r r r" r% r r r# r! <module>r s 5 / 8 2 6 / + 8 $.0 Fl/ l/^ ?: ?:r#