Файловый менеджер - Редактировать - /usr/lib/rads/venv/lib/python3.13/site-packages/botocore/__pycache__/monitoring.cpython-313.pyc
Ðазад
� � �irP � � � S SK r S SKrS SKrS SKrS SKJrJrJr S SKJ r \R " \ 5 r " S S5 r " S S5 r " S S 5 r " S S \5 r " S S \5 r " S S5 r " S S5 rg)� N)� ensure_bytes�ensure_unicode�urlparse)� EXCEPTION_MAPc �. � \ rS rSr/ SQrS rS rS rSrg)�Monitor� )zbefore-parameter-buildzrequest-createdzresponse-receivedz after-callzafter-call-errorc � � Xl X l g)z�Abstraction 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)�self�adapter� publishers �F/usr/lib/rads/venv/lib/python3.13/site-packages/botocore/monitoring.py�__init__�Monitor.__init__! s � � � �#�� c �` � U R H nUR X R 5 M g)z(Register an event emitter to the monitorN)�_EVENTS_TO_REGISTER� register_last�capture)r � event_emitter�event_to_registers r �register�Monitor.register, s& � �!%�!9�!9� � � '� '�(9�<�<� H� ":r c �� � U R R X5 nU( a U R R U5 gg! [ a n[ R SUUSS9 SnAgSnAff = f)z�Captures 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� Exception�logger�debug)r � event_name�payload� monitor_event�es r r �Monitor.capture1 sb � � � �M�M� .� .�z� C�M� ����'�'� �6� ��� � �L�L�L��� � � �� �s �=A � A+� A&�&A+r N) �__name__� __module__� __qualname__�__firstlineno__r r r r �__static_attributes__� r r r r s � ��� $�I� r r c �v � \ rS rSr\R 4S jrS rS rS rS r S r S r S r S r S rS rS rSrg)�MonitorEventAdapter�D c � � Xl g)z�Adapts event emitter events to produce monitor events :type time: callable :param time: A callable that produces the current time N��_time)r �times r r � MonitorEventAdapter.__init__E s � � � r c �0 � U R U5 " S0 UD6$ )aX Feed 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)r �emitter_event_name�emitter_payloads r r �MonitorEventAdapter.feedM s � � � � �!3�4�G��G�Gr c �d � [ U SUR S5 S R SS5 - 5 $ )N�_handle_�.r �-�_)�getattr�split�replace)r r$ s r r8 � MonitorEventAdapter._get_handler] s6 � �� �*�z� /� /�� 4�Q� 7� ?� ?��S� I�I� � r c �x � [ UR R UR U R 5 S9US' g )N��service� operation� timestamp�current_api_call_event)� APICallEvent� service_model� service_id� wire_name�_get_current_time)r �model�context�kwargss r � _handle_before_parameter_build�2MonitorEventAdapter._handle_before_parameter_buildb s4 � �,8��'�'�2�2��o�o��,�,�.�- ��(�)r c � � UR nUS R U R 5 S9nUR Ul UR Ul XCS' g )NrJ )rI � current_api_call_attempt_event)rQ �new_api_call_attemptrO �headers�request_headers�url)r �requestrR rQ �new_attempt_events r �_handle_request_created�+MonitorEventAdapter._handle_request_createdi sW � ��/�/�� #� $� � � ��)?�)?�)A� � B� � -4�O�O��)� '� � �� �4E�0�1r c �� � UR S5 nU R U5 Ul Ub2 US S Ul US S Ul UR S5 Ul U$ X5l U$ )NrV �ResponseMetadata�HTTPStatusCode� HTTPHeaders�Error)�pop� _get_latency�latency�http_status_code�response_headers�get� parsed_error�wire_exception)r �parsed_responserQ � exceptionrR � attempt_events r �_handle_response_received�-MonitorEventAdapter._handle_response_receivedr s� � � � � �$D�E� � $� 1� 1�-� @� � � � &�-<�"�.� �. �M� *� .=�"�.��. �M� *� *9�)<�)<�W�)E�M� &� � � ,5� (� � r c �^ � US R SS5 US l U R U5 $ )Nr` �MaxAttemptsReachedFrJ )ri �retries_exceeded�_complete_api_call)r rQ �parsedrR s r �_handle_after_call�&MonitorEventAdapter._handle_after_call� s; � �=C� �> � �#�"�E� *� �(�)�:� �&�&�w�/�/r c �V � U R U5 US l U R U5 $ �NrJ )�_is_retryable_exceptionrs rt )r rQ rm rR s r �_handle_after_call_error�,MonitorEventAdapter._handle_after_call_error� s3 � � "� 9� 9�)� D� � $� � ��&�&�w�/�/r c �: � [ U[ [ S 5 5 $ )N�GENERAL_CONNECTION_ERROR)� isinstance�tuple�RETRYABLE_EXCEPTIONS)r rm s r rz �+MonitorEventAdapter._is_retryable_exception� s � �� �u� 1�2L� M�N� � r c �T � UR S5 nU R U5 Ul U$ ry )rd re rf )r rQ � call_events r rt �&MonitorEventAdapter._complete_api_call� s* � � �[�[�!9�:� � !� .� .�z� :� ���r c �< � U R 5 UR - $ �N)rO rI �r �events r re � MonitorEventAdapter._get_latency� s � ��%�%�'�%�/�/�9�9r c �: � [ U R 5 S- 5 $ )Ni� )�intr4 �r s r rO �%MonitorEventAdapter._get_current_time� s � ��4�:�:�<�$�&�'�'r r3 N)r) r* r+ r, r5 r r r8 rS r] ro rv r{ rz rt re rO r- r. r r r0 r0 D sG � � �I�I� �H� � �F� �"0� 0� � � :�(r r0 c �& � \ rS rSrS rS rS rSrg)�BaseMonitorEvent� c �( � Xl X l X0l g)aC Base 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 )r rG rH rI s r r �BaseMonitorEvent.__init__� s � � � �"��"�r c �P � U R R SU R < S3$ )N�(�))� __class__r) �__dict__r� s r �__repr__�BaseMonitorEvent.__repr__� s% � ��.�.�)�)�*�!�D�M�M�+<�A�>�>r c �j � [ XR 5 ( a U R UR :H $ g)NF)r r� r� )r �others r �__eq__�BaseMonitorEvent.__eq__� s' � � �e�^�^� ,� ,��=�=�E�N�N�2� 2�r )rH rG rI N)r) r* r+ r, r r� r� r- r. r r r� r� � s � �#�$?�r r� c �8 ^ � \ rS rSr SU 4S jjrS rSrU =r$ )rK � c �Z >� [ TU ] XUS9 X@l XPl Uc / U l X`l g)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 rF N)�superr rf �attemptsrs )r rG rH rI rf r� rs r� s �r r �APICallEvent.__init__� s< �� �H ����I� � � � � � � � � �D�M� 0� r c �z � [ U R U R US9nU R R U5 U$ )z�Instantiates APICallAttemptEvent associated to the APICallEvent :type timestamp: int :param timestamp: Epoch time in milliseconds to associate to the APICallAttemptEvent rF )�APICallAttemptEventrG rH r� �append)r rI rn s r rW �!APICallEvent.new_api_call_attempt� s7 � � ,��L�L�D�N�N�i� � � � � � � �]�+� � r )r� rf rs )NNF)r) r* r+ r, r rW r- � __classcell__�r� s @r rK rK � s �� � �� �+1�Z � r rK c �: ^ � \ rS rSr SU 4S jjrSrU =r$ )r� � c �v >� [ T U ] XUS9 X@l XPl X`l Xpl X�l X�l X�l g)a� Monitor 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) rF N) r� r rf rZ rg rY rh rj rk ) r rG rH rI rf rZ rg rY rh rj rk r� s �r r � APICallAttemptEvent.__init__� sG �� �r ����I� � � � ��� 0� � .� � 0� � (�� ,�r )rg rf rj rY rh rZ rk )NNNNNNN)r) r* r+ r, r r- r� r� s @r r� r� � s& �� � � � � � ���B-� B-r r� c � � \ rS rSrSrSrSrSrSrSSSS .r \ R " S 5 \ R " S 5 S .r / S Qr S rS rS rS rS rS rS rS rS rS rS rS rS rS rS r S r S r S r S r S! r!S" r"S# r#S$ r$S% r%S& r&S'r'g())� CSMSerializeriB � � � i �XAmznRequestId� XAmzRequestId�XAmzId2)zx-amzn-requestidzx-amz-request-idz x-amz-id-2zSAWS4-HMAC-SHA256 Credential=(?P<access_key>\w+)/\d+/(?P<signing_region>[a-z0-9-]+)/zAWS (?P<access_key>\w+):)�v4�s3) rG rH rI r� rf rs rZ rY rg rh rj rk c �2 � U R U5 Xl g)z�Serializes 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_id�r r� s r r �CSMSerializer.__init__d s � � � � � �/� *�r c �n � [ U5 U R :� a [ SU SU R S35 eg )Nz&The value provided for csm_client_id: z exceeds the maximum length of z characters)�len�_MAX_CLIENT_ID_LENGTH� ValueErrorr� s r r� �!CSMSerializer._validate_client_idn sH � � �}� �� :� :� :� �8� �� H)�)-�)C�)C�(D�K�Q�� � ;r c � � U R U5 nU R U5 nX2S' U R H( n[ XS5 nUc M [ U SU- 5 " XRUS9 M* [ [ R " USS95 $ )z�Serializes 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_PROPERTIESrA r �json�dumps)r r� � event_dictr� �attr�values r � serialize�CSMSerializer.serializeu s � � �.�.�u�5� ��)�)�%�0� � '�6���8�8�D��E��.�E�� ���m�d� 2�3��*�� 9� �D�J�J�z�j� I�J�Jr c � � SU R S.$ )N� )�Version�ClientId�r� r� s r r� �"CSMSerializer._get_base_event_dict� s � �� �*�*� � r c � � XS' g )N�Servicer. )r rG r� rR s r �_serialize_service� CSMSerializer._serialize_service� s � � '�9� r c � � XS' g )N�Apir. )r rH r� rR s r �_serialize_operation�"CSMSerializer._serialize_operation� s � � %�5�r c � � XS' g )N� Timestampr. )r rI r� rR s r �_serialize_timestamp�"CSMSerializer._serialize_timestamp� s � �"+�;� r c �X � [ U5 US' U( a U R X!S 5 g g )N� AttemptCount���)r� � _add_fields_from_last_attempt)r r� r� rR s r �_serialize_attempts�!CSMSerializer._serialize_attempts� s* � �%(��]� �>�"� � � .� .�z�B�<� H� r c � � UR ( a@ U R UR 5 nUb X1S' U R UR 5 US' UR b UR US' UR b U R UR US5 UR b U R UR US5 g g )N�Region� UserAgent�FinalHttpStatusCode�ApiCall)rY � _get_region�_get_user_agentrg rj �_serialize_parsed_errorrk �_serialize_wire_exception)r r� � last_attempt�regions r r� �+CSMSerializer._add_fields_from_last_attempt� s� � � � '� '� �%�%�l�&B�&B�C�F��!�'-�8�$�&*�&:�&:� �,�,�'�J�{� #� � (� (� 4�0<�0M�0M�J�,� -� � $� $� 0� � (� (� �)�)�:�y� � � &� &� 2� � *� *� �+�+�Z�� � 3r c �0 � US:X a XS' g US:X a XS' g g )Nr� �Latency�ApiCallAttempt�AttemptLatencyr. )r rf r� r� s r �_serialize_latency� CSMSerializer._serialize_latency� s) � � �� "�$+�y� !� �+� +�+2�'� (� ,r c � � U( a SOSUS' g )Nr� r �MaxRetriesExceededr. )r rs r� rR s r �_serialize_retries_exceeded�)CSMSerializer._serialize_retries_exceeded� s � � 1A�1�a� �'�(r c �4 � [ U5 R US' g )N�Fqdn)r �netloc)r rZ r� rR s r �_serialize_url� CSMSerializer._serialize_url� s � � %�c�]� 1� 1� �6�r c �� � U R U5 US' U R U5 ( a U R U5 US' U R U5 nUb XBS' SU; a US US' g g )Nr� � AccessKeyr� zX-Amz-Security-Token� SessionToken)r� � _is_signed�_get_access_keyr� )r rY r� rR r� s r �_serialize_request_headers�(CSMSerializer._serialize_request_headers� sz � � #'�"6�"6��"G� �;� � �?�?�?� +� +�&*�&:�&:�?�&K�J�{� #��!�!�/�2�� � �#)�x� � !�_� 4�)8�&�*�J�~� &� 5r c � � XS' g )N�HttpStatusCoder. )r rg r� rR s r �_serialize_http_status_code�)CSMSerializer._serialize_http_status_code� s � � (8�#�$r c �d � U R R 5 H u pEXA; d M X X%' M g r� )�"_RESPONSE_HEADERS_TO_EVENT_ENTRIES�items)r rh r� rR �header�entrys r �_serialize_response_headers�)CSMSerializer._serialize_response_headers� s1 � � "� D� D� J� J� L�M�F��)�$4�$<� �!� Mr c � � US:X a SOSnU R US U R 5 X%S- ' U R US U R 5 X%S- ' g )Nr� �Final� �Code� AwsException�Message�AwsExceptionMessage)� _truncate�_MAX_ERROR_CODE_LENGTH�_MAX_MESSAGE_LENGTH)r rj r� r� rR � field_prefixs r r� �%CSMSerializer._serialize_parsed_error� sb � � #-� �"9�w�r� �48�N�N� �� �$�"=�"=�5 � �.�0�1� <@�>�>� �� #�T�%=�%=�< � �"7�7�8r c �� � US:X a SOSnU R UR R U R 5 X%S- ' U R [ U5 U R 5 X%S- ' g )Nr� r r � SdkException�SdkExceptionMessage)r r� r) �_MAX_EXCEPTION_CLASS_LENGTH�strr" )r rk r� r� rR r# s r r� �'CSMSerializer._serialize_wire_exception� si � � #-� �"9�w�r� �48�N�N� � $� $� -� -�t�/O�/O�5 � �.�0�1� <@�>�>� �� ��!9�!9�< � �"7�7�8r c �\ � [ U[ 5 ( a g[ U[ 5 ( a gg )Nr� r� )r rK r� r� s r r� � CSMSerializer._get_event_type� s( � � �e�\� *� *� � �� 2� 3� 3�#� 4r c �l � U R U5 nU R U5 u p4UR S5 $ )N� access_key)�_get_auth_value�_get_auth_match�group)r rY �auth_valr@ � auth_matchs r r � CSMSerializer._get_access_key� s5 � ��'�'��8�� �,�,�X�6� ��� � � �-�-r c � � U R U5 ( d g U R U5 nU R U5 u p4US:w a g UR S5 $ )Nr� �signing_region)r r/ r0 r1 )r rY r2 �signature_versionr3 s r r� �CSMSerializer._get_region� sU � �����/�/���'�'��8��(,�(<�(<�X�(F�%�� �� $��� � � 0�1�1r c �l � U R [ UR SS5 5 U R 5 $ )Nz User-Agentr )r r ri �_MAX_USER_AGENT_LENGTH�r rY s r r� � CSMSerializer._get_user_agent s1 � ��~�~� �?�.�.�|�R�@� A� � '� '� � r c � � SU; $ �N� Authorizationr. r; s r r �CSMSerializer._is_signed s � � �/�1�1r c � � [ US 5 $ r> )r r; s r r/ � CSMSerializer._get_auth_value s � � �o�o� >�?�?r c � � U R R 5 H" u p#UR U5 nU( d M X$4s $ g)N)NN)� _AUTH_REGEXSr �match)r r2 r7 �regexrE s r r0 � CSMSerializer._get_auth_match sA � �(,�(9�(9�(?�(?�(A� $� ��K�K��)�E��u�(�/�/� )B� r c �\ � [ U5 U:� a [ R SUU5 US U $ U$ )Nz6Truncating following value to maximum length of %s: %s)r� r" r# )r �text� max_lengths r r �CSMSerializer._truncate s7 � � �t�9�z� !� �L�L�H��� � � ��$� $�� r r� N)(r) r* r+ r, r� r( r! r: r" r �re�compilerD r� r r� r� r� r� r� r� r� r� r� r r r r r r� r� r� r r� r� r r/ r0 r r- r. r r r� r� B s� � � ��"%� � �� �� �� ,� +� �*�&� �j�j� /� � �j�j�4�5� �L� '�#� +��K�( � (�&�,�I� �*3� H� 2� � 8� =� � �$� .� 2� � 2�@��r r� c �$ � \ rS rSrSrS rS rSrg)�SocketPublisheri" i c �, � Xl X#4U l X@l g)a� Publishes 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 �socket�host�port� serializers r r �SocketPublisher.__init__% s � �" � � � �� �%�r c � � U R R U5 n[ U5 U R :� a+ [ R S[ U5 U R 5 gU R R X R 5 g)z�Publishes 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) rS r� r� �_MAX_MONITOR_EVENT_LENGTHr" r# rQ �sendtorR )r r� �serialized_events r r �SocketPublisher.publish: sn � � �+�+�5�5�e�<�� � � �4�#A�#A� A� �L�L�<��$�%��.�.� � � � � ��� ,�m�m�<r )rR rS rQ N)r) r* r+ r, rZ r r r- r. r r rO rO " s � � (� �&�*=r rO )r� �loggingrL r5 �botocore.compatr r r �botocore.retryhandlerr r� � getLoggerr) r" r r0 r� rK r� r� rO r. r r �<module>rb s� �� � � � � B� B� G� � � �8� $��)� )�X](� ](�@� �89 �#� 9 �xC-�*� C-�L]� ]�@(=� (=r
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка