관리-도구
편집 파일: transport.cpython-37.pyc
B T a�0 � @ s� d dl mZ d dlZd dlZd dlZd dlZd dlmZmZ d dlm Z m Z m Z m Z d dl mZ d dlmZ d dlmZ e�rd dlmZ d d lmZ d d lmZ d d lmZ d d lmZ d d lmZ d dlmZ d dlmZ d dl m Z d dl m Z d dlm Z m Z ee! Z"yd dl#m$Z$ W n" e%k �r@ d dl&m$Z$ Y nX G dd� de'�Z(d dd�Z)G dd� de(�Z*G dd� de(�Z+d d � Z,dS ) � )�print_functionN)�datetime� timedelta)�Dsn�logger�capture_internal_exceptions� json_dumps)�BackgroundWorker)�Envelope)�MYPY)�Any)�Callable)�Dict)�Iterable)�Optional)�Tuple)�Type)�Union)� PoolManager)� ProxyManager)�Event� EndpointType)� getproxiesc @ sH e Zd ZdZdZddd�Zdd� Zdd� Zdd d �Zd d � Z d d� Z dS )� TransportzWBaseclass for all transports. A transport is used to send an event to sentry. Nc C s8 || _ |r.|d d k r.|d r.t|d �| _nd | _d S )N�dsn)�optionsr � parsed_dsn)�selfr � r �E/opt/alt/python37/lib/python3.7/site-packages/sentry_sdk/transport.py�__init__/ s zTransport.__init__c C s t � �dS )zm This gets invoked with the event dictionary when an event should be sent to sentry. N)�NotImplementedError)r �eventr r r � capture_event9 s zTransport.capture_eventc C s t � �dS )a$ Send an envelope to Sentry. Envelopes are a data container format that can hold any type of data submitted to Sentry. We use it for transactions and sessions, but regular "error" events should go through `capture_event` for backwards compat. N)r! )r �enveloper r r �capture_envelopeC s zTransport.capture_envelopec C s dS )z=Wait `timeout` seconds for the current events to be sent out.Nr )r �timeout�callbackr r r �flushQ s zTransport.flushc C s dS )z Forcefully kills the transport.Nr )r r r r �killZ s zTransport.killc C s& y | � � W n tk r Y nX d S )N)r) � Exception)r r r r �__del___ s zTransport.__del__)N)N) �__name__� __module__� __qualname__�__doc__r r r# r% r( r) r+ r r r r r ' s r c c s� |d krt �� }x�| �d�D ]r}yR|�� �dd�\}}}|tt|�d� }x$|rZ|�d�p\dD ]}||fV q^W W q ttfk r� w Y q X q W d S )N�,�:� )�seconds�;)N)r �utcnow�split�stripr �int� LookupError� ValueError)�header�now�limitZ retry_after� categories�_�categoryr r r �_parse_rate_limitsg s rA c @ s� e Zd ZdZdd� Zdd� Zd dd�Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zd!d d �Zd d � ZdS )"� HttpTransportzThe default HTTP transport.c C s� ddl m} t�| |� | jd k s&t�|| _t|d d�| _| j� d| �| _ i | _ t j �� | _| j| j|d |d |d d �| _dd lm} || _d S ) Nr )�VERSIONZtransport_queue_size)Z queue_sizezsentry.python/%s� http_proxy� https_proxy�ca_certs)rD rE rF )�Hub)Zsentry_sdk.constsrC r r r �AssertionErrorr r �_workerZto_auth�_auth�_disabled_until�urllib3�utilZRetry�_retry� _make_pool�_pool� sentry_sdkrG �hub_cls)r r rC rG r r r r y s zHttpTransport.__init__c C sh |j �d�}|r,t�d� | j�t|�� n8|jdkrdt�d� t� � t | j � |�pVdd� | jd < d S )Nzx-sentry-rate-limitsz%Rate-limited via x-sentry-rate-limitsi� zRate-limited via 429�< )r3 ) �headers�getr �warningrK �updaterA �statusr r5 r rN Zget_retry_after)r �responser; r r r �_update_rate_limits� s z!HttpTransport._update_rate_limits�storec C s� |� t| jj�t| j�� �d�� y$| jjdt| j�|��||d�}W n tk rf | � d� � Y nX z\| � |� |j dkr�| � d� n8|j dks�|j dk r�t � d |j |j� | � d �|j �� W d |�� X d S ) N)z User-Agentz X-Sentry-AuthZPOST)�bodyrT Znetworki� Z status_429i, �� z%Unexpected status code: %s (body: %s)z status_{})rW �strrJ ZclientZ to_headerrP ZrequestZ get_api_urlr* �on_dropped_eventrZ rX r �error�data�format�close)r r\ rT � endpoint_typerY r r r � _send_request� s0 zHttpTransport._send_requestc C s d S )Nr )r �reasonr r r r_ � s z HttpTransport.on_dropped_eventc s � fdd�}||�p|d �S )Nc s � j �| �}|d k o |t�� kS )N)rK rU r r5 )�bucket�ts)r r r � _disabled� s z0HttpTransport._check_disabled.<locals>._disabledr )r r@ ri r )r r �_check_disabled� s z HttpTransport._check_disabledc C s� | � d�r| �d� d S t�� }tj|dd��}|�t|�� W d Q R X | jd k sVt �t � d|� d�phd|� d�ptd|� d �p�d| jj | jjf � | j|�� d d d �d � d S )Nr` Zself_rate_limits�w)�fileobj�modez>Sending event, type:%s level:%s event_id:%s project:%s host:%s�type�null�levelZevent_idzapplication/json�gzip)z Content-TypezContent-Encoding)rT )rj r_ �io�BytesIOrq �GzipFile�writer r rH r �debugrU � project_id�hostre �getvalue)r r" r\ �fr r r � _send_event� s$ zHttpTransport._send_eventc s� � fdd�|j D �|j d d �< |j s(d S t�� }tj|dd��}|�|� W d Q R X � jd k sbt�t� d|j � jj � jj � � j |�� ddd�d d � d S ) Nc s g | ]}� � |j�s|�qS r )rj Z data_category)�.0�x)r r r � <listcomp> s z0HttpTransport._send_envelope.<locals>.<listcomp>rk )rl rm z(Sending envelope [%s] project:%s host:%sz application/x-sentry-enveloperq )z Content-TypezContent-Encodingr$ )rT rd )�itemsrr rs rq rt Zserialize_intor rH r rv � descriptionrw rx re ry )r r$ r\ rz r )r r �_send_envelope� s$ z HttpTransport._send_envelopec C s dd|pt �� d�S )Nr2 Z CERT_REQUIRED)Z num_poolsZ cert_reqsrF )�certifi�where)r rF r r r �_get_pool_options s z HttpTransport._get_pool_optionsc C sP t � �d�}|sdS x6|�d�D ](}|�� }|j�|�sD|j�|�r dS q W dS )N�noFr0 T)r rU r6 r7 rx �endswith�netloc)r r �no_proxyrx r r r � _in_no_proxy$ s zHttpTransport._in_no_proxyc C s� d }| � |�}|jdkr6|dkr6|p4| o4t� �d�}|sX|dkrX|pV| oVt� �d�}| �|�}|rttj|f|�S tjf |�S d S )N�https� �http)r� �schemer rU r� rL r r )r r rD rE rF �proxyr� �optsr r r rO / s zHttpTransport._make_poolc s2 �j j�� ��fdd�}�j�|�s.��d� d S )Nc s0 ��" t � � ��� � W d Q R X W d Q R X d S )N)r r{ r )r" �hubr r r �send_event_wrapperO s z7HttpTransport.capture_event.<locals>.send_event_wrapper� full_queue)rR �currentrI �submitr_ )r r" r� r )r" r� r r r# I s zHttpTransport.capture_eventc s2 �j j�� ��fdd�}�j�|�s.��d� d S )Nc s0 ��" t � � ��� � W d Q R X W d Q R X d S )N)r r� r )r$ r� r r r �send_envelope_wrapper^ s z=HttpTransport.capture_envelope.<locals>.send_envelope_wrapperr� )rR r� rI r� r_ )r r$ r� r )r$ r� r r r% X s z HttpTransport.capture_envelopeNc C s$ t �d� |dkr | j�||� d S )NzFlushing HTTP transportr )r rv rI r( )r r& r' r r r r( g s zHttpTransport.flushc C s t �d� | j�� d S )NzKilling HTTP transport)r rv rI r) )r r r r r) q s zHttpTransport.kill)r[ )N)r, r- r. r/ r rZ re r_ rj r{ r� r� r� rO r# r% r( r) r r r r rB v s ' ! rB c @ s e Zd Zdd� Zdd� ZdS )�_FunctionTransportc C s t �| � || _d S )N)r r �_func)r �funcr r r r x s z_FunctionTransport.__init__c C s | � |� d S )N)r� )r r" r r r r# s z _FunctionTransport.capture_eventN)r, r- r. r r# r r r r r� w s r� c C sb | d }|d krt }n8t|t�r$|S t|t�r>t|t�r>|}nt|�rNt|�S | d r^|| �S d S )NZ transportr )rB � isinstancer rn � issubclass�callabler� )r Z ref_transportZ transport_clsr r r �make_transport� s r� )N)-� __future__r rr rL r� rq r r Zsentry_sdk.utilsr r r r Zsentry_sdk.workerr Zsentry_sdk.enveloper Zsentry_sdk._typesr �typingr r r r r r r r Zurllib3.poolmanagerr r r r r^ Z DataCategoryZurllib.requestr � ImportError�urllib�objectr rA rB r� r� r r r r �<module> sB @