Website : rimsha.abasa.com
backdoor
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
lib
/
python3
/
dist-packages
/
botocore
/
__pycache__
/
Filename :
monitoring.cpython-310.pyc
back
Copy
o .&�ajP � @ s� d dl Z d dlZd dlZd dlZd dlmZmZmZ d dlm Z e� e �Z G dd� de�ZG dd� de�ZG dd � d e�ZG d d � d e�ZG d d � d e�ZG dd� de�ZG dd� de�ZdS )� N)�ensure_unicode� ensure_bytes�urlparse)� EXCEPTION_MAPc @ s, e Zd Zg d�Zdd� Zdd� Zdd� ZdS ) �Monitor)zbefore-parameter-buildzrequest-createdzresponse-receivedz after-callzafter-call-errorc C s || _ || _dS )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� publisher� r �5/usr/lib/python3/dist-packages/botocore/monitoring.py�__init__" s zMonitor.__init__c C s | j D ] }|�|| j� qdS )z(Register an event emitter to the monitorN)�_EVENTS_TO_REGISTER� register_last�capture)r � event_emitter�event_to_registerr r r �register- s �zMonitor.registerc K sd z| j �||�}|r| j�|� W dS W dS ty1 } ztjd||dd� W Y d}~dS d}~ww )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�er r r r 2 s ����zMonitor.captureN)�__name__� __module__� __qualname__r r r r r r r r r s r c @ sr e Zd Zejfdd�Zdd� Zdd� Zdd� Zd d � Zd d � Z d d� Z dd� Z dd� Z dd� Z dd� Zdd� ZdS )�MonitorEventAdapterc C s || _ dS )z�Adapts event emitter events to produce monitor events :type time: callable :param time: A callable that produces the current time N)�_time)r �timer r r r C s z MonitorEventAdapter.__init__c C s | � |�di |��S )a� 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 Nr )� _get_handler)r �emitter_event_name�emitter_payloadr r r r K s zMonitorEventAdapter.feedc C s t | d|�d�d �dd� �S )N�_handle_�.r �-�_)�getattr�split�replace)r r r r r r% [ s �z MonitorEventAdapter._get_handlerc K s t |jj|j| �� d�|d< d S )N��service� operation� timestamp�current_api_call_event)� APICallEvent� service_model� service_id� wire_name�_get_current_time)r �model�context�kwargsr r r � _handle_before_parameter_build` s �z2MonitorEventAdapter._handle_before_parameter_buildc K s6 |j }|d j| �� d�}|j|_|j|_||d< d S )Nr3 )r2 � current_api_call_attempt_event)r: �new_api_call_attemptr8 �headers�request_headers�url)r �requestr; r: �new_attempt_eventr r r �_handle_request_createdg s �� z+MonitorEventAdapter._handle_request_createdc K sT |� d�}| �|�|_|d ur%|d d |_|d d |_|�d�|_|S ||_|S )Nr= �ResponseMetadata�HTTPStatusCode� HTTPHeaders�Error)�pop� _get_latency�latency�http_status_code�response_headers�get� parsed_error�wire_exception)r �parsed_responser: � exceptionr; � attempt_eventr r r �_handle_response_receivedp s" ���� �z-MonitorEventAdapter._handle_response_receivedc K s |d � dd�|d _| �|�S )NrE �MaxAttemptsReachedFr3 )rN �retries_exceeded�_complete_api_call)r r: �parsedr; r r r �_handle_after_call~ s �� z&MonitorEventAdapter._handle_after_callc K s | � |�|d _| �|�S �Nr3 )�_is_retryable_exceptionrV rW )r r: rR r; r r r �_handle_after_call_error� s � z,MonitorEventAdapter._handle_after_call_errorc C s t |ttd ��S )N�GENERAL_CONNECTION_ERROR)� isinstance�tuple�RETRYABLE_EXCEPTIONS)r rR r r r r[ � s �z+MonitorEventAdapter._is_retryable_exceptionc C s |� d�}| �|�|_|S rZ )rI rJ rK )r r: � call_eventr r r rW � s z&MonitorEventAdapter._complete_api_callc C s | � � |j S �N)r8 r2 �r �eventr r r rJ � s z MonitorEventAdapter._get_latencyc C s t | �� d �S )Ni� )�intr# �r r r r r8 � s z%MonitorEventAdapter._get_current_timeN)r r r! r$ r r r% r< rD rT rY r\ r[ rW rJ r8 r r r r r" B s r" c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�BaseMonitorEventc C s || _ || _|| _dS )a� 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 Nr/ )r r0 r1 r2 r r r r � s zBaseMonitorEvent.__init__c C s d| j j| jf S )Nz%s(%r))� __class__r �__dict__rf r r r �__repr__� � zBaseMonitorEvent.__repr__c C s t || j�r | j|jkS dS )NF)r^ rh ri )r �otherr r r �__eq__� s zBaseMonitorEvent.__eq__N)r r r! r rj rm r r r r rg � s rg c s* e Zd Z d� fdd� Zdd� Z� ZS )r4 NFc s: t t| �j|||d� || _|| _|du rg | _|| _dS )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)�superr4 r rK �attemptsrV )r r0 r1 r2 rK ro rV �rh r r r � s � zAPICallEvent.__init__c C s" t | j| j|d�}| j�|� |S )z�Instantiates APICallAttemptEvent associated to the APICallEvent :type timestamp: int :param timestamp: Epoch time in milliseconds to associate to the APICallAttemptEvent r/ )�APICallAttemptEventr0 r1 ro �append)r r2 rS r r r r> � s � z!APICallEvent.new_api_call_attempt)NNF)r r r! r r> � __classcell__r r rp r r4 � s �%r4 c s$ e Zd Z d� fdd� Z� ZS )rq Nc sD t t| �j|||d� || _|| _|| _|| _|| _| | _| | _ dS )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) r/ N) rn rq r rK rA rL r@ rM rO rP ) r r0 r1 r2 rK rA rL r@ rM rO rP rp r r r � s 0� z APICallAttemptEvent.__init__)NNNNNNN)r r r! r rs r r rp r rq � s �rq c @ s e Zd ZdZdZdZdZdZdddd�Ze � d �e � d �d �Z g d �Z d d� Z dd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Z d-d.� Z d/d0� Z d1d2� Z d3d4� Z d5d6� Z!d7d8� Z"d9d:� Z#d;d<� Z$d=d>� Z%d?S )@� CSMSerializer� � � 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) r0 r1 r2 ro rK rV rA r@ rL rM rO rP c C s | � |� || _dS )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~ r r r r O s zCSMSerializer.__init__c C s$ t |�| jkrtd|| jf ��d S )NzTThe value provided for csm_client_id: %s exceeds the maximum length of %s characters)�len�_MAX_CLIENT_ID_LENGTH� ValueErrorr r r r r} Y s ����z!CSMSerializer._validate_client_idc C sf | � |�}| �|�}||d< | jD ]}t||d�}|dur)t| d| �|||d� qttj|dd��S )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_PROPERTIESr, r �json�dumps)r rd � event_dictr� �attr�valuer r r � serializea s �� �zCSMSerializer.serializec C s d| j d�S )N� )�Version�ClientId)r~ rc r r r r� u s �z"CSMSerializer._get_base_event_dictc K � ||d< d S )N�Servicer )r r0 r� r; r r r �_serialize_service{ � z CSMSerializer._serialize_servicec K r� )N�Apir )r r1 r� r; r r r �_serialize_operation~ r� z"CSMSerializer._serialize_operationc K r� )N� Timestampr )r r2 r� r; r r r �_serialize_timestamp� r� z"CSMSerializer._serialize_timestampc K s( t |�|d< |r| �||d � d S d S )N� AttemptCount���)r� � _add_fields_from_last_attempt)r ro r� r; r r r �_serialize_attempts� s �z!CSMSerializer._serialize_attemptsc C s� |j r| �|j �}|d ur||d< | �|j �|d< |jd ur#|j|d< |jd ur0| �|j|d� |jd ur?| �|j|d� d S d S )N�Region� UserAgent�FinalHttpStatusCode�ApiCall)r@ � _get_region�_get_user_agentrL rO �_serialize_parsed_errorrP �_serialize_wire_exception)r r� � last_attempt�regionr r r r� � s$ � � ��z+CSMSerializer._add_fields_from_last_attemptc C s, |dkr ||d< d S |dkr||d< d S d S )Nr� �Latency�ApiCallAttempt�AttemptLatencyr )r rK r� r� r r r �_serialize_latency� s �z CSMSerializer._serialize_latencyc K s |rdnd|d< d S )Nr� r �MaxRetriesExceededr )r rV r� r; r r r �_serialize_retries_exceeded� s z)CSMSerializer._serialize_retries_exceededc K s t |�j|d< d S )N�Fqdn)r �netloc)r rA r� r; r r r �_serialize_url� rk z CSMSerializer._serialize_urlc K s\ | � |�|d< | �|�r| �|�|d< | �|�}|d ur ||d< d|v r,|d |d< d S d S )Nr� � AccessKeyr� zX-Amz-Security-Token� SessionToken)r� � _is_signed�_get_access_keyr� )r r@ r� r; r� r r r �_serialize_request_headers� s ��z(CSMSerializer._serialize_request_headersc K r� )N�HttpStatusCoder )r rL r� r; r r r �_serialize_http_status_code� s z)CSMSerializer._serialize_http_status_codec K s, | j �� D ]\}}||v r|| ||< qd S rb )�"_RESPONSE_HEADERS_TO_EVENT_ENTRIES�items)r rM r� r; �header�entryr r r �_serialize_response_headers� s ��z)CSMSerializer._serialize_response_headersc K sH |dkrdnd}| � |d | j�||d < | � |d | j�||d < d S )Nr� �Final� �Code� AwsException�Message�AwsExceptionMessage)� _truncate�_MAX_ERROR_CODE_LENGTH�_MAX_MESSAGE_LENGTH)r rO r� r� r; � field_prefixr r r r� � s � �z%CSMSerializer._serialize_parsed_errorc K sH |dkrdnd}| � |jj| j�||d < | � t|�| j�||d < d S )Nr� r� r� � SdkException�SdkExceptionMessage)r� rh r �_MAX_EXCEPTION_CLASS_LENGTH�strr� )r rP r� r� r; r� r r r r� � s � �z'CSMSerializer._serialize_wire_exceptionc C s t |t�rdS t |t�rdS d S )Nr� r� )r^ r4 rq rc r r r r� � s �z CSMSerializer._get_event_typec C s" | � |�}| �|�\}}|�d�S )N� access_key)�_get_auth_value�_get_auth_match�group)r r@ �auth_valr+ � auth_matchr r r r� � s z CSMSerializer._get_access_keyc C s< | � |�sd S | �|�}| �|�\}}|dkrd S |�d�S )Nr{ �signing_region)r� r� r� r� )r r@ r� �signature_versionr� r r r r� � s zCSMSerializer._get_regionc C s | � t|�dd��| j�S )Nz User-Agentr� )r� r rN �_MAX_USER_AGENT_LENGTH�r r@ r r r r� � s �z CSMSerializer._get_user_agentc C s d|v S �N� Authorizationr r� r r r r� � s zCSMSerializer._is_signedc C s t |d �S r� )r r� r r r r� � r� z CSMSerializer._get_auth_valuec C s2 | j �� D ]\}}|�|�}|r||f S qdS )N)NN)� _AUTH_REGEXSr� �match)r r� r� �regexr� r r r r� � s �z CSMSerializer._get_auth_matchc C s* t |�|krt�d||� |d |� S |S )Nz6Truncating following value to maximum length of %s: %s)r� r r )r �text� max_lengthr r r r� � s � zCSMSerializer._truncateN)&r r r! r� r� r� r� r� r� �re�compiler� r� r r} r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r rt + sV ���� rt c @ s e Zd ZdZdd� Zdd� ZdS )�SocketPublisheri c C s || _ ||f| _|| _dS )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� serializerr r r r s zSocketPublisher.__init__c C sF | j �|�}t|�| jkrt�dt|�| j� dS | j�|| j� dS )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) r� r� r� �_MAX_MONITOR_EVENT_LENGTHr r r� �sendtor� )r rd �serialized_eventr r r r s �zSocketPublisher.publishN)r r r! r� r r r r r r r� � s r� )r� �loggingr� r$ �botocore.compatr r r �botocore.retryhandlerr r` � getLoggerr r �objectr r" rg r4 rq rt r� r r r r �<module> s )Z 6= U