Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/botocore/__pycache__/monitoring.cpython-39.pyc
Ðазад
a p�hjP � @ 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�adapterZ publisher� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-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_REGISTERZ register_last�capture)r Z event_emitterZevent_to_registerr r r �register- s zMonitor.registerc K s^ z"| j �||�}|r | j�|� W n6 tyX } z tjd||dd� W Y d}~n d}~0 0 dS )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�payloadZ 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 | � |�f i |��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 )� _get_handler)r Zemitter_event_nameZemitter_payloadr r r r K s zMonitorEventAdapter.feedc C s t | d|�d�d �dd� �S )NZ_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)� APICallEventZ service_modelZ service_idZ 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 )Nr+ )r* � current_api_call_attempt_event)r/ �new_api_call_attemptr- �headers�request_headers�url)r �requestr0 r/ Znew_attempt_eventr r r �_handle_request_createdg s ��z+MonitorEventAdapter._handle_request_createdc K sR |� d�}| �|�|_|d urH|d d |_|d d |_|�d�|_n||_|S )Nr2 �ResponseMetadataZHTTPStatusCodeZ HTTPHeaders�Error)�pop� _get_latency�latency�http_status_code�response_headers�get� parsed_error�wire_exception)r Zparsed_responser/ � exceptionr0 � attempt_eventr r r �_handle_response_receivedp s ����z-MonitorEventAdapter._handle_response_receivedc K s |d � dd�|d _| �|�S )Nr9 ZMaxAttemptsReachedFr+ )r@ �retries_exceeded�_complete_api_call)r r/ �parsedr0 r r r �_handle_after_call~ s �� z&MonitorEventAdapter._handle_after_callc K s | � |�|d _| �|�S �Nr+ )�_is_retryable_exceptionrF rG )r r/ rC r0 r r r �_handle_after_call_error� s �z,MonitorEventAdapter._handle_after_call_errorc C s t |ttd ��S )NZGENERAL_CONNECTION_ERROR)� isinstance�tuple�RETRYABLE_EXCEPTIONS)r rC r r r rK � s �z+MonitorEventAdapter._is_retryable_exceptionc C s |� d�}| �|�|_|S rJ )r; r< r= )r r/ Z call_eventr r r rG � s z&MonitorEventAdapter._complete_api_callc C s | � � |j S �N)r- r* �r �eventr r r r< � s z MonitorEventAdapter._get_latencyc C s t | �� d �S )Ni� )�intr �r r r r r- � s z%MonitorEventAdapter._get_current_timeN)r r r r r r r r1 r8 rE rI rL rK rG r< r- 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 r( r) r* r r r r � s zBaseMonitorEvent.__init__c C s d| j j| jf S )Nz%s(%r))� __class__r �__dict__rT r r r �__repr__� s zBaseMonitorEvent.__repr__c C s t || j�r| j|jkS dS )NF)rM rV rW )r �otherr r r �__eq__� s zBaseMonitorEvent.__eq__N)r r r r rX rZ r r r r rU � s rU c s& e Zd Zd� fdd� Zdd� Z� ZS )r, NFc s: t t| �j|||d� || _|| _|du r0g | _|| _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)�superr, r r= �attemptsrF )r r( r) r* r= r\ rF �rV 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' )�APICallAttemptEventr( r) r\ �append)r r* rD r r r r3 � s � z!APICallEvent.new_api_call_attempt)NNF)r r r r r3 � __classcell__r r r] r r, � s �%r, c s e Zd Zd� fdd� Z� ZS )r^ 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) r[ r^ r r= r6 r> r5 r? rA rB ) r r( r) r* r= r6 r> r5 r? rA rB r] r r r � s 0 �z APICallAttemptEvent.__init__)NNNNNNN)r r r r r` r r r] r r^ � s �r^ 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 ZXAmznRequestIdZ XAmzRequestIdZXAmzId2)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+):)�v4Zs3) r( r) r* r\ r= rF r6 r5 r> r? rA rB 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 rg r r r r O s zCSMSerializer.__init__c C s$ t |�| jkr td|| jf ��d S )NzTThe value provided for csm_client_id: %s exceeds the maximum length of %s characters)�len�_MAX_CLIENT_ID_LENGTH� ValueErrorrh r r r rf Y s ���z!CSMSerializer._validate_client_idc C sf | � |�}| �|�}||d< | jD ]0}t||d�}|dur"t| d| �|||d� q"ttj|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 �TypeNZ _serialize_)� event_type)�,�:)� separators)�_get_base_event_dict�_get_event_type� _SERIALIZEABLE_EVENT_PROPERTIESr$ r �json�dumps)r rR � event_dictrm �attr�valuer r r � serializea s � �zCSMSerializer.serializec C s d| j d�S )N� )�VersionZClientId)rg rQ r r r rq u s �z"CSMSerializer._get_base_event_dictc K s ||d< d S )NZServicer )r r( rv r0 r r r �_serialize_service{ s z CSMSerializer._serialize_servicec K s ||d< d S )NZApir )r r) rv r0 r r r �_serialize_operation~ s z"CSMSerializer._serialize_operationc K s ||d< d S )N� Timestampr )r r* rv r0 r r r �_serialize_timestamp� s z"CSMSerializer._serialize_timestampc K s$ t |�|d< |r | �||d � d S )NZ AttemptCount���)ri � _add_fields_from_last_attempt)r r\ rv r0 r r r �_serialize_attempts� s z!CSMSerializer._serialize_attemptsc C s~ |j r2| �|j �}|d ur"||d< | �|j �|d< |jd urF|j|d< |jd ur`| �|j|d� |jd urz| �|j|d� d S )N�Region� UserAgentZFinalHttpStatusCode�ApiCall)r5 � _get_region�_get_user_agentr> rA �_serialize_parsed_errorrB �_serialize_wire_exception)r rv Z last_attempt�regionr r r r� � s" � � �z+CSMSerializer._add_fields_from_last_attemptc C s& |dkr||d< n|dkr"||d< d S )Nr� ZLatency�ApiCallAttemptZAttemptLatencyr )r r= rv rm r r r �_serialize_latency� s z CSMSerializer._serialize_latencyc K s |rdnd|d< d S )Nrz r ZMaxRetriesExceededr )r rF rv r0 r r r �_serialize_retries_exceeded� s z)CSMSerializer._serialize_retries_exceededc K s t |�j|d< d S )NZFqdn)r �netloc)r r6 rv r0 r r r �_serialize_url� s z CSMSerializer._serialize_urlc K sX | � |�|d< | �|�r&| �|�|d< | �|�}|d ur@||d< d|v rT|d |d< d S )Nr� Z AccessKeyr� zX-Amz-Security-TokenZ SessionToken)r� � _is_signed�_get_access_keyr� )r r5 rv r0 r� r r r �_serialize_request_headers� s �z(CSMSerializer._serialize_request_headersc K s ||d< d S )NZHttpStatusCoder )r r> rv r0 r r r �_serialize_http_status_code� s z)CSMSerializer._serialize_http_status_codec K s, | j �� D ] \}}||v r || ||< q d S rP )�"_RESPONSE_HEADERS_TO_EVENT_ENTRIES�items)r r? rv r0 �header�entryr r r �_serialize_response_headers� s z)CSMSerializer._serialize_response_headersc K sH |dkr dnd}| � |d | j�||d < | � |d | j�||d < d S )Nr� �Final� ZCodeZ AwsException�MessageZAwsExceptionMessage)� _truncate�_MAX_ERROR_CODE_LENGTH�_MAX_MESSAGE_LENGTH)r rA rv rm r0 � field_prefixr r r r� � s � �z%CSMSerializer._serialize_parsed_errorc K sH |dkr dnd}| � |jj| j�||d < | � t|�| j�||d < d S )Nr� r� r� Z SdkExceptionZSdkExceptionMessage)r� rV r �_MAX_EXCEPTION_CLASS_LENGTH�strr� )r rB rv rm r0 r� r r r r� � s � �z'CSMSerializer._serialize_wire_exceptionc C s t |t�rdS t |t�r dS d S )Nr� r� )rM r, r^ rQ r r r rr � s z CSMSerializer._get_event_typec C s" | � |�}| �|�\}}|�d�S )NZ access_key)�_get_auth_value�_get_auth_match�group)r r5 �auth_valr# � auth_matchr r r r� � s z CSMSerializer._get_access_keyc C s< | � |�sd S | �|�}| �|�\}}|dkr2d S |�d�S )Nre Zsigning_region)r� r� r� r� )r r5 r� �signature_versionr� r r r r� � s zCSMSerializer._get_regionc C s | � t|�dd��| j�S )Nz User-Agentr� )r� r r@ �_MAX_USER_AGENT_LENGTH�r r5 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� � s z CSMSerializer._get_auth_valuec C s2 | j �� D ]"\}}|�|�}|r ||f S q dS )N)NN)� _AUTH_REGEXSr� �match)r r� r� �regexr� r r r r� � s z CSMSerializer._get_auth_matchc C s* t |�|kr&t�d||� |d |� S |S )Nz6Truncating following value to maximum length of %s: %s)ri r r )r �text� max_lengthr r r r� � s � zCSMSerializer._truncateN)&r r r rj r� r� r� r� r� �re�compiler� rs r rf ry rq r| r} r r� r� r� r� r� r� r� r� r� r� rr r� r� r� r� r� r� r� r r r r ra + sT ���� ra 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|�| jkr2t�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� ry ri �_MAX_MONITOR_EVENT_LENGTHr r r� �sendtor� )r rR Zserialized_eventr r r r s �zSocketPublisher.publishN)r r r r� r r r r r r r� � s r� )rt �loggingr� r Zbotocore.compatr r r Zbotocore.retryhandlerr rO � getLoggerr r �objectr r rU r, r^ ra r� r r r r �<module> s )Z 6= U
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка