~yL , d dl mZ d dlZd dlmZ d dlmZ d dlmZ d dl m
Z
m Z d dl m
Z
d dlmZ d d lmZ d d
lmZ n# e$ r e
d w xY werd d lmZmZmZ d d
lmZmZm Z g dZ d Z d Z G d dej Z! G d de Z"dS ) )absolute_importN)Hub)SPANDATA)_should_send_default_pii) DidNotEnable Integration)Span)capture_internal_exceptions)
TYPE_CHECKING)
monitoringzPymongo not installed)AnyDictUnion)CommandFailedEventCommandStartedEventCommandSucceededEvent)
insertorderedfindlimit singleBatch aggregate
createIndexesindexesdelete
findAndModifyrenameCollectiontodropc " | D ]}|t v }|r|dk od| v}|r|dk }|r| | D ] }|D ]}d||<
9|dv }|r| | D ]
}d| | |< V|dk } | r(| | D ] }
d|
v r|
d ng D ]
} d|
d | < d| |< | S )Nupdater documentsz%s)filterqueryr! pipelinez$match)SAFE_COMMAND_ATTRIBUTES) commandkey
is_safe_fieldupdate_db_command is_documentdocdoc_key
is_dict_fielditem_keyis_pipeline_fieldr% match_keys q/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/sentry_sdk/integrations/pymongo.py
_strip_piir3 - sE $ $ 66
8O Nw0N
[( s|
(
( " ( (G#'CLL( <<
#CL
.
.)- X&& : - #CL
9
97?87K7K(!3!3QS 9 9I48HX&y119 N c i }d|t j < | j }|||t j < | j d }|||t j < | j d }|||t j < |S )Nmongodbr )r DB_SYSTEM
database_nameDB_NAME
connection_idSERVER_ADDRESS SERVER_PORT)eventdatadb_nameserver_address server_ports r2 _get_db_datarC X st
D (D !G!(X
(+N!(6X
$%%a(K %0X
!" Kr4 c , e Zd Zd Zd Zd Zd Zd ZdS )
CommandTracerc i | _ d S N)_ongoing_operations)selfs r2 __init__zCommandTracer.__init__n s #% r4 c |j S rG )
request_id)rI r> s r2 _operation_keyz CommandTracer._operation_keyr s r4 c t j }| t d S t 5 t t
j |j }| dd | dd | dd d}d|j
t j dt j
|j i} |j d |d< t! |j d |d
< n# t" $ r Y nw xY wd i i}|j |d d < |j |d d
< | t+ | | d d }t! | |d d< n# t, $ r Y nw xY wt/ st1 | }d |j | }| || } | D ]\ }
} | |
| | D ]\ } } | | | t 5 | |d|| d d d n # 1 swxY w Y | | j | ! | < d d d d S # 1 swxY w Y d S )Nz$dbz $clusterTimez
$signaturezdb.queryzdb.namer6 r z
net.peer.namer7 z
net.peer.port
operation_ids operationrequestlsididsessionz{} {})op descriptionr$ )messagecategorytyper? )"r currentget_integrationPyMongoIntegrationr
dictcopydeepcopyr' popr9 r r8 DB_OPERATION command_namer; str TypeError operation_idrL r! rC KeyErrorr r3 format
start_spanitemsset_tagset_dataadd_breadcrumb __enter__rH rM )
rI r> hubr' rU tagsr? rR r$ spantagvaluer( s
r2 startedzCommandTracer.startedv s| k 1 2 2 : F
(
*
* 0 T 0 T4= 7788G KKt $ $ $ KK - - - KK d + + +B 5."I%u'9D
(-(;A(>_%(+E,?,B(C(C_%%
$R(D161CD !+ ./4/?D !) , KK U++ , , ,
{{6**4036t99_%i00
,--
.$W--NN5#5w??E>>RU>;;D "jjll
)
)
U S%(((( "jjll
*
*
U
c5)))),..
X
X""57RV"WWW
X
X
X
X
X
X
X
X
X
X
X
X
X
X
X DH>>CSCSD $T%8%8%?%? @a0 T 0 T 0 T 0 T 0 T 0 T 0 T 0 T 0 T 0 T 0 T 0 T 0 T 0 T 0 T 0 T 0 T 0 Ts BJ< -C76J<7
DJ<DA J<3FJ<
F J<FC J<I5) J<5I9 9J<<I9 =2J<<K K c , t j }| t d S | j | | }| d | d d d d S # t $ r Y d S w xY w)Ninternal_error
r rZ r[ r\ rH r` rM
set_status__exit__rf rI r> rn rp s r2 failedzCommandTracer.failed s k 1 2 2 : F +//0C0CE0J0JKKD OO , - - - MM$d + + + + + FF AB
BBc , t j }| t d S | j | | }| d | d d d d S # t $ r Y d S w xY w)Nokrv ry s r2 succeededzCommandTracer.succeeded s k 1 2 2 : F +//0C0CE0J0JKKD OOD ! ! ! MM$d + + + + + DD r{ N)__name__
__module__ __qualname__rJ rM rs rz r~ r4 r2 rE rE m sc & & & 5T 5T 5Tn r4 rE c ( e Zd ZdZed ZdS )r\ pymongoc F t j t d S rG )r registerrE r r4 r2
setup_oncez PyMongoIntegration.setup_once s MOO,,,,,r4 N)r r r
identifier staticmethodr r r4 r2 r\ r\ s2 J- - \- - -r4 r\ )#
__future__r r^
sentry_sdkr sentry_sdk.constsr sentry_sdk.hubr sentry_sdk.integrationsr r sentry_sdk.tracingr sentry_sdk.utilsr
sentry_sdk._typesr r r ImportErrortypingr
r r pymongo.monitoringr r r r& r3 rC CommandListenerrE r\ r r4 r2 r s & & & & & & & & & & & & 3 3 3 3 3 3 = = = = = = = = # # # # # # 8 8 8 8 8 8 + + + + + +0""""""" 0 0 0
,.
/
//0 '''''''''' "( ( (V *X X X X XJ. X X Xv- - - - - - - - - -s ? A