관리-도구
편집 파일: utils.cpython-37.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)�,�:)� allow_nan� 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+�gitz 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)�release�null�varr! r! r" �get_default_release8 s, r: 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)r< �ty�value�tbr! r! r" �__exit__f s z!CaptureInternalException.__exit__N)�__name__� __module__� __qualname__� __slots__r= rB r! r! r! r" r; _ s r; c C s t S )N)�_CAPTURE_INTERNAL_EXCEPTIONr! r! r! r" �capture_internal_exceptionsq s rH 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)�epoch� total_seconds)r@ r! r! r" � to_timestamp} s rL c C s | � d�S )Nz%Y-%m-%dT%H:%M:%S.%fZ)�strftime)r@ r! r! r" �format_timestamp� s rN c C s2 | dkrt �� } nt| �} | d dkr*d} d| iS )z+Creates a hint with the exc info filled in.Nr rI )�sysrI �exc_info_from_error)rI r! r! r" �event_hint_with_exc_info� s rQ c @ s e Zd ZdZdS )�BadDsnzRaised on invalid DSNs.N)rC rD rE �__doc__r! r! r! r" rR � s rR 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 hostnamerV i� �P zMissing public key�/r zInvalid project in DSN (%r)� )� isinstancerT �dict�__dict__r �urlsplitr �schemerR �hostname�host�port�username� public_key�password� secret_keyr- �rsplit�int�pop� project_id� ValueError� TypeError�join)r< 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.))rU rW )rV i� z%s:%s)r` r^ ra )r< �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.)r^ r` r- ri rc re �client)�Authr^ rp r- ri rc re )r< rq 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�@rY )r^ rc re rp r- ri )r< r! r! r" �__str__� s z Dsn.__str__)N) rC rD rE rS rn �propertyrp rs ru r! r! r! r" rT � s $ rT c @ s: e Zd ZdZddd�Zedd� �Zdd d �Zdd d �ZdS )rr z,Helper object that represents the auth info.N� rX c C s4 || _ || _|| _|| _|| _|| _|| _|| _d S )N)r^ r` r- ri rc re �versionrq ) r< r^ r` ri rc re rx rq r- r! r! r" rn � 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)r< r! r! r" � store_api_url� s zAuth.store_api_urlry c C s d| j | j| j| j|f S )z'Returns the API url for storing events.z%s://%s%sapi/%s/%s/)r^ r` r- ri )r< rz r! r! r" r{ 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>)rc rx �append�strrL rq re rl )r< � timestampro r! r! r" � to_header s zAuth.to_header)Nrw NrX )ry )N) rC rD rE rS rn rv r| r{ r� r! r! r! r" rr � s rr c @ s e Zd ZdZdd� ZdS )�AnnotatedValue)r@ �metadatac C s || _ || _d S )N)r@ r� )r< r@ r� r! r! r" rn s zAnnotatedValue.__init__N)rC rD rE rF rn r! r! r! r" r� s r� )�TypeVar�Tc C s t | dd �pt | dd �S )NrE rC )�getattr)�clsr! r! r" � get_type_name, s r� c C s t | dd �}|dkr|S d S )NrD )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 )NrC 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)rA 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_stringr3 )r} �liner! r! r" � <listcomp>t s z'get_lines_from_file.<locals>.<listcomp>z c S s g | ]}t |�d ���qS )z )r� r3 )r} r� r! r! r" r� x s )�hasattrr� � ImportErrorr6 � splitlines� linecache�getlinesr5 �max�min�lenr� r3 � 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 )NrC � __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>)�reprr4 r r� )r@ ro 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- �basenamerO �modules�__file__rf �sep�lstripr� )r� r� � 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� rC 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� ro 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)rO � _getframer� r� 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 ) Nrz Zgeneric�metar� �numberTr� c s g | ]}t |j|j� d ��qS ))r� r� )r� r� r� )r} rA )r� r! r" r� , s z5single_exception_from_error_tuple.<locals>.<listcomp>)r� rz r@ � mechanismr� � stacktrace)r� � setdefaultr� r� r� r� )�exc_typer� rA �client_optionsr� r� r� ro 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�idr� �addr� � __cause__� __context__rz r� )rI r� r� rA Zseen_exceptionsZseen_exception_ids�causer! r! r" �walk_exception_chainA s$ r� c c s | V d S )Nr! )rI r! r! r" r� b s c C sH | \}}}g }x,t | �D ] \}}}|�t|||||�� qW |�� |S )N)r� r� r� r� )rI r� r� r� r� rA ro 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!) rZ �tupler� � BaseExceptionr� rz rO rI rj )�errorr� r� rA r! r! r" rP � s rP c C s* t | �} t| �}ddt| ||�id�|fS )Nr� r� )�levelr� )rP rQ r� )rI r� r� �hintr! 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� �rem)r@ r� )�MAX_STRING_LENGTHr� r� )r@ � 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! )rg )r} �partr! r! r" r� s z*_is_contextvars_broken.<locals>.<listcomp>r� r� � threading�local)r� rw )� � � contextvars� ContextVarFT)�is_monkey_patchedr� ) �geventZ gevent.monkeyr r� � __version__r� rO � 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)r< r )r r! r" rn < s z:_make_threadlocal_contextvars.<locals>.ContextVar.__init__c S s t | jd|�S )Nr@ )r� r )r< �defaultr! r! r" r+ A s z5_make_threadlocal_contextvars.<locals>.ContextVar.getc S s || j _d S )N)r r@ )r< r@ r! r! r" r� E s z5_make_threadlocal_contextvars.<locals>.ContextVar.setN)rC rD rE rn 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� rw r )r T)r F) r rO 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.%srE rC z%s.%s)Zim_classrD rC 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)rC rD rE rS 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 �Threadrn � waiting_time�configured_timeout�Event� _stop_event)r< r! r" r! r! r" rn � s zTimeoutThread.__init__c C s | j �� d S )N)r$ r� )r< 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_setrg r" r �format)r< Zinteger_configured_timeoutr! r! r" �run� s zTimeoutThread.runN)rC rD rE rS rn r% r) r! r! r! r" r � s r )N)NN)NT)T)NN)NN)NN)NN)N)_r r� �loggingr) rO r r/ r � 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 rJ � getLogger�loggerr ZMAX_FORMAT_PARAM_LENGTHr# r$ r: r r; rG rH r> rL rN rQ rj rR rT rr r� 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� rP r r� r� r r r ZHAS_REAL_CONTEXTVARSr ZCONTEXTVARS_ERROR_MESSAGEr r r r r r! r! r! r" �<module> s� ' I; ( # % ! )&