]jd d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZmZ d dlm Z d dl
Z
d dl m Z m
Z
mZ d dlmZ d dlmZ erd dlmZ nd dlmZ er.d dlZd dlmZ d d lmZ d d
lmZ d d lmZ d d lmZ d d
lm Z d dlm Z e j d Z G d de Z G d de! Z" G d de! Z# G d de# Z$d Z%d Z&d Z'ej( d Z)d Z*dS ) N)datetime timedelta)Real)capture_internal_exceptionslogger to_string)PY2)MYPY)Mapping) Generator)Optional)Any)Dict)List)Tuple)SamplingContextz5^[ ]*([0-9a-f]{32})?-?([0-9a-f]{16})?-?([01])?[ ]*$c * e Zd Z ddZd Zd Zd ZdS )EnvironHeadersHTTP_c " || _ || _ d S N)environprefix)selfr r s I/opt/imunify360/venv/lib64/python3.11/site-packages/sentry_sdk/tracing.py__init__zEnvironHeaders.__init__0 s c x | j | j | dd z S N-_)r r replaceupper)r keys r __getitem__zEnvironHeaders.__getitem__9 s0 |DK#++c3*?*?*E*E*G*G GHHr c N t d t | D S )Nc 3 K | ]}d V dS ) N ).0r! s r <genexpr>z)EnvironHeaders.__len__.<locals>.<genexpr>? s" ))1))))))r )sumiterr s r __len__zEnvironHeaders.__len__= s% ))d4jj))))))r c # K | j D ]y}t |t s| dd }| | j s[|t | j d V zd S r )r
isinstancestrr" r#
startswithr len)r ks r __iter__zEnvironHeaders.__iter__A s ( (A a%%
#s##))++A<< ,,
C $$&&' ' ' ' ' ( (r N)r )__name__
__module__ __qualname__r r% r/ r6 r) r r r r / s] I I I* * *
(
(
(
(
(r r c " e Zd ZdZdZd Zd ZdS )
_SpanRecorderz5Limits the number of spans recorded in a transaction.maxlenspansc ( |dz
| _ g | _ d S )Nr( r< r r= s r r z_SpanRecorder.__init__S s qj
r c t | j | j k r d |_ d S | j | d S r )r4 r> r= _span_recorderappend)r spans r addz_SpanRecorder.add] sA tz??T[ ( ("&D J d # # # # #r N)r7 r8 r9 __doc__ __slots__r rE r) r r r; r; N s= ??#I $ $ $ $ $r r; c e Zd ZdZd Z ddZd Zd Zd Zd Z d
Z
d Z e d Z
e d
Zd Ze d Zd Zd Zd Zd Zd Zd ZddZd Zd ZdS )Span)trace_idspan_idparent_span_idsame_process_as_parentsampledop descriptionstart_timestamp_start_timestamp_monotonicstatus timestamp_tags_datarB hub_context_manager_state_containing_transactionc | d|v r t t S t | S )z_
Backwards-compatible implementation of Span and Transaction
creation.
transaction)object__new__ Transaction)clskwargss r r] z Span.__new__| s3 F " ">>+.. .~~c"""r NTc |pt j j | _ |p t j j dd | _ || _ || _ || _ || _ || _ | | _
|| _ i | _ i | _
t j | _ t# j | _ n# t( $ r Y nw xY wd | _ d | _ d | _ d S )N )uuiduuid4hexrJ rK rL rM rN rO rP rS rW rU rV r utcnowrQ time perf_counterrR AttributeErrorrT rB rY ) r rJ rK rL rM rN rO rP rW rS r[ s r r z
Span.__init__ s !4DJLL$4
7$*,,"2233"7 ,&<# &
' 0 0
/3.?.A.AD + + D "'+$$$s B8 8
CCc p | j t | | _ | j | d S r )rB r; rE r@ s r init_span_recorderzSpan.init_span_recorder s8 &"/"7"7D %%%%%r c d| j j d| j d| j d| j d| j d| j d| j dS ) N<z(op=z, description: , trace_id=
, span_id=, parent_span_id=
, sampled=)>) __class__r7 rO rP rJ rK rL rN r. s r __repr__z
Span.__repr__ sZ
N # # # GGG MMM LLL LLL
r c | j pt j j }|j d \ }}|j }| |_ |||f| _ | S )N)rW
sentry_sdkHubcurrent_stackrD rX )r rW r! scopeold_spans r __enter__zSpan.__enter__ sD h0*.0:b>5:
'*E8&<# r c || d | j \ }}}| `| | ||_ d S )Ninternal_error)
set_statusrX finishrD )r tyvaluetbrW r{ r| s r __exit__z
Span.__exit__ sM OO , - - - # : UH ' C
r c | d| j t d| j d| j d|}t | t r| |_ n | j |_ | j x|_ }|r| | |S )a
Start a sub-span from the current span or transaction.
Takes the same arguments as the initializer of :py:class:`Span`. The
trace id, sampling decision, transaction pointer, and span recorder are
inherited from the current span/transaction.
rN N)rJ rK rL r) )
setdefaultrN rI rJ rK r1 r^ rY rB rE )r r` rvrecorders r start_childzSpan.start_child s )T\222
]D
QW
dK ( ( F)-B & &)-)EB &'+'::H LL r c D t j d | j di |S )z$Deprecated: use start_child instead.z:Deprecated: use Span.start_child instead of Span.new_span.r) )r warningr )r r` s r new_spanz
Span.new_span s. STTT t ))&)))r c z | t u rt j d t j t | fi |S )aJ
Create a Transaction with the given params, then add in data pulled from
the 'sentry-trace' header in the environ (if any) before returning the
Transaction.
If the 'sentry-trace' header is malformed or missing, just create and
return a Transaction instance with the given params.
zXDeprecated: use Transaction.continue_from_environ instead of Span.continue_from_environ.)rI r r r^ continue_from_headersr )r_ r r` s r continue_from_environzSpan.continue_from_environ sI $;; N9
0 1H1HSSFSSSr c | t u rt j d t j | d fi |}| t di |}d|_ |S )a3
Create a Transaction with the given params, then add in data pulled from
the 'sentry-trace' header (if any) before returning the Transaction.
If the 'sentry-trace' header is malformed or missing, just create and
return a Transaction instance with the given params.
zXDeprecated: use Transaction.continue_from_headers instead of Span.continue_from_headers. sentry-traceNFr) )rI r r r^ from_traceparentgetrM )r_ headersr` r[ s r r zSpan.continue_from_headers s $;; N9
"2 KK ' '
+1
%////K-2 *r c # : K d| fV d S )Nr )to_traceparentr. s r iter_headerszSpan.iter_headers* s) d 1 1 3 3333333r c | t u rt j d |sdS | d r | d r
|dd }t
t | }|dS | \ }}}|#d t |d }|#d t |d }|r|d
k }nd}t d |||d |S )
a-
Create a Transaction with the given params, then add in data pulled from
the given 'sentry-trace' header value before returning the Transaction.
If the header value is malformed or missing, just create and return a
Transaction instance with the given params.
zNDeprecated: use Transaction.from_traceparent instead of Span.from_traceparent.Nz00-z-00 z{:032x}rb z{:016x}0)rJ rL parent_sampledr) ) rI r r r3 endswith _traceparent_header_format_rematchr2 groupsformatintr^ )r_ traceparentr` r rJ rL sampled_strr s r r zSpan.from_traceparent. s5 $;; N4
4 ! !% ( ( ,[-A-A%-H-H ,%ad+K-33C 4D4DEE =405 -.+ ''Hb(9(9::H % & - -c.".E.E F FN " (C /NN !N
))
r c Z d}| j du rd}| j du rd}| j d| j d|S )N T1Fr r )rN rJ rK )r rN s r r zSpan.to_traceparent_ sF <4 G <5 G !]]]DLLL''BBr c || j |< d S r )rU r r$ r s r set_tagz Span.set_tagh
3r c || j |< d S r )rV r s r set_dataz
Span.set_datal r r c || _ d S r rS )r r s r r zSpan.set_statusp s
r c V | dt | |dk r| d d S d|cxk rdk rn n|dk r| d d S |dk r| d d S |d k r| d
d S |d k r| d d S |d
k r| d d S |dk r| d d S | d d S d|cxk rdk rqn nn|dk r| d d S |dk r| d d S |dk r| d d S | d d S | d d S )Nzhttp.status_codei oki i permission_deniedi not_foundi resource_exhaustedi failed_preconditioni unauthenticatedi already_existsinvalid_argumentiX i deadline_exceededi
unimplementedi unavailabler
unknown_error)r r2 r )r http_statuss r set_http_statuszSpan.set_http_statust s '[)9)9::: OOD ! ! ! ! !
K
%
%
%
%#
%
%
%
%
%c!! 344444 ## ,,,,, ## 455555 ## 566666 ## 122222 ## 011111 233333
K
%
%
%
%#
%
%
%
%
%c!! 344444 ##00000 ##
..... 011111 OOO , , , , ,r c | j dk S )Nr r r. s r
is_successzSpan.is_success s {d""r c 0 | j d S |p| j pt j j } t j | j z
}| j t | z | _ n(# t $ r t j | _ Y nw xY wt || d S )N)seconds)rT rW rw rx ry rg rh rR rQ r ri r rf #_maybe_create_breadcrumbs_from_span)r rW duration_secondss r r z Span.finish s > %47TX7 !7 / # 0 2 2T5T T ! 1IFV4W4W4W WDNN / / / %_ . .DNNN / ,C666ts 8A "BBc | j | j | j | j | j | j | j | j d}| j r| j | j d< | j }|r||d< | j
}|r||d< |S )N)rJ rK rL rM rO rP rQ rT rS tagsdata) rJ rK rL rM rO rP rQ rT rS rU rV )r r r r s r to_jsonz Span.to_json s
| " 1&*&A' + # 3
; /#';DJx z BvJz BvJ r c j | j | j | j | j | j d}| j r
| j |d< |S )N)rJ rK rL rO rP rS )rJ rK rL rO rP rS )r r s r get_trace_contextzSpan.get_trace_context sG
| " 1' +
; ' ;BxL r )
NNNTNNNNNNr )r7 r8 r9 rG r] r rk rt r} r r r classmethodr r r r r r r r r r r r r r) r r rI rI e s I, # # # # ', ', ', ',R& & &
2* * * T T [T* [44 4 4 .
.
[.
`C C C - - -B# # # & 4 r rI c B e Zd ZdZ d dZd Zd
dZ fdZd Z xZ S ) r^ )namer r Nc |s-d|v r)t j d | d }t j | fi | || _ || _ d S )Nr[ z^Deprecated: use Transaction(name=...) to create transactions instead of Span(transaction=...).)r r poprI r r r )r r r r` s r r zTransaction.__init__ so -
// N4
::m,,D
d%%f%%% ,r c d| j j d| j d| j d| j d| j d| j d| j dS ) Nrm z(name=z, op=rn ro rp rq rr )rs r7 r rO rJ rK rL rN r. s r rt zTransaction.__repr__ sW
N # # # III GGG MMM LLL LLL
r c
j d S j t j d d S |p j pt
j j }|j }|d S j st j
d d _ t | j
s j
t j
d d S fd j j D }| d j d i j j j |d S ) Nz.Discarding transaction because sampled = FalsezCTransaction has no name, falling back to `<unlabeled transaction>`.z<unlabeled transaction>z1Discarding transaction without sampling decision.c N g | ]!}|u|j
| "S r )rT r )r* rD r s r
<listcomp>z&Transaction.finish.<locals>.<listcomp> s=
4 DN$>
LLNN$>$>$>r r[ trace)typer[ contextsr rT rQ r> )rT rB r debugrW rw rx ry clientr r rI r rN r>
capture_eventr rU rQ )r rW r finished_spanss ` r r zTransaction.finish sA > %4 & LI J J J47TX7 !7 >4y 2 NU
2DI D# | |# RSSS4
+1
% #y $d&<&<&>&> ?
!^#'#7'
r c t t | }| j |d< | j |d< | j |d< |S )Nr rN r )superr^ r r rN r )r r rs s r r zTransaction.to_json+ sG
;
%
%
-
-
/
/Y6
9
# 2 r c
| j pt j j }|j }|r|j pi }d | j r
d| j z dz nd| j }|rt | s d| _
dS | j
dS t | d r |d | n|d |d n|d
}t | s1t j d | d| _
dS |sVt j d
|t | d rdnd d| _
dS t# j t% | k | _
| j
r*t j d | dS t j d |t% | dS )aP
Sets the transaction's sampling decision, according to the following
precedence rules:
1. If a sampling decision is passed to `start_transaction`
(`start_transaction(name: "my transaction", sampled: True)`), that
decision will be used, regardlesss of anything else
2. If `traces_sampler` is defined, its decision will be used. It can
choose to keep or ignore any parent sampling decision, or use the
sampling context data to make its own decision or to choose a sample
rate for the transaction.
3. If `traces_sampler` is not defined, but there's a parent sampling
decision, the parent sampling decision will be used.
4. If `traces_sampler` is not defined and there's no parent sampling
decision, `traces_sample_rate` will be used.
z{op}transaction <{name}>rm z> r )rO r FNtraces_samplerr traces_sample_ratezN[Tracing] Discarding {transaction_description} because of invalid sample rate.)transaction_descriptionz?[Tracing] Discarding {transaction_description} because {reason}z"traces_sampler returned 0 or Falsez traces_sample_rate is set to 0)r reasonz,[Tracing] Starting {transaction_description}z}[Tracing] Discarding {transaction_description} because it's not included in the random sample (sampling rate = {sample_rate}))r sample_rate)rW rw rx ry r optionsr rO r has_tracing_enabledrN callabler _is_valid_sample_rater r r randomfloat)r sampling_contextrW r r r r s r _set_initial_sampling_decisionz*Transaction._set_initial_sampling_decision5 sl , h0*.0,fn3"<"C"C(,7dg
$$Rty #D #
#
0 9 9 DL F < # F $45566
%G$ %&6 7 7 7
$$45A !!122 12 %[11 N`gg,C h
!DL F LQXX,C $GKK0@$A$ABB><< = Y
!DL F
}{););; < L>EE,C F
L P W W,C %k 2 2 W
r )r Nr )
r7 r8 r9 rG r rt r r r
__classcell__)rs s @r r^ r^ s *I - - - -(
1
1
1
1
f b b b b b b br r^ c p t | d p| d S )zo
Returns True if either traces_sample_rate or traces_sampler is
non-zero/defined, False otherwise.
r r )boolr )r s r r r s1 011RW[[AQ5R5R S SSr c R t | t rt j | r8t j d | t | dS t | } | dk s| dk r*t j d | dS dS ) z
Checks the given sample rate to make sure it is valid type and value (a
boolean or a number between 0 and 1, inclusive).
z}[Tracing] Given sample rate is invalid. Sample rate must be a boolean or a number between 0 and 1. Got {rate} of type {type}.)rater Fr r( zX[Tracing] Given sample rate is invalid. Sample rate must be between 0 and 1. Got {rate}.r T) r1 r mathisnanr r r r r r s r r r s dD ! ! TZ%5%5
L
S
ST
S
u ;;D axx4!88 f m m
n
u 4r c d } t | d rI| | }t |t r | | j j }n# t $ r d }Y nw xY w|pt | S )Nmogrify) hasattrr r1 bytesdecode
connectionencoding Exceptionr )cursorsqlreal_sqls r _format_sqlr s H 69 % % G ~~c**H(E**
G#??6+<+EFF %y~~%s AA A-,A-c # & K | j r:| j j d dd r|r|d gk rd }|dk rd}nd }d }t || }i }|||d< |||d< |rd|d < t 5 | |d
| d d d n # 1 swxY w Y | d |
5 }| D ]\ }} | || |V d d d d S # 1 swxY w Y d S )N _experimentsrecord_sql_paramsFpyformatr z db.paramsz
db.paramstyleTzdb.executemanyquery)messagecategoryr db)rO rP ) r r r r r add_breadcrumb
start_spanitemsr )
rW r r params_list
paramstyle executemanyr rD r5 vs
r record_sql_queriesr s z
cj( 8<<U
kdV 3 3 K # #!J
& &E
D '[ *_ &!%
$ & & G G 57FFFG G G G G G G G G G G G G G G
4U 3 3 tJJLL DAq MM!Q
s$ =B""B&)B&5DD
D
c |j dk r%| |j dd|j d S |j dk r | dd|j d S |j dk r%| dd|j |j d S d S )Nredis)r r r r httphttplib)r r r
subprocess)r r r r )rO r rP rU rV )rW rD s r r r s w' $7W4:
F LLLLL
L !$
! r )+rerc
contextlibr r rg r r numbersr rw sentry_sdk.utilsr r r sentry_sdk._compatr sentry_sdk._typesr
collectionsr collections.abctypingr r
r r r r r compiler r r\ r; rI r^ r r r contextmanagerr r r) r r <module>r s
( ( ( ( ( ( ( (
# " " " " " " " " " " " (#######''''''
2MMM 111111 *
! ! ( ( ( ( (W ( ( (>$ $ $ $ $F $ $ $.m m m m m6 m m m` B B B B B$ B B BJT T T >& & &( ' ' 'T
r