관리-도구
편집 파일: client.cpython-38.pyc
U �Mgv � @ s� d dl Z d dlZd dlZd dlZd dlmZ d dlmZmZ d dlm Z d dl m Z m Z d dl mZmZ d dlmZmZmZmZmZmZmZmZmZmZmZ d dl m Z d d l m Z d d l m!Z!m"Z" d d l#m$Z$m%Z%m&Z&m'Z'm(Z( d d l)m*Z*m+Z+ d d l,m-Z- d dl.m/Z/ d dl0m1Z1 d dl2m3Z3m4Z4m5Z5 d dl6m7Z7 d dl8m9Z9 d dl:m;Z; d dl m<Z< e<�r&d dl m=Z= d dl m>Z> d dl m?Z? d dl m@Z@ d dl mAZA d dl mBZB d dl mCZC d d l mDZD d d lEmFZFmGZGmHZH d d l)mIZI d d lJmKZK d d lLmMZM d d!lNmOZO d d"l:mPZP d d#l mQZQ eDd$eId%�ZRed&�ZSd'e'd(e'd)�gd*�ZTd+d,� ZUzeVZWW n eXk �rl eYZWY nX G d-d.� d.�ZZG d/d0� d0eZ�Z[G d1d2� d2eZ�Z\d dl m<Z< e<�r�G d3d4� d4e(e?e]e=f �Z^G d5d6� d6e(e\�Z_nd7d8� � Z^d9d8� � Z_dS ):� N)�Mapping)�datetime�timezone)� import_module)�cast�overload)�PY37�check_uwsgi_thread_support) � ContextVar�capture_internal_exceptions�current_stacktrace� env_to_bool�format_timestamp� get_sdk_name� get_type_name�get_default_release� handle_in_app� is_gevent�logger)� serialize)�trace)�BaseHttpTransport�make_transport)�DEFAULT_MAX_VALUE_LENGTH�DEFAULT_OPTIONS� INSTRUMENTER�VERSION�ClientConstructor)�_DEFAULT_INTEGRATIONS�setup_integrations)�SessionFlusher)�Envelope)�setup_continuous_profiler)�has_profiling_enabled�Profile�setup_profiler)� EventScrubber)�Monitor)�setup_spotlight)� TYPE_CHECKING)�Any)�Callable)�Dict)�Optional)�Sequence)�Type)�Union)�TypeVar)�Event�Hint�SDKInfo)� Integration��MetricsAggregator)�Scope)�Session)�SpotlightClient)� Transport�I)�boundZclient_init_debugz sentry.pythonzpypi:sentry-sdk)�name�version)r> r? �packagesc O s | r8t | d ttf�s"| d d kr8| d }| dd � } nd }t| �dkrPtd��tt�}t| |�}|d k r�|�d�d kr�||d< |�� D ]&\}}||kr�td|f ��|||< q�|d d kr�t j �d�|d< |d d kr�t � |d< |d d k�rt j �d �p�d |d< |d d k�r,t t j �d d �dd�|d < |d d k�rRt td��rRt�� |d< |d d k�rjtj|d< |d d k�r�z t �� }W n tk �r� d }Y nX ||d< |d dk�r�|d d k�r�d|d< |d d k�r�t|d d�|d< |d �rt |d t��st�d� d |d< |S ) Nr � z+Only single positional argument is expected�dsnzUnknown option %rZ SENTRY_DSN�release� environmentZSENTRY_ENVIRONMENT� production�debugZ SENTRY_DEBUG�FalseT��strict� server_name� gethostname� instrumenter� project_rootZenable_tracingZtraces_sample_rate� �?�event_scrubber�send_default_pii)rP �socket_optionszxIgnoring socket_options because of unexpected format. See urllib3.HTTPConnection.socket_options for the expected format.)� isinstance�bytes�str�len� TypeError�dictr �get�items�os�environr r �hasattr�socketrK r ZSENTRY�getcwd� Exceptionr& �listr �warning)�args�kwargsrB �rv�options�key�valuerM � rh �?/opt/hc_python/lib/python3.8/site-packages/sentry_sdk/client.py� _get_optionsO sT " �rj c @ s� e Zd ZdZdZd dd�Zdd� Zdd� Zed d � �Z d d � Z d d� Z dd� Z dd� Z erredd� �Zedd� �Zdd� Zdd� Zdd� Zdd � Zd d � ZdS ) � BaseClientzp .. versionadded:: 2.0.0 The basic definition of a client that is used for sending data to Sentry. Nc C s( |d k r |nt | _d | _d | _d | _d S �N)r re � transport�monitor�metrics_aggregator)�selfre rh rh ri �__init__� s �zBaseClient.__init__c O s di iS �Nre rh �rp rb rc rh rh ri � __getstate__� s zBaseClient.__getstate__c O s d S rl rh rs rh rh ri � __setstate__� s zBaseClient.__setstate__c C s d S rl rh �rp rh rh ri rB � s zBaseClient.dsnc C s dS )NFrh rv rh rh ri �should_send_default_pii� s z"BaseClient.should_send_default_piic C s dS )�u .. versionadded:: 2.0.0 Returns whether the client is active (able to send data to Sentry) Frh rv rh rh ri � is_active� s zBaseClient.is_activec O s d S rl rh rs rh rh ri � capture_event� s zBaseClient.capture_eventc O s d S rl rh rs rh rh ri �capture_session� s zBaseClient.capture_sessionc C s d S rl rh �rp � name_or_classrh rh ri �get_integration� s zBaseClient.get_integrationc C s d S rl rh r| rh rh ri r~ � s c C s d S rl rh r| rh rh ri r~ � s c O s d S rl rh rs rh rh ri �close� s zBaseClient.closec O s d S rl rh rs rh rh ri �flush� s zBaseClient.flushc C s | S rl rh rv rh rh ri � __enter__� s zBaseClient.__enter__c C s d S rl rh �rp �exc_type� exc_value�tbrh rh ri �__exit__� s zBaseClient.__exit__)N)�__name__� __module__� __qualname__�__doc__� spotlightrq rt ru �propertyrB rw ry rz r{ r) r r~ r r� r� r� rh rh rh ri rk � s* rk c @ s e Zd ZdZdS )�NonRecordingClientz� .. versionadded:: 2.0.0 A client that does not send any events to Sentry. This is used as a fallback when the Sentry SDK is not yet initialized. N)r� r� r� r� rh rh rh ri r� � s r� c s� e Zd ZdZ� fdd�Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z e dd� �Z dd� Z dd� Zd-dd�Zdd� Zdd � Zd.d d �Zd d � Zer�ed!d"� �Zed#d"� �Zd$d"� Zd/d%d&�Zd0d'd(�Zd)d*� Zd+d,� Z� ZS )1�_ClientaI The client is internally responsible for capturing the events and forwarding them to sentry through the configured transport. It takes the client options as keyword arguments and optionally the DSN as first argument. Alias of :py:class:`sentry_sdk.Client`. (Was created for better intelisense support) c s$ t t| �jt||�d� | �� d S )N�re )�superr� rq � get_options� _init_implrs �� __class__rh ri rq s z_Client.__init__c C s d| j iS rr r� rv rh rh ri rt s z_Client.__getstate__c C s |d | _ | �� d S rr )re r� )rp �staterh rh ri ru s z_Client.__setstate__c C sX |D �]L}d}|d }|� dd�\}}z2t|�}t||�}t||t|�� t�d|� W q tk �r z~|� dd�\}}t|�}t||�} t| |�}t| j | �} t|�} | t t fkr�t | �} t| || � t||| � t�d|� W n2 t k �r } zt� d|| � W 5 d} ~ X Y nX Y q t k �rP } zt� d|| � W 5 d} ~ X Y qX qdS )z� Instruments the functions given in the list `functions_to_trace` with the `@sentry_sdk.tracing.trace` decorator. NZqualified_name�.rA zEnabled tracing for %szWCan not enable tracing for '%s'. (%s) Please check your `functions_to_trace` parameter.)�rsplitr �getattr�setattrr r rF �module_not_found_error�type�__dict__� staticmethod� classmethodr_ ra ) rp �functions_to_trace�function� class_nameZfunction_qualname� module_nameZ function_nameZ module_objZ function_objZ class_objZ function_typeZtraced_function�erh rh ri �_setup_instrumentation sD ��z _Client._setup_instrumentationc s� t �d�}� fdd�}�z\t �� jd � t� j�� _d � _� jrX� jd rXt� j�� _t|d�� _ d � _ � j�di �}|�dd �r�t � p�t }|r�d d l m} ||t|�d d ��d �� _ n t�d� d}� jd |kr�td�|���� jd �dd��r$t�d� tj� jd< dtk�r$t�d� t� jd � jd � jd � jd d�� _� j�d�}|d k�r�d tj k�r�tj d }t |d d �}|d k �r�|n|� jd< � j�d��r�t � j�� _ t t!� j�"� ��} | t#d < t�d | � t$� j��r,zt%� j� W n0 t&k �r( } zt�d | � W 5 d } ~ X Y nX nFzt'� jt#|d!� W n0 t&k �rp } zt�d"| � W 5 d } ~ X Y nX W 5 t �|� X � �(� j�d#g �� � j�s�� j �s�t$� j��s�t)� jt*��r�t+� d S )$NFc s � j d k r� j �| � d S rl )rm �capture_envelope)�enveloperv rh ri �_capture_envelopeE s z-_Client._init_impl.<locals>._capture_enveloperF Z enable_backpressure_handling)� capture_funcZ _experimentsZenable_metricsTr r6 Zmetric_code_locations)r� Zenable_code_locationsz:Metrics not supported on Python 3.6 and lower with gevent.)�always�neverZsmallZmedium�max_request_body_sizez:Invalid value for max_request_body_size. Must be one of {}Zotel_powered_performancezA[OTel] Enabling experimental OTel-powered performance monitoring.rL zJsentry_sdk.integrations.opentelemetry.integration.OpenTelemetryIntegration� integrationsZdefault_integrationsZauto_enabling_integrations�disabled_integrations)Z with_defaultsZ with_auto_enabling_integrationsr� r� ZSENTRY_SPOTLIGHTrH r> zSetting SDK name to '%s'z Can not set up profiler. (%s))�sdk_infor� z(Can not set up continuous profiler. (%s)r� ),�_client_init_debugrX �setre r rm rn r' r �session_flusherro r r �sentry_sdk.metricsr7 �boolr �info� ValueError�formatrF r ZOTELr �appendr r� rZ r[ r r( r� r r` �keys�SDK_INFOr# r% r_ r" r� rR r r ) rp Z old_debugr� Z experimentsZmetrics_supportedr7 r� Zspotlight_configZspotlight_env_valueZsdk_namer� rh rv ri r� A s� �� ���� ����� �� � " ��� �z_Client._init_implc C s dS )rx Trh rv rh rh ri ry � s z_Client.is_activec C s | j �dd�S )z� .. versionadded:: 2.0.0 Returns whether the client should send default PII (Personally Identifiable Information) data to Sentry. rP F)re rX rv rh rh ri rw � s z _Client.should_send_default_piic C s | j d S )z%Returns the configured DSN as string.rB r� rv rh rh ri rB � s z _Client.dsnc C s� |� d�d kr t�tj�|d< |d k r�|� d�dk}t|� dg ��}|�||| j�}|d kr�| jr�| jj d|rrdndd� |r�| jj dd|d d � d S |}|t|� dg �� }|r�|d kr�| jd k r�| jj dd|d � | jd �rFd |k�rFd|k�rFd|k�rFt � �8 dt | j� dd�| j� dt �d�ddd�gi|d< W 5 Q R X dD ]<}|� |�d k�rJ| j| d k �rJt | j| ��� ||< �qJ|� d�d k�r�tt�} t| j�� �| d< | |d< |� d�d k�r�d|d< t|| jd | jd | jd �}|d k �r| jd } | �r| �|� |d k �rTtd ttd!|�| j� d"�| j� d�| j� d#�d$��}| jd% } | d k �r�|d k �r�|� d�dk�r�d } t � � | ||�p�i �} W 5 Q R X | d k�r�t�d&� | j�r�| jj d%dd� | }| jd' } | d k �r�|d k �r�|� d�dk�r�d } t|� dg ��}t � � | ||�p.i �} W 5 Q R X | d k�r�t�d(� | j�r�| jj d%dd)� | jj d%d|d d*� n<|t| � dg �� }|d k�r�| jd k �r�| jj d%d|d*� | }|S )+N� timestampr� � transaction�spansZevent_processor�error�� data_category�spanrA )r� �quantityr Zattach_stacktrace� exception� stacktrace�threads�values�include_local_variablesT�max_value_length)r� r� F)r� �crashed�current)rC rD rJ �distZsdkr� �platform�pythonZin_app_excludeZin_app_includerM rO r2 zDict[str, Any]r� � custom_repr)r� r� r� � before_sendzbefore send dropped event�before_send_transactionz%before send transaction dropped event)�reasonr� )r� r� r� )rX r �nowr �utcrU Zapply_to_eventre rm �record_lost_eventr r r rT �striprW r� �sortedr� r� r Z scrub_eventr r r r� )rp �event�hint�scope�is_transactionZ spans_beforeZevent_Z spans_deltarf r� rO r� Z new_eventr� rh rh ri �_prepare_event� s �� ����� � ����� � �� �� � � �� � �� �z_Client._prepare_eventc C s� |� d�}|d krdS |d }t|d �}d|d j|f }| jd D ]6}t|t�rl||ksd||kr| dS qFt||�rF dS qFdS )N�exc_infoFr z%s.%s� ignore_errorsT)rX r r� re rR rT � issubclass)rp r� r� r� r� Zerror_type_nameZerror_full_nameZ ignored_errorrh rh ri �_is_ignored_errorb s z_Client._is_ignored_errorNc C sF |� d�dk}|rdS |d k o$|j }|r.dS | �||�}|rBdS dS )Nr� r� TF)rX �_should_capturer� )rp r� r� r� r� Zignoring_prevents_recursionZignored_by_config_optionrh rh ri r� x s z_Client._should_capturec C s� | j �dd �}t|�r4t� � |||�}W 5 Q R X n | j d }z|dk oRt�� |k}W nd tk rx t�d� d}Y nD tk r� t|�r�dnd\}}t�d||t |�f � d}Y nX |r�| j r�| j j dd d � dS d S ) N� error_sampler� sample_raterN zMThe provided error_sampler raised an error. Defaulting to sampling the event.F)r� Zreturned)r� �containszsThe provided %s %s an invalid value of %s. The value should be a float or a bool. Defaulting to sampling the event.r� r� T) re rX �callabler �random� NameErrorr ra rV �reprrm r� )rp r� r� r� r� Znot_in_sample_rateZ parameterZverbrh rh ri �_should_sample_error� s8 ��� �� z _Client._should_sample_errorc C s� d}d}d }|� d�pi � d�}|r\d}|D ].}|� d�}t|t�r,|� d�dkr,d} q\q,|� d�} |jd kr�|� d�p|i � d �} t| t�r�| ni } | �� D ] \} } | �� d kr�| } q�q�|j|r�d nd | ||j|p�| d � d S ) NFr� r� T� mechanismZhandled�user�request�headersz user-agentr� )�statusr� � user_agent�errors) rX rR r r� rW rY �lower�updater� )rp �sessionr� r� Zerroredr� � exceptionsr� r� r� r� Z headers_dict�k�vrh rh ri �_update_session_from_event� s2 �z"_Client._update_session_from_eventc C s� t |pd�}| �|||�s dS |�dd�}|�d�}|dkrNt�� j |d< }| �|||�}|dkrhdS |rr|jnd}|r�| � ||� |�d�dk}|�d�dk} |s�| s�| � ||�s�dS |�d�} |�d i ��d �p�i } | �d i �} |d t t � tj��d �} | �r| | d < t| d �}|�rJt|t��r>|�|�|| j�� |�|� n | �r\|�|� n |�|� | �pndD ]}|�|�� � �qpd}| j�r�| j� |� |}| j dk �r�| j � |� |}|S )a Captures an event. :param event: A ready-made event that can be directly sent to Sentry. :param hint: Contains metadata about the event that can be read from `before_send`, such as the original exception object or a HTTP request object. :param scope: An optional :py:class:`sentry_sdk.Scope` to apply to events. :returns: An event ID. May be `None` if there is no DSN set or of if the SDK decided to discard the event for other reasons. In such situations setting `debug=True` on `init()` may help. rh N�profile�event_idr� r� Zcheck_in� attachmentsZcontextsr �dynamic_sampling_context)r� Zsent_at)r� ) rW r� �poprX �uuid�uuid4�hexr� �_sessionr� r� r r r� r r� r! rR r$ Z add_profile�to_jsonre Zadd_transactionZ add_checkinZ add_eventZadd_itemZto_envelope_itemr� r� rm )rp r� r� r� r� r� Z event_optr� r� Z is_checkinr� Z trace_contextr� r� r� � attachmentZ return_valuerh rh ri rz � s` �� � � z_Client.capture_eventc C s" |j st�d� n | j�|� d S )Nz3Discarded session update because of missing release)rC r r� r� Z add_session)rp r� rh rh ri r{ 8 s z_Client.capture_sessionc C s d S rl rh r| rh rh ri r~ C s z_Client.get_integrationc C s d S rl rh r| rh rh ri r~ H s c C s6 t |t�r|}n|jdk r"|j}ntd��| j�|�S )z�Returns the integration for this client by name or class. If the client does not have that integration then `None` is returned. NzIntegration has no name)rR rT � identifierr� r� rX )rp r} Zintegration_namerh rh ri r~ M s c C sZ | j dk rV| j||d� | j�� | jdk r6| j�� | jrF| j�� | j �� d| _ dS )z� Close the client and shut down the transport. Arguments have the same semantics as :py:meth:`Client.flush`. N��timeout�callback)rm r� r� �killro rn �rp r r rh rh ri r ] s z _Client.closec C sN | j dk rJ|dkr | jd }| j�� | jdk r:| j�� | j j||d� dS )a# Wait for the current events to be sent. :param timeout: Wait for at most `timeout` seconds. If no `timeout` is provided, the `shutdown_timeout` option value is used. :param callback: Is invoked with the number of pending events and the configured timeout. NZshutdown_timeoutr )rm re r� r� ro r rh rh ri r� q s z _Client.flushc C s | S rl rh rv rh rh ri r� � s z_Client.__enter__c C s | � � d S rl )r r� rh rh ri r� � s z_Client.__exit__)N)NN)NN)NN) r� r� r� r� rq rt ru r� r� ry rw r� rB r� r� r� r� r� rz r{ r) r r~ r r� r� r� � __classcell__rh rh r� ri r� � sF 3u � 0( � U � � r� c @ s e Zd ZdS )r� N�r� r� r� rh rh rh ri r� � s r� c @ s e Zd ZdS )�ClientNr rh rh rh ri r � s r c C s t S rl )rj rh rh rh ri �<lambda>� � r c C s t S rl )r� rh rh rh ri r � r )`rZ r� r� r] �collections.abcr r r � importlibr �typingr r Zsentry_sdk._compatr r Zsentry_sdk.utilsr r r r r r r r r r r Zsentry_sdk.serializerr Zsentry_sdk.tracingr Zsentry_sdk.transportr r Zsentry_sdk.constsr r r r r Zsentry_sdk.integrationsr r Zsentry_sdk.sessionsr Zsentry_sdk.enveloper! Z'sentry_sdk.profiler.continuous_profilerr" Z(sentry_sdk.profiler.transaction_profilerr# r$ r% Zsentry_sdk.scrubberr& Zsentry_sdk.monitorr' Zsentry_sdk.spotlightr( r) r* r+ r, r- r. r/ r0 r1 Zsentry_sdk._typesr2 r3 r4 r5 r� r7 Zsentry_sdk.scoper8 Zsentry_sdk.sessionr9 r: r; r< r� r� rj �ModuleNotFoundErrorr� r_ � ImportErrorrk r� r� rT r� r rh rh rh ri �<module> s~ 4 �? V