uPSSKrSSKrSSKrSSKrSSKJrJrJr SSKJ r \R"\ 5r "SS5r"SS5r"SS 5r"S S \5r"S S \5r"SS5r"SS5rg)N) ensure_bytesensure_unicodeurlparse) EXCEPTION_MAPc.\rSrSr/SQrSrSrSrSrg)Monitor)zbefore-parameter-buildzrequest-createdzresponse-receivedz after-callzafter-call-errorcXlX lg)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 &lib/third_party/botocore/monitoring.py__init__Monitor.__init__!s #c`URHnURX R5 M g)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 URRX5nU(aURRU5 gg![a n[ R SUUSS9 SnAgSnAff=f)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.capture1sb  MM..zCM'' 6  LLL   s=A A+ A&&A+r N) __name__ __module__ __qualname____firstlineno__rrrr__static_attributes__rrrrs $I rrcv\rSrSr\R4SjrSrSrSrSr Sr Sr S r S r S rS rS rSrg)MonitorEventAdapterDcXlg)zAdapts event emitter events to produce monitor events :type time: callable :param time: A callable that produces the current time N_time)rtimes rrMonitorEventAdapter.__init__Es  rc0URU5"S0UD6$)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 r.) _get_handler)remitter_event_nameemitter_payloads rrMonitorEventAdapter.feedMs  !34GGGrcd[USURS5SRSS5-5$)N_handle_.r-_)getattrsplitreplace)rr$s rr8 MonitorEventAdapter._get_handler]s6 *z//4Q7??SII  rc x[URRURUR 5S9US'g)Nservice operation timestampcurrent_api_call_event) APICallEvent service_model service_id wire_name_get_current_time)rmodelcontextkwargss r_handle_before_parameter_build2MonitorEventAdapter._handle_before_parameter_buildbs4,8''22oo,,.- ()rc URnUSRUR5S9nURUlUR UlXCS'g)NrJ)rIcurrent_api_call_attempt_event)rQnew_api_call_attemptrOheadersrequest_headersurl)rrequestrRrQnew_attempt_events r_handle_request_created+MonitorEventAdapter._handle_request_createdisW//# $  )?)?)A  B -4OO) ' 4E01rc URS5nURU5UlUb2USSUlUSSUlUR S5UlU$X5lU$)NrVResponseMetadataHTTPStatusCode HTTPHeadersError)pop _get_latencylatencyhttp_status_coderesponse_headersget parsed_errorwire_exception)rparsed_responserQ exceptionrR attempt_events r_handle_response_received-MonitorEventAdapter._handle_response_receivedrs $DE $ 1 1- @   &-<".. M *.="..M **9)<) #"E * ():&&w//rc VURU5USlURU5$NrJ)_is_retryable_exceptionrsrt)rrQrmrRs r_handle_after_call_error,MonitorEventAdapter._handle_after_call_errors3"99)D  $ &&w//rc:[U[[S55$)NGENERAL_CONNECTION_ERROR) isinstancetupleRETRYABLE_EXCEPTIONS)rrms rrz+MonitorEventAdapter._is_retryable_exceptions  u12LMN  rcTURS5nURU5UlU$ry)rdrerf)rrQ call_events rrt&MonitorEventAdapter._complete_api_calls*[[!9: !..z: rc<UR5UR- $N)rOrIrevents rre MonitorEventAdapter._get_latencys%%'%//99rc:[UR5S-5$)Ni)intr4rs rrO%MonitorEventAdapter._get_current_times4::<$&''rr3N)r)r*r+r,r5rrr8rSr]rorvr{rzrtrerOr-r.rrr0r0DsG IIH   F"0 0  :(rr0c&\rSrSrSrSrSrSrg)BaseMonitorEventc(XlX lX0lg)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 NrF)rrGrHrIs rrBaseMonitorEvent.__init__s ""rcPURRSUR<S3$)N()) __class__r)__dict__rs r__repr__BaseMonitorEvent.__repr__s%..))*!DMM+>rcj[XR5(aURUR:H$g)NF)rrr)rothers r__eq__BaseMonitorEvent.__eq__s' e^^ , ,==ENN2 2r)rHrGrIN)r)r*r+r,rrrr-r.rrrrs#$?rrc8^\rSrSrSU4SjjrSrSrU=r$)rKcZ>[TU]XUS9 X@lXPlUc/UlX`lg)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 rFN)superrrfattemptsrs)rrGrHrIrfrrsrs rrAPICallEvent.__init__s<H I     DM 0rcz[URURUS9nURR U5 U$)zInstantiates APICallAttemptEvent associated to the APICallEvent :type timestamp: int :param timestamp: Epoch time in milliseconds to associate to the APICallAttemptEvent rF)APICallAttemptEventrGrHrappend)rrIrns rrW!APICallEvent.new_api_call_attempts7,LLDNNi  ]+r)rrfrs)NNF)r)r*r+r,rrWr- __classcell__rs@rrKrKs +1Z  rrKc:^\rSrSrSU4SjjrSrU=r$)rc v>[T U]XUS9 X@lXPlX`lXplXlXlXlg)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) rFN) rrrfrZrgrYrhrjrk) rrGrHrIrfrZrgrYrhrjrkrs rrAPICallAttemptEvent.__init__sGr I    0. 0(,r)rgrfrjrYrhrZrk)NNNNNNN)r)r*r+r,rr-rrs@rrrs&  B-B-rrc\rSrSrSrSrSrSrSrSSSS .r \ R"S 5\ R"S 5S .r /S Qr SrSrSrSrSrSrSrSrSrSrSrSrSrSrSrSrSrSrS r S!r!S"r"S#r#S$r$S%r%S&r&S'r'g()) CSMSerializeriBiXAmznRequestId XAmzRequestIdXAmzId2)zx-amzn-requestidzx-amz-request-idz x-amz-id-2zSAWS4-HMAC-SHA256 Credential=(?P\w+)/\d+/(?P[a-z0-9-]+)/zAWS (?P\w+):)v4s3) rGrHrIrrfrsrZrYrgrhrjrkc2URU5 Xlg)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_idrrs rrCSMSerializer.__init__ds   /*rcn[U5UR:a[SUSURS35eg)Nz&The value provided for csm_client_id: z exceeds the maximum length of z characters)len_MAX_CLIENT_ID_LENGTH ValueErrorrs rr!CSMSerializer._validate_client_idnsH }  : : :8H))-)C)C(DKQ  ;rcURU5nURU5nX2S'URH(n[XS5nUcM[USU-5"XRUS9 M* [ [ R "USS95$)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_PROPERTIESrArjsondumps)rr event_dictrattrvalues r serializeCSMSerializer.serializeus..u5 ))%0 '688DE.E md23*9 DJJzjIJJrc SURS.$)N)VersionClientIdrrs rr"CSMSerializer._get_base_event_dicts**  rc XS'g)NServicer.)rrGrrRs r_serialize_service CSMSerializer._serialize_services '9rc XS'g)NApir.)rrHrrRs r_serialize_operation"CSMSerializer._serialize_operations %5rc XS'g)N Timestampr.)rrIrrRs r_serialize_timestamp"CSMSerializer._serialize_timestamps "+;rc X[U5US'U(aURX!S5 gg)N AttemptCount)r_add_fields_from_last_attempt)rrrrRs r_serialize_attempts!CSMSerializer._serialize_attemptss*%(] >"   . .zB< H rcUR(a@URUR5nUbX1S'URUR5US'URbURUS'URbUR URUS5 UR bURUR US5 gg)NRegion UserAgentFinalHttpStatusCodeApiCall)rY _get_region_get_user_agentrgrj_serialize_parsed_errorrk_serialize_wire_exception)rr last_attemptregions rr+CSMSerializer._add_fields_from_last_attempts  ' '%%l&B&BCF!'-8$&*&:&:,,'J{ #  ( ( 40<0M0MJ, -  $ $ 0  ( ()):y   & & 2  * *++Z  3rc0US:XaXS'gUS:XaXS'gg)NrLatencyApiCallAttemptAttemptLatencyr.)rrfrrs r_serialize_latency CSMSerializer._serialize_latencys)  "$+y ! + ++2' (,rc U(aSOSUS'g)NrrMaxRetriesExceededr.)rrsrrRs r_serialize_retries_exceeded)CSMSerializer._serialize_retries_exceededs1A1a '(rc 4[U5RUS'g)NFqdn)rnetloc)rrZrrRs r_serialize_urlCSMSerializer._serialize_urls%c]11 6rc URU5US'URU5(aURU5US'URU5nUbXBS'SU;a USUS'gg)Nr AccessKeyrzX-Amz-Security-Token SessionToken)r _is_signed_get_access_keyr)rrYrrRrs r_serialize_request_headers(CSMSerializer._serialize_request_headerssz#'"6"6"G ; ??? + +&*&:&:?&KJ{ #!!/2  #)x !_ 4)8&*J~ & 5rc XS'g)NHttpStatusCoder.)rrgrrRs r_serialize_http_status_code)CSMSerializer._serialize_http_status_codes (8#$rc dURR5HupEXA;dM XX%'M gr)"_RESPONSE_HEADERS_TO_EVENT_ENTRIESitems)rrhrrRheaderentrys r_serialize_response_headers)CSMSerializer._serialize_response_headerss1"DDJJLMF)$4$< !Mrc US:XaSOSnURUSUR5X%S-'URUSUR5X%S-'g)NrFinalCode AwsExceptionMessageAwsExceptionMessage) _truncate_MAX_ERROR_CODE_LENGTH_MAX_MESSAGE_LENGTH)rrjrrrR field_prefixs rr%CSMSerializer._serialize_parsed_errorsb#- "9wr 48NN  $"="=5 .01<@>>  #T%=%=< "778rc US:XaSOSnURURRUR5X%S-'UR[ U5UR 5X%S-'g)Nrrr SdkExceptionSdkExceptionMessage)r rr)_MAX_EXCEPTION_CLASS_LENGTHstrr")rrkrrrRr#s rr'CSMSerializer._serialize_wire_exceptionsi#- "9wr 48NN  $ $ - -t/O/O5 .01<@>>  !9!9< "778rc\[U[5(ag[U[5(agg)Nrr)rrKrrs rrCSMSerializer._get_event_types( e\ * * 2 3 3#4rclURU5nURU5up4URS5$)N access_key)_get_auth_value_get_auth_matchgroup)rrYauth_valr@ auth_matchs rr CSMSerializer._get_access_keys5''8,,X6  --rcURU5(dgURU5nURU5up4US:wagURS5$)Nrsigning_region)r r/r0r1)rrYr2signature_versionr3s rrCSMSerializer._get_regionsU//''8(,(<()rr;s rr/CSMSerializer._get_auth_value soo>??rcURR5H"up#URU5nU(dMX$4s $ g)N)NN) _AUTH_REGEXSrmatch)rr2r7regexrEs rr0CSMSerializer._get_auth_matchsA(,(9(9(?(?(A $ KK)Eu(//)Brc\[U5U:a[RSUU5 USU$U$)Nz6Truncating following value to maximum length of %s: %s)rr"r#)rtext max_lengths rr CSMSerializer._truncates7 t9z ! LLK   $ $ rrN)(r)r*r+r,rr(r!r:r"rrecompilerDrrrrrrrrrrrrrr rrrrrr rrr r/r0r r-r.rrrrBs"%  ,+*& jj / jj45 L '#+K( (&,I *3 H 2 8 =    $ . 2 2@rrc$\rSrSrSrSrSrSrg)SocketPublisheri"i c,XlX#4UlX@lg)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)rsockethostport serializers rrSocketPublisher.__init__%s"   %rc URRU5n[U5UR:a+[R S[U5UR5 gUR RX R5 g)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) rSrr_MAX_MONITOR_EVENT_LENGTHr"r#rQsendtorR)rrserialized_events rr SocketPublisher.publish:sn ++55e<  4#A#A A LL<$%..    ,mmrbs  BBG   8 $))X](](@89#9xC-*C-L]]@(=(=r