+ IirPcs^RIt^RIt^RIt^RIt^RIHtHtHt^RIH t ]P!] 4t !RR4t!RR4t!RR 4t!R R ]4t!R R ]4t!RR4t!RR4tR#)iN) ensure_bytesensure_unicodeurlparse) EXCEPTION_MAPcs:a]tRt^to.ROtRtRtRtRtVt R#)Monitorc sWnW 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)selfZadapterZ publisher&&&8/usr/lib/python3.14/site-packages/botocore/monitoring.py__init__ZMonitor.__init__!s #c sbVPFpVPW P4K R#)z(Register an event emitter to the monitorN)_EVENTS_TO_REGISTERZ register_lastcapture)rZ event_emitterZevent_to_register&& r registerZMonitor.register,s&!%!9!9   ' '(9<< H":r c sVPPW4pV'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)Zexc_infoN)rfeedrpublishZ Exceptionloggerdebug)r event_nameZpayloadZ monitor_eventZe&&, r rZMonitor.capture1sg  MM..zCM'' 6  LLL    s>A A3A..A3rN)zbefore-parameter-buildzrequest-createdzresponse-receivedz after-callzafter-call-error) __name__ __module__ __qualname____firstlineno__r r rr__static_attributes____classdictcell__ __classdict__@r rrs" $I r rcsa]tRt^Dto]P3RltRtRtRtRt Rt Rt Rt R t R tR tR tR tVtR#)MonitorEventAdapterc sWnR#)zAdapts event emitter events to produce monitor events :type time: callable :param time: A callable that produces the current time N_time)rtime&&r r ZMonitorEventAdapter.__init__Es  r c s0VPV4!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)rZemitter_event_nameZemitter_payloadr r rZMonitorEventAdapter.feedMs  !34GGGr cst\VRVPR4^,PRR4,4#)Z_handle_Z.Z-_)getattrZsplitZreplace)rrr$r r&Z MonitorEventAdapter._get_handler]s6 *z//4Q7??SII  r c s\VPPVPVP 4R7VR&R#)service operation timestampcurrent_api_call_eventN) APICallEventZ service_modelZ service_idZ wire_name_get_current_time)rZmodelcontextkwargs&&&,r _handle_before_parameter_buildZ2MonitorEventAdapter._handle_before_parameter_buildbs4,8''22oo,,.- ()r c sVPpVR,PVP4R7pVPVnVP VnWCR&R#)r-)r,current_api_call_attempt_eventN)r0new_api_call_attemptr/Zheadersrequest_headersurl)rZrequestr1r0Znew_attempt_eventrr _handle_request_createdZ+MonitorEventAdapter._handle_request_createdisW//# $  )?)?)A  B -4OO) ' 4E01r c sVPR4pVPV4VnVeCVR,R,VnVR,R,VnVP R4VnV#W5nV#)r4ResponseMetadataZHTTPStatusCodeZ HTTPHeadersZError)pop _get_latencylatencyhttp_status_coderesponse_headersget parsed_errorwire_exception)rZparsed_responser0 exceptionr1 attempt_event&&&&, r _handle_response_receivedZ-MonitorEventAdapter._handle_response_receivedrs $DE $ 1 1- @   &-<".. M *.="..M **9)<) #"E * ():&&w//r c s^VPV4VR,nVPV4#r-)_is_retryable_exceptionrFrG)rr0rBr1r2r _handle_after_call_errorZ,MonitorEventAdapter._handle_after_call_errors3"99)D  $ &&w//r csB\V\\R,44#)ZGENERAL_CONNECTION_ERROR) isinstanceZtupleRETRYABLE_EXCEPTIONS)rrBr$r rJZ+MonitorEventAdapter._is_retryable_exceptions  u12LMN  r csTVPR4pVPV4VnV#rI)r:r;r<)rr0Z call_eventrr rGZ&MonitorEventAdapter._complete_api_calls*[[!9: !..z: r csDVP4VP, #N)r/r,reventr$r r;Z MonitorEventAdapter._get_latencys%%'%//99r csB\VP4R,4#)i)Zintr"r&r r/Z%MonitorEventAdapter._get_current_times4::<$&''r r!N)rrrrr#r rr&r3r8rErHrKrJrGr;r/rrrrr r r DsO IIH   F"0 0  :((r r cs2a]tRt^toRtRtRtRtVtR#)BaseMonitorEventc s*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 Nr))rr*r+r,&&&&r r ZBaseMonitorEvent.__init__s ""r csPVPP RVP: R2#)Z(Z)) __class__r__dict__rQrRr __repr__ZBaseMonitorEvent.__repr__s%..))*!DMM+>r csn\WP4'dVPVP8H#R#)F)rLrUrV)rZotherr$r __eq__ZBaseMonitorEvent.__eq__s' e^^ , ,==ENN2 2r )r+r*r,N) rrrrr rWrXrrrrr rSrSs#$?r rScs<aa]tRt^toRV3RlltRtRtVtV;t#)r.c sd<\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 r)N)superr r<attemptsrF)rr*r+r,r<rZrFrUs&&&&&&&r r ZAPICallEvent.__init__s<H I     DM 0r c s\VPVPVR7pVPP V4V#)zInstantiates APICallAttemptEvent associated to the APICallEvent :type timestamp: int :param timestamp: Epoch time in milliseconds to associate to the APICallAttemptEvent r))APICallAttemptEventr*r+rZZappend)rr,rCrr r5Z!APICallEvent.new_api_call_attempts7,LLDNNi  ]+r )rZr<rF)NNF) rrrrr r5rr __classcell__rUr@@r r.r.s+1Z  r r.cs6aa]tRt^toRV3RlltRtVtV;t#)r[c  s~<\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) r)N) rYr r<r7r=r6r>r@rA) rr*r+r,r<r7r=r6r>r@rArUs &&&&&&&&&&&r r ZAPICallAttemptEvent.__init__sGr I    0. 0(,r )r=r<r@r6r>r7rA)NNNNNNN)rrrrr rrr\r]r^r r[r[sB-B-r r[cs.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(#)* CSMSerializeriBiizx-amzn-requestidZXAmznRequestIdzx-amz-request-idZ XAmzRequestIdz x-amz-id-2ZXAmzId2v4zSAWS4-HMAC-SHA256 Credential=(?P\w+)/\d+/(?P[a-z0-9-]+)/Zs3zAWS (?P\w+):c s4VPV4WnR#)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_idrrbr$r r ZCSMSerializer.__init__ds   /*r csr\V4VP8d\RV RVP R24hR#)z&The value provided for csm_client_id: z exceeds the maximum length of z charactersN)len_MAX_CLIENT_ID_LENGTHZ ValueErrorrcr$r raZ!CSMSerializer._validate_client_idnsH }  : : :8H))-)C)C(DKQ  ;r c sVPV4pVPV4pW2R&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 ZTypeNZ _serialize_) event_type)Z separators)Z,Z:)_get_base_event_dict_get_event_type_SERIALIZEABLE_EVENT_PROPERTIESr(rjsonZdumps)rrP event_dictrfZattrZvalues&& r serializeZCSMSerializer.serializeus..u5 ))%0 '688DE.E md23*9 DJJzjIJJr cs"R^RVP/#)ZVersionZClientIdrbrOr$r rgZ"CSMSerializer._get_base_event_dicts q **  r c WR&R#)ZServiceNr%)rr*rkr1r2r _serialize_serviceZ CSMSerializer._serialize_services '9r c rn)ZApiNr%)rr+rkr1r2r _serialize_operationZ"CSMSerializer._serialize_operations %5r c rn)Z TimestampNr%)rr,rkr1r2r _serialize_timestampZ"CSMSerializer._serialize_timestamps "+;r c sf\V4VR&V'dVPW!R,4R#R#)Z AttemptCountNi)rd_add_fields_from_last_attempt)rrZrkr1r2r _serialize_attemptsZ!CSMSerializer._serialize_attemptss*%(] >"   . .zB< H r csVP'dBVPVP4pVeW1R&VPVP4VR&VPeVPVR&VPeVP VPVR4VP e VPVP VR4R#R#)NRegion UserAgentZFinalHttpStatusCodeApiCall)r6 _get_region_get_user_agentr=r@_serialize_parsed_errorrA_serialize_wire_exception)rrkZ last_attemptregions&&& r rrZ+CSMSerializer._add_fields_from_last_attempts  ' ' '%%l&B&BCF!'-8$&*&:&:,,'J{ #  ( ( 40<0M0MJ, -  $ $ 0  ( ()):y   & & 2  * *++Z  3r cs:VR8XdWR&R#VR8XdWR&R#R#)rvZLatencyApiCallAttemptZAttemptLatencyNr%)rr<rkrfrTr _serialize_latencyZ CSMSerializer._serialize_latencys)  "$+y ! + ++2' (,r c s$V'd^M^VR&R#)iZMaxRetriesExceededNr%)rrFrkr1r2r _serialize_retries_exceededZ)CSMSerializer._serialize_retries_exceededs1A1a '(r c s6\V4PVR&R#)ZFqdnN)rZnetloc)rr7rkr1r2r _serialize_urlZCSMSerializer._serialize_urls%c]11 6r c sVPV4VR&VPV4'dVPV4VR&VPV4pVeWBR&RV9dVR,VR&R#R#)ruZ AccessKeyNrtzX-Amz-Security-TokenZ SessionToken)rx _is_signed_get_access_keyrw)rr6rkr1r{s&&&, r _serialize_request_headersZ(CSMSerializer._serialize_request_headerssz#'"6"6"G ; ??? + +&*&:&:?&KJ{ #!!/2  #)x !_ 4)8&*J~ & 5r c rn)ZHttpStatusCodeNr%)rr=rkr1r2r _serialize_http_status_codeZ)CSMSerializer._serialize_http_status_codes (8#$r c spVPP4FwrEWA9gK W,W%&K R#rN)"_RESPONSE_HEADERS_TO_EVENT_ENTRIESitems)rr>rkr1ZheaderZentrys&&&, r _serialize_response_headersZ)CSMSerializer._serialize_response_headerss1"DDJJLMF)$4$< !Mr c sVR8XdRMRpVPVR,VP4W%R,&VPVR,VP4W%R,&R#)rvFinalZCodeZ AwsExceptionZMessageZAwsExceptionMessageN) _truncate_MAX_ERROR_CODE_LENGTH_MAX_MESSAGE_LENGTH)rr@rkrfr1 field_prefixrDr ryZ%CSMSerializer._serialize_parsed_errorsb#- "9wr 48NN  $"="=5 .01<@>>  #T%=%=< "778r c sVR8XdRMRpVPVPPVP4W%R,&VP\ V4VP 4W%R,&R#)rvrrZ SdkExceptionZSdkExceptionMessageN)rrUr_MAX_EXCEPTION_CLASS_LENGTHZstrr)rrArkrfr1rrDr rzZ'CSMSerializer._serialize_wire_exceptionsi#- "9wr 48NN  $ $ - -t/O/O5 .01<@>>  !9!9< "778r csf\V\4'dR#\V\4'dR#R#)rvr|N)rLr.r[rOr$r rhZCSMSerializer._get_event_types( e\ * * 2 3 3#4r cslVPV4pVPV4wr4VPR4#)Z access_key)_get_auth_value_get_auth_matchgroup)rr6auth_valr' auth_match&& r rZCSMSerializer._get_access_keys5''8,,X6  --r csVPV4'gR#VPV4pVPV4wr4VR8wdR#VPR4#)Nr`Zsigning_region)rrrr)rr6rsignature_versionrrr rwZCSMSerializer._get_regionsU//''8(,(<(??r csVPP4F#wr#VPV4pV'gK W$3u# R#)N)NN) _AUTH_REGEXSrmatch)rrrZregexrrr rZCSMSerializer._get_auth_matchsD(,(9(9(?(?(A $ KK)Eu(//)Br cs^\V4V8d\PRVV4VRV#V#)z6Truncating following value to maximum length of %s: %sN)rdrr)rZtextZ max_lengthr r rZCSMSerializer._truncates7 t9z ! LLH   $ $ r rmN) r*r+r,rZr<rFr7r6r=r>r@rA))rrrrrerrrrrreZcompilerrir rarlrgrorprqrsrrr}r~rrrrryrzrhrrwrxrrrrrrrrr r_r_Bs"%  ,Oi*& bjj / bjj45 L '#+K( (&,I *3 H 2 8 =    $ . 2 2@r r_cs0a]tRtRtoRtRtRtRtVtR#)SocketPublisheri"c s.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)rZsocketZhostZportZ serializers&&&&&r r ZSocketPublisher.__init__%s"   %r c sVPPV4p\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) rrlrd_MAX_MONITOR_EVENT_LENGTHrrrZsendtor)rrPZserialized_eventrr rZSocketPublisher.publish:sn ++55e<  4#A#A A LL<$%..    ,mmrs  BBG   8 $))X](](@89#9xC-*C-L]]@(=(=r