+ irP^RIt^RIt^RIt^RIt^RIHtHtHt^RIH t ]P!] 4t !RR4t!RR4t!RR 4t!R R ]4t!R R ]4t!RR4t!RR4tR#)N) ensure_bytesensure_unicodeurlparse) EXCEPTION_MAPc:a]tRt^to.ROtRtRtRtRtVt R#)Monitorc WnW nR#)zAbstraction for monitoring clients API calls :param adapter: An adapter that takes event emitter events and produces monitor events :param publisher: A publisher for generated monitor events N_adapter _publisher)selfadapter publishers&&&5/usr/lib/python3/dist-packages/botocore/monitoring.py__init__Monitor.__init__!s #c bVPFpVPW P4K R#)z(Register an event emitter to the monitorN)_EVENTS_TO_REGISTER register_lastcapture)r event_emitterevent_to_registers&& rregisterMonitor.register,s&!%!9!9   ' '(9<< H":rc VPPW4pV'dVPPV4R#R# \d%p\ P RTTRR7Rp?R#Rp?ii;i)zCaptures an incoming event from the event emitter It will feed an event emitter event to the monitor's adaptor to create a monitor event and then publish that event to the monitor's publisher. z:Exception %s raised by client monitor in handling event %sT)exc_infoN)r feedr publish Exceptionloggerdebug)r event_namepayload monitor_eventes&&, rrMonitor.capture1sg  MM..zCM'' 6  LLL    s>A A3A..A3r N)zbefore-parameter-buildzrequest-createdzresponse-receivedz after-callzafter-call-error) __name__ __module__ __qualname____firstlineno__rrrr__static_attributes____classdictcell__ __classdict__s@rrrs" $I rrca]tRt^Dto]P3RltRtRtRtRt Rt Rt Rt R t R tR tR tR tVtR#)MonitorEventAdapterc WnR#)zAdapts event emitter events to produce monitor events :type time: callable :param time: A callable that produces the current time N_time)r times&&rrMonitorEventAdapter.__init__Es  rc 0VPV4!R/VB#)aXFeed an event emitter event to generate a monitor event :type emitter_event_name: str :param emitter_event_name: The name of the event emitted :type emitter_payload: dict :param emitter_payload: The payload to associated to the event emitted :rtype: BaseMonitorEvent :returns: A monitor event based on the event emitter events fired ) _get_handler)r emitter_event_nameemitter_payloads&&&rrMonitorEventAdapter.feedMs  !34GGGrct\VRVPR4^,PRR4,4#)_handle_.-_)getattrsplitreplace)r r#s&&rr9 MonitorEventAdapter._get_handler]s6 *z//4Q7??SII  rc \VPPVPVP 4R7VR&R#)service operation timestampcurrent_api_call_eventN) APICallEvent service_model service_id wire_name_get_current_time)r modelcontextkwargss&&&,r_handle_before_parameter_build2MonitorEventAdapter._handle_before_parameter_buildbs4,8''22oo,,.- ()rc VPpVR,PVP4R7pVPVnVP VnWCR&R#)rK)rJcurrent_api_call_attempt_eventN)rRnew_api_call_attemptrPheadersrequest_headersurl)r requestrSrRnew_attempt_events&&, r_handle_request_created+MonitorEventAdapter._handle_request_createdisW//# $  )?)?)A  B -4OO) ' 4E01rc VPR4pVPV4VnVeCVR,R,VnVR,R,VnVP R4VnV#W5nV#)rWResponseMetadataHTTPStatusCode HTTPHeadersError)pop _get_latencylatencyhttp_status_coderesponse_headersget parsed_errorwire_exception)r parsed_responserR exceptionrS attempt_events&&&&, r_handle_response_received-MonitorEventAdapter._handle_response_receivedrs $DE $ 1 1- @   &-<".. M *.="..M **9)<) #"E * ():&&w//rc ^VPV4VR,nVPV4#rK)_is_retryable_exceptionrtru)r rRrnrSs&&&,r_handle_after_call_error,MonitorEventAdapter._handle_after_call_errors3"99)D  $ &&w//rcB\V\\R,44#)GENERAL_CONNECTION_ERROR) isinstancetupleRETRYABLE_EXCEPTIONS)r rns&&rr{+MonitorEventAdapter._is_retryable_exceptions  u12LMN  rcTVPR4pVPV4VnV#rz)rerfrg)r rR call_events&& rru&MonitorEventAdapter._complete_api_calls*[[!9: !..z: rcDVP4VP, #N)rPrJr events&&rrf MonitorEventAdapter._get_latencys%%'%//99rcB\VP4R,4#)i)intr4r s&rrP%MonitorEventAdapter._get_current_times4::<$&''rr3N)r(r)r*r+r5rrr9rTr^rprwr|r{rurfrPr,r-r.s@rr1r1DsO IIH   F"0 0  :((rr1c2a]tRt^toRtRtRtRtVtR#)BaseMonitorEventc *WnW nW0nR#)aCBase monitor event :type service: str :param service: A string identifying the service associated to the event :type operation: str :param operation: A string identifying the operation of service associated to the event :type timestamp: int :param timestamp: Epoch time in milliseconds from when the event began NrG)r rHrIrJs&&&&rrBaseMonitorEvent.__init__s ""rcPVPP RVP: R2#)()) __class__r(__dict__rs&r__repr__BaseMonitorEvent.__repr__s%..))*!DMM+>rcn\WP4'dVPVP8H#R#)F)rrr)r others&&r__eq__BaseMonitorEvent.__eq__s' e^^ , ,==ENN2 2r)rIrHrJN) r(r)r*r+rrrr,r-r.s@rrrs#$?rrc<aa]tRt^toRV3RlltRtRtVtV;t#)rLc d<\SV`WVR7W@nWPnVf.VnW`nR#)a Monitor event for a single API call This event corresponds to a single client method call, which includes every HTTP requests attempt made in order to complete the client call :type service: str :param service: A string identifying the service associated to the event :type operation: str :param operation: A string identifying the operation of service associated to the event :type timestamp: int :param timestamp: Epoch time in milliseconds from when the event began :type latency: int :param latency: The time in milliseconds to complete the client call :type attempts: list :param attempts: The list of APICallAttempts associated to the APICall :type retries_exceeded: bool :param retries_exceeded: True if API call exceeded retries. False otherwise rGN)superrrgattemptsrt)r rHrIrJrgrrtrs&&&&&&&rrAPICallEvent.__init__s<H I     DM 0rc \VPVPVR7pVPP V4V#)zInstantiates APICallAttemptEvent associated to the APICallEvent :type timestamp: int :param timestamp: Epoch time in milliseconds to associate to the APICallAttemptEvent rG)APICallAttemptEventrHrIrappend)r rJros&& rrX!APICallEvent.new_api_call_attempts7,LLDNNi  ]+r)rrgrt)NNF) r(r)r*r+rrXr,r- __classcell__rr/s@@rrLrLs+1Z  rrLc6aa]tRt^toRV3RlltRtVtV;t#)rc  ~<\S V`WVR7W@nWPnW`nWpnWnWnWnR#)aMonitor event for a single API call attempt This event corresponds to a single HTTP request attempt in completing the entire client method call. :type service: str :param service: A string identifying the service associated to the event :type operation: str :param operation: A string identifying the operation of service associated to the event :type timestamp: int :param timestamp: Epoch time in milliseconds from when the HTTP request started :type latency: int :param latency: The time in milliseconds to complete the HTTP request whether it succeeded or failed :type url: str :param url: The URL the attempt was sent to :type http_status_code: int :param http_status_code: The HTTP status code of the HTTP response if there was a response :type request_headers: dict :param request_headers: The HTTP headers sent in making the HTTP request :type response_headers: dict :param response_headers: The HTTP headers returned in the HTTP response if there was a response :type parsed_error: dict :param parsed_error: The error parsed if the service returned an error back :type wire_exception: Exception :param wire_exception: The exception raised in sending the HTTP request (i.e. ConnectionError) rGN) rrrgr[rhrZrirkrl) r rHrIrJrgr[rhrZrirkrlrs &&&&&&&&&&&rrAPICallAttemptEvent.__init__sGr I    0. 0(,r)rhrgrkrZrir[rl)NNNNNNN)r(r)r*r+rr,r-rrs@@rrrsB-B-rrc.a]tRtRto^t^t^tRtRtRRRRRR /t R ] P!R 4R ] P!R 4/t .R)Ot RtRtRtRtRtRtRtRtRtRtRtRtRtRtRtRtRtRtR t R!t!R"t"R#t#R$t$R%t%R&t&R't'Vt(R(#)* CSMSerializeriBizx-amzn-requestidXAmznRequestIdzx-amz-request-id XAmzRequestIdz x-amz-id-2XAmzId2v4zSAWS4-HMAC-SHA256 Credential=(?P\w+)/\d+/(?P[a-z0-9-]+)/s3zAWS (?P\w+):c 4VPV4WnR#)zSerializes monitor events to CSM (Client Side Monitoring) format :type csm_client_id: str :param csm_client_id: The application identifier to associate to the serialized events N)_validate_client_id csm_client_idr rs&&rrCSMSerializer.__init__ds   /*rcr\V4VP8d\RV RVP R24hR#)z&The value provided for csm_client_id: z exceeds the maximum length of z charactersN)len_MAX_CLIENT_ID_LENGTH ValueErrorrs&&rr!CSMSerializer._validate_client_idnsH }  : : :8H))-)C)C(DKQ  ;rc VPV4pVPV4pW2R&VPF0p\WR4pVfK\VRV,4!WRVR7K2 \ \ P !VRR74#)zSerializes a monitor event to the CSM format :type event: BaseMonitorEvent :param event: The event to serialize to bytes :rtype: bytes :returns: The CSM serialized form of the event TypeN _serialize_) event_type) separators),:)_get_base_event_dict_get_event_type_SERIALIZEABLE_EVENT_PROPERTIESrBrjsondumps)r r event_dictrattrvalues&& r serializeCSMSerializer.serializeus..u5 ))%0 '688DE.E md23*9 DJJzjIJJrc"R^RVP/#)VersionClientIdrrs&&rr"CSMSerializer._get_base_event_dicts q **  rc WR&R#)ServiceNr8)r rHrrSs&&&,r_serialize_service CSMSerializer._serialize_services '9rc WR&R#)ApiNr8)r rIrrSs&&&,r_serialize_operation"CSMSerializer._serialize_operations %5rc WR&R#) TimestampNr8)r rJrrSs&&&,r_serialize_timestamp"CSMSerializer._serialize_timestamps "+;rc f\V4VR&V'dVPW!R,4R#R#) AttemptCountN)r_add_fields_from_last_attempt)r rrrSs&&&,r_serialize_attempts!CSMSerializer._serialize_attemptss*%(] >"   . .zB< H rcVP'dBVPVP4pVeW1R&VPVP4VR&VPeVPVR&VPeVP VPVR4VP e VPVP VR4R#R#)NRegion UserAgentFinalHttpStatusCodeApiCall)rZ _get_region_get_user_agentrhrk_serialize_parsed_errorrl_serialize_wire_exception)r r last_attemptregions&&& rr+CSMSerializer._add_fields_from_last_attempts  ' ' '%%l&B&BCF!'-8$&*&:&:,,'J{ #  ( ( 40<0M0MJ, -  $ $ 0  ( ()):y   & & 2  * *++Z  3rc:VR8XdWR&R#VR8XdWR&R#R#)rLatencyApiCallAttemptAttemptLatencyNr8)r rgrrs&&&&r_serialize_latency CSMSerializer._serialize_latencys)  "$+y ! + ++2' (,rc $V'd^M^VR&R#)MaxRetriesExceededNr8)r rtrrSs&&&,r_serialize_retries_exceeded)CSMSerializer._serialize_retries_exceededs1A1a '(rc 6\V4PVR&R#)FqdnN)rnetloc)r r[rrSs&&&,r_serialize_urlCSMSerializer._serialize_urls%c]11 6rc VPV4VR&VPV4'dVPV4VR&VPV4pVeWBR&RV9dVR,VR&R#R#)r AccessKeyNrzX-Amz-Security-Token SessionToken)r _is_signed_get_access_keyr)r rZrrSrs&&&, r_serialize_request_headers(CSMSerializer._serialize_request_headerssz#'"6"6"G ; ??? + +&*&:&:?&KJ{ #!!/2  #)x !_ 4)8&*J~ & 5rc WR&R#)HttpStatusCodeNr8)r rhrrSs&&&,r_serialize_http_status_code)CSMSerializer._serialize_http_status_codes (8#$rc pVPP4FwrEWA9gK W,W%&K R#r)"_RESPONSE_HEADERS_TO_EVENT_ENTRIESitems)r rirrSheaderentrys&&&, r_serialize_response_headers)CSMSerializer._serialize_response_headerss1"DDJJLMF)$4$< !Mrc VR8XdRMRpVPVR,VP4W%R,&VPVR,VP4W%R,&R#)rFinalCode AwsExceptionMessageAwsExceptionMessageN) _truncate_MAX_ERROR_CODE_LENGTH_MAX_MESSAGE_LENGTH)r rkrrrS field_prefixs&&&&, rr%CSMSerializer._serialize_parsed_errorsb#- "9wr 48NN  $"="=5 .01<@>>  #T%=%=< "778rc VR8XdRMRpVPVPPVP4W%R,&VP\ V4VP 4W%R,&R#)rrr SdkExceptionSdkExceptionMessageN)rrr(_MAX_EXCEPTION_CLASS_LENGTHstrr)r rlrrrSrs&&&&, rr'CSMSerializer._serialize_wire_exceptionsi#- "9wr 48NN  $ $ - -t/O/O5 .01<@>>  !9!9< "778rcf\V\4'dR#\V\4'dR#R#)rrN)rrLrrs&&rrCSMSerializer._get_event_types( e\ * * 2 3 3#4rclVPV4pVPV4wr4VPR4#) access_key)_get_auth_value_get_auth_matchgroup)r rZauth_valrA auth_matchs&& rrCSMSerializer._get_access_keys5''8,,X6  --rcVPV4'gR#VPV4pVPV4wr4VR8wdR#VPR4#)Nrsigning_region)rr+r,r-)r rZr.signature_versionr/s&& rrCSMSerializer._get_regionsU//''8(,(<(??rcVPP4F#wr#VPV4pV'gK W$3u# R#)N)NN) _AUTH_REGEXSrmatch)r r.r3regexrAs&& rr,CSMSerializer._get_auth_matchsD(,(9(9(?(?(A $ KK)Eu(//)Brc^\V4V8d\PRVV4VRV#V#)z6Truncating following value to maximum length of %s: %sN)rr!r")r text max_lengths&&&rrCSMSerializer._truncates7 t9z ! LLH   $ $ rrN) rHrIrJrrgrtr[rZrhrirkrl))r(r)r*r+rr$rr6rrrecompiler@rrrrrrrrrrrrrrr rrrrrrrrr+r,rr,r-r.s@rrrBs"%  ,Oi*& bjj / bjj45 L '#+K( (&,I *3 H 2 8 =    $ . 2 2@rrc0a]tRtRtoRtRtRtRtVtR#)SocketPublisheri"c .WnW#3VnW@nR#)aPublishes monitor events to a socket :type socket: socket.socket :param socket: The socket object to use to publish events :type host: string :param host: The host to send events to :type port: integer :param port: The port on the host to send events to :param serializer: The serializer to use to serialize the event to a form that can be published to the socket. This must have a `serialize()` method that accepts a monitor event and return bytes N)_socket_address _serializer)r sockethostport serializers&&&&&rrSocketPublisher.__init__%s"   %rc VPPV4p\V4VP8d-\P R\V4VP4R#VP PW P4R#)zPublishes a specified monitor event :type event: BaseMonitorEvent :param event: The monitor event to be sent over the publisher's socket to the desired address. z`Serialized event of size %s exceeds the maximum length allowed: %s. Not sending event to socket.N) rOrr_MAX_MONITOR_EVENT_LENGTHr!r"rMsendtorN)r rserialized_events&& rrSocketPublisher.publish:sn ++55e<  4#A#A A LL<$%..    ,mmr^s  BBG   8 $))X](](@89#9xC-*C-L]]@(=(=r