관리-도구
편집 파일: utils.cpython-37.opt-1.pyc
B T a(k � @ sX d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZ d dlZd dl m Z m Z m Z m Z d dlmZ e�r"d dlmZ d dlmZ d dlmZ d dlmZ d d lmZ d d lmZ d d lmZ d d lmZ d d lmZ d dlmZ d dlm Z d dlm Z d dlm Z d dlm Z m Z eddd�Z!e�"d�Z#dZ$dZ%dd� Z&dd� Z'd d � Z(G d d � d e)�Z*e*� Z+d d!� Z,d"d#� Z-d$d%� Z.d&d'� Z/dvd(d)�Z0G d*d+� d+e1�Z2e G d,d-� d-e)��Z3G d.d/� d/e)�Z4G d0d1� d1e)�Z5e�rd d2lm6Z6 e6d3�Z7e e5e7f Z8d4d5� Z9d6d7� Z:d8d9� Z;d:d;� Z<dwd<d=�Z=d>d?� Z>d@dA� Z?e �rLdBdC� Z@ndDdC� Z@dEdF� ZAdxdHdI�ZBdydJdK�ZCdLdM� ZDdzdNdO�ZEeFeGdP�ZHeH�r�dQdR� ZIndSdR� ZId{dTdU�ZJdVdW� ZKdXdY� ZLdZd[� ZMd|d\d]�ZNd^d_� ZOd`da� ZPd}dbdc�ZQddde� ZRd~dfdg�ZSdhdi� ZTdjdk� ZUdldm� ZVeV� \ZWZXdnZYdodp� ZZeXdq�Z[G drds� dseG�Z\G dtdu� duej]�Z^dS )� N)�datetime)�urlparse� text_type�implements_str�PY2)�MYPY)� FrameType)� TracebackType)�Any)�Callable)�Dict)�ContextManager)�Iterator)�List)�Optional)�Set)�Tuple)�Union)�Type)�ExcInfo� EndpointTypei� � zsentry_sdk.errorsi � c C s t j| ddd��d�S )zCSerialize data into a compact JSON representation encoded as UTF-8.F)�,�:)Z allow_nanZ separatorszutf-8)�json�dumps�encode)�data� r �A/opt/alt/python37/lib/python3.7/site-packages/sentry_sdk/utils.py� json_dumps, s r! c C s d S )Nr r r r r �_get_debug_hub2 s r" c C s� t j�d�} | r| S tt jjd��X}y0tjdddgtj||d�� � d � � � d�} W n t t fk rl Y nX | rv| S W d Q R X x d D ]}t j�|�} | r�| S q�W d S ) z Try to guess a default release.ZSENTRY_RELEASEzw+Zgitz rev-parseZHEAD)�stdout�stderr�stdinr zutf-8N)ZHEROKU_SLUG_COMMITZSOURCE_VERSIONZ!CODEBUILD_RESOLVED_SOURCE_VERSIONZ CIRCLE_SHA1ZGAE_DEPLOYMENT_ID)�os�environ�get�open�path�devnull� subprocess�Popen�PIPE� communicate�strip�decode�OSError�IOError)�releaseZnull�varr r r �get_default_release8 s, r6 c @ s e Zd ZdZdd� Zdd� ZdS )�CaptureInternalExceptionr c C s | S )Nr )�selfr r r � __enter__b s z"CaptureInternalException.__enter__c C s" |d k r |d k r t |||f� dS )NT)�capture_internal_exception)r8 Zty�value�tbr r r �__exit__f s z!CaptureInternalException.__exit__N)�__name__� __module__� __qualname__� __slots__r9 r= r r r r r7 _ s r7 c C s t S )N)�_CAPTURE_INTERNAL_EXCEPTIONr r r r �capture_internal_exceptionsq s rC c C s t � }|d k r|�| � d S )N)r" Z_capture_internal_exception)�exc_infoZhubr r r r: v s r: c C s | t �� S )N)�epochZ total_seconds)r; r r r � to_timestamp} s rF c C s | � d�S )Nz%Y-%m-%dT%H:%M:%S.%fZ)�strftime)r; r r r �format_timestamp� s rH c C s2 | dkrt �� } nt| �} | d dkr*d} d| iS )z+Creates a hint with the exc info filled in.Nr rD )�sysrD �exc_info_from_error)rD r r r �event_hint_with_exc_info� s rK c @ s e Zd ZdZdS )�BadDsnzRaised on invalid DSNs.N)r> r? r@ �__doc__r r r r rL � s rL c @ s6 e Zd ZdZdd� Zedd� �Zd dd�Zd d � ZdS ) �DsnzRepresents a DSN.c C s t |t�rt|j�| _d S t�t|��}|jdkr@td|j ��|j| _|j d krZtd��|j | _ |j d kr�| jdkrzdp|d| _ n|j | _ |j s�td��|j | _ |j| _|j�dd �}ytt|�� ��| _W n2 ttfk r� td |jp�d d d � ��Y nX d�|�d | _d S ) N)�http�httpszUnsupported scheme %rzMissing hostnamerP i� �P zMissing public key�/r zInvalid project in DSN (%r)� )� isinstancerN �dict�__dict__r Zurlsplitr �schemerL Zhostname�host�portZusername� public_keyZpassword� secret_keyr* �rsplit�int�pop� project_id� ValueError� TypeError�join)r8 r; �partsr* r r r �__init__� s. z Dsn.__init__c C s( | j }| j| jfdkr$d|| jf }|S )zThe netloc part of a DSN.))rO rQ )rP i� z%s:%s)rX rW rY )r8 �rvr r r �netloc� s z Dsn.netlocNc C s" t | j| j| j| j| j| j|d�S )z*Returns the auth info object for this dsn.)rW rX r* r_ rZ r[ �client)�AuthrW rf r* r_ rZ r[ )r8 rg r r r �to_auth� s z Dsn.to_authc C s. d| j | j| jrd| j p d| j| j| jf S )Nz%s://%s%s@%s%s%s�@rS )rW rZ r[ rf r* r_ )r8 r r r �__str__� s z Dsn.__str__)N) r> r? r@ rM rd �propertyrf ri rk r r r r rN � s $ rN c @ s: e Zd ZdZddd�Zedd� �Zdd d �Zdd d �ZdS )rh z,Helper object that represents the auth info.N� rR c C s4 || _ || _|| _|| _|| _|| _|| _|| _d S )N)rW rX r* r_ rZ r[ �versionrg ) r8 rW rX r_ rZ r[ rn rg r* r r r rd � s z Auth.__init__c C s | j dd�S )z^Returns the API url for storing events. Deprecated: use get_api_url instead. �store)�type)� get_api_url)r8 r r r � store_api_url� s zAuth.store_api_urlro c C s d| j | j| j| j|f S )z'Returns the API url for storing events.z%s://%s%sapi/%s/%s/)rW rX r* r_ )r8 rp r r r rq s zAuth.get_api_urlc C s~ d| j fd| jfg}|dk r2|�dtt|��f� | jdk rL|�d| jf� | jdk rf|�d| jf� dd�d d � |D �� S ) z!Returns the auth header a string.Z sentry_keyZsentry_versionNZsentry_timestampZ sentry_clientZ sentry_secretzSentry z, c s s | ]\}}d ||f V qdS )z%s=%sNr )�.0�keyr; r r r � <genexpr> s z!Auth.to_header.<locals>.<genexpr>)rZ rn �append�strrF rg r[ rb )r8 Z timestampre r r r � to_header s zAuth.to_header)Nrm NrR )ro )N) r> r? r@ rM rd rl rr rq rx r r r r rh � s rh c @ s e Zd ZdZdd� ZdS )�AnnotatedValue)r; �metadatac C s || _ || _d S )N)r; rz )r8 r; rz r r r rd s zAnnotatedValue.__init__N)r> r? r@ rA rd r r r r ry s ry )�TypeVar�Tc C s t | dd �pt | dd �S )Nr@ r> )�getattr)�clsr r r � get_type_name, s r c C s t | dd �}|dkr|S d S )Nr? )N�builtins� __builtins__)r} )r~ �modr r r �get_type_module1 s r� c C sp y | j d }|�d�rdS W n ttfk r4 Y nX x4dD ],}y| j| rPdS W q< tk rf Y q<X q<W dS )Nr> z sentry_sdk.T)Z__traceback_hide__�__tracebackhide__F)� f_globals� startswith�AttributeError�KeyError�f_locals� Exception)�framer� Z flag_namer r r �should_hide_frame9 s r� c c s, | }x"|d k r&t |j�s |V |j}qW d S )N)r� �tb_frame�tb_next)r< Ztb_r r r � iter_stacksL s r� c C s, d}d }|d k rVt |d�rVy|�|�}W n ttfk rD d }Y nX |d k rV|�� }|d kr�yt�| �}W n ttfk r� g d g fS X |s�g d g fS td|| �}t |d | t |��}yLdd� |||� D �} t || � d��} dd� ||d |� D �} | | | fS t k �r& g d g fS X d S ) N� � get_sourcer r c S s g | ]}t |�d ���qS )z )� strip_stringr0 )rs �liner r r � <listcomp>t s z'get_lines_from_file.<locals>.<listcomp>z c S s g | ]}t |�d ���qS )z )r� r0 )rs r� r r r r� x s )�hasattrr� � ImportErrorr3 � splitlines� linecache�getlinesr2 �max�min�lenr� r0 � IndexError) �filename�lineno�loader�moduleZ context_lines�sourceZ source_strZ lower_boundZ upper_bound� pre_context� context_line� post_contextr r r �get_lines_from_fileU s4 r� c C s� y | j j}W n tk r$ d }Y nX y| jd }W n tk rN g d g fS X y| jd }W n tk rv d }Y nX |d }|d k r�|r�t||||�S g d g fS )Nr> � __loader__r )�f_code� co_filenamer� r� r� )r� � tb_lineno�abs_pathr� r� r� r r r �get_source_context� s r� c C s& yt | �S tk r t| �S X d S )N)r r� � safe_repr)r; r r r �safe_str� s r� c C sT y:t | ��dd�}y|�d��d�S tk r6 |S X W n tk rN dS X d S )Nzutf-8�replace�latin1zunicode-escapez <broken repr>)�reprr1 r r� )r; re r r r r� � s r� c C s" yt | �S tk r dS X d S )Nz <broken repr>)r� r� )r; r r r r� � s c C s� |r| s |S yl|� d�r$|d d� }| �dd�d }|| krHtj�|�S tj| j}|�|�tj d�d d�d � tj �S t k r� |S X d S )Nz.pyc����.r r � ) �endswith�splitr& r* �basenamerI �modules�__file__r\ �sep�lstripr� )r� r� Z base_moduleZbase_module_pathr r r �filename_for_module� s r� Tc C s� t | dd �}|sd }d }n| jj}| jj}y| jd }W n tk rP d }Y nX |d kr`| j}t| |�\}}} t||�p|d |r�t j � |�nd |p�d||||| d�} |r�| j | d< | S )Nr� r> z <unknown>)r� r� �functionr� r� r� r� r� �vars) r} r� r� �co_namer� r� �f_linenor� r� r& r* �abspathr� ) r� r� � with_localsr� r� r� r� r� r� r� re r r r �serialize_frame� s0 r� c C sN d}g }t �� }x,|d k r<t|�s4|�t|| d�� |j}qW |�� d|iS )NT)r� �frames)rI � _getframer� rv r� �f_back�reverse)r� r� r� �fr r r �current_stacktrace� s r� c C s t | dd �S )N�errno)r} )� exc_valuer r r � get_errno s r� c s� |d k rt |�}nd }|d k rF|p(ddi}|�di ��di ��d|� |d krTd� n|d � � fdd �t|�D �}t| �t| �t|�|d �}|r�d |i|d < |S ) Nrp Zgeneric�metar� ZnumberTr� c s g | ]}t |j|j� d ��qS ))r� r� )r� r� r� )rs r< )r� r r r� , s z5single_exception_from_error_tuple.<locals>.<listcomp>)r� rp r; � mechanismr� � stacktrace)r� � setdefaultr� r� r r� )�exc_typer� r< �client_optionsr� r� r� re r )r� r �!single_exception_from_error_tuple s& r� �__suppress_context__c c s� | \}}}g }t � }xz|d k r�|d k r�t|�|kr�|||fV |�|� |�t|�� |jrd|j}n|j}|d krtP t|�}|}t|dd �}qW d S )N� __traceback__) �set�idrv �addr� � __cause__� __context__rp r} )rD r� r� r< Zseen_exceptionsZseen_exception_ids�causer r r �walk_exception_chainA s$ r� c c s | V d S )Nr )rD r r r r� b s c C sH | \}}}g }x,t | �D ] \}}}|�t|||||�� qW |�� |S )N)r� rv r� r� )rD r� r� r� r� r< re r r r �exceptions_from_error_tupleg s r� c C s. yt | �S tk r( t| �dd� S X d S )Nr r� )r �UnicodeDecodeErrorr� )r; r r r � to_string{ s r� c c s� d| kr| d V d| krHx,| d � d�p,dD ]}d|kr.|d V q.W d| kr~x,| d � d�pbdD ]}d|krd|d V qdW d S )Nr� �threads�valuesr � exception)r( )�event�threadr� r r r �iter_event_stacktraces� s r� c c s4 x.t | �D ]"}x |�d�p dD ] }|V q W q W d S )Nr� r )r� r( )r� r� r� r r r �iter_event_frames� s r� c C s* x$t | �D ]}t|�d�||d� q W | S )Nr� )�in_app_exclude�in_app_include)r� �handle_in_app_implr( )r� r� r� r� r r r � handle_in_app� s r� c C s� | sd S d}xd| D ]\}|� d�}|d k r2|rd}q|� d�}|sDqqt||�r\d|d< d}qt||�rd|d< qW |s�x"| D ]}|� d�d kr|d|d< q|W | S )NF�in_appTr� )r( �_module_in_set)r� r� r� Z any_in_appr� r� r� r r r r� � s, r� c C s� t | t�r"t| �dkr"| \}}}ndt | t�rvt| dd �}|d k rNt| �}| }q�t�� \}}}|| k r�d }| }t| �}ntdt| � ��|||fS )N� r� z,Expected Exception object to report, got %s!) rT �tupler� � BaseExceptionr} rp rI rD r` )�errorr� r� r< r r r rJ � s rJ c C s* t | �} t| �}ddt| ||�id�|fS )Nr� r� )�levelr� )rJ rK r� )rD r� r� Zhintr r r �event_from_exception� s r� c C s8 |sdS x*|pdD ] }|| ks,| � |d �rdS qW dS )NFr r� T)r� )�namer� �itemr r r r� � s r� c C sX | s| S |d krt }t| �}||krTt| d |d � d |dd|d |ggd�d�S | S )Nr� z...z!limit�x)r� Zrem)r; rz )�MAX_STRING_LENGTHr� ry )r; Z max_length�lengthr r r r� � s r� c C s� yhddl } ddlm} tdd� | j�d�dd� D ��}|dd �rftjd krT|d ks^|d d �rbdS dS W n tk r| Y nX y ddl m } |d�r�dS W n tk r� Y nX dS )z� Returns whether gevent/eventlet have patched the stdlib in a way where thread locals are now more "correct" than contextvars. r N)�is_object_patchedc S s g | ] }t |��qS r )r] )rs �partr r r r� s z*_is_contextvars_broken.<locals>.<listcomp>r� r� � threading�local)r� rm )� � � contextvars� ContextVarFT)�is_monkey_patchedr� ) �geventZ gevent.monkeyr� r� � __version__r� rI � version_infor� Zeventlet.patcherr )r r� Z version_tupler r r r �_is_contextvars_broken s$ " r c s G � fdd�dt �}|S )Nc s( e Zd Z� fdd�Zdd� Zdd� ZdS )z1_make_threadlocal_contextvars.<locals>.ContextVarc s || _ � � | _d S )N)�_name�_local)r8 r� )r� r r rd < s z:_make_threadlocal_contextvars.<locals>.ContextVar.__init__c S s t | jd|�S )Nr; )r} r )r8 �defaultr r r r( A s z5_make_threadlocal_contextvars.<locals>.ContextVar.getc S s || j _d S )N)r r; )r8 r; r r r r� E s z5_make_threadlocal_contextvars.<locals>.ContextVar.setN)r> r? r@ rd r( r� r )r� r r r� 9 s r� )�object)r� r� r )r� r � _make_threadlocal_contextvars7 s r c C s~ t � sftjdk r<yddlm} d| fS tk r8 Y qfX n*yddlm} d| fS tk rd Y nX ddlm} dt |�fS )z� Figure out the "right" contextvars installation to use. Returns a `contextvars.ContextVar`-like class with a limited API. See https://docs.sentry.io/platforms/python/contextvars/ for more information. )r� rm r )r� T)r� F) r rI r Zaiocontextvarsr� r� r� r� r� r )r� r� r r r �_get_contextvarsL s r z� With asyncio/ASGI applications, the Sentry SDK requires a functional installation of `contextvars` to avoid leaking scope/context data across requests. Please refer to https://docs.sentry.io/platforms/python/contextvars/ for more information. c C sz yd| j j| j j| jf S tk r, Y nX t| dd �pHt| dd �pHd }|sRd S yd| j|f S tk rt Y nX |S )Nz%s.%s.%sr@ r> z%s.%s)Zim_classr? r> r� r} )�funcZ func_qualnamer r r �transaction_from_function~ s r �disable_capture_eventc @ s e Zd ZdZdS )�ServerlessTimeoutWarningz>Raised when a serverless method is about to reach its timeout.N)r> r? r@ rM r r r r r � s r c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) � TimeoutThreadz�Creates a Thread which runs (sleeps) for a time duration equal to waiting_time and raises a custom ServerlessTimeout exception. c C s& t j�| � || _|| _t �� | _d S )N)r� �Threadrd � waiting_time�configured_timeout�Event� _stop_event)r8 r r r r r rd � s zTimeoutThread.__init__c C s | j �� d S )N)r r� )r8 r r r �stop� s zTimeoutThread.stopc C sJ | j �| j� | j �� r d S t| j�}|| jk r8|d }td�|���d S )Nr zZWARNING : Function is expected to get timed out. Configured timeout duration = {} seconds.)r �waitr �is_setr] r r �format)r8 Zinteger_configured_timeoutr r r �run� s zTimeoutThread.runN)r> r? r@ rM rd r r r r r r r � s r )N)NN)NT)T)NN)NN)NN)NN)N)_r r� Zloggingr& rI r� r, r Z sentry_sdkZsentry_sdk._compatr r r r Zsentry_sdk._typesr �typesr r �typingr r r r r r r r r r r r r rE Z getLoggerZloggerr� ZMAX_FORMAT_PARAM_LENGTHr! r" r6 r r7 rB rC r: rF rH rK r` rL rN rh ry r{ r| Z Annotatedr r� r� r� r� r� r� r� r� r� r� r� r� r� r� ZHAS_CHAINED_EXCEPTIONSr� r� r� r� r� r� r� rJ r� r� r� r r r ZHAS_REAL_CONTEXTVARSr� ZCONTEXTVARS_ERROR_MESSAGEr r r r r r r r r �<module> s� ' I; ( # % ! )&