e1+ v d dl Z d dlmZ d dlmZmZ d dlmZ d dlmZ d dl m
Z
d dl m Z m
Z
d dlmZ d d lmZmZmZmZmZ d d
lmZ d d lmZ d d lmZ d d
l m Z e r7d dl m Z d dl m Z d dl m!Z! d dl m"Z" d dl m#Z#m$Z$m%Z% e de!de f Z&dZ'dZ(d Z)d Z*d Z+ G d d e Z,d Z-d Z.d Z/d Z0dS )! N)deepcopy)datetime timedelta)environ)continue_trace)OP)Hub_should_send_default_pii) TRANSACTION_SOURCE_COMPONENT)AnnotatedValuecapture_internal_exceptionsevent_from_exceptionlogger
TimeoutThread) Integration)_filter_headers)reraise)
TYPE_CHECKING)Any)TypeVar)Callable)Optional)EventProcessorEventHintF.)boundi g @@c fd}|S )Nc t j }| t }| | i |S |j }t 5 | 5 }| d d d n # 1 swxY w Y t j }|rCt | r4t ||j ddd \ }}|
|| d d d n # 1 swxY w Y | i |S )N
aws_lambdaFtypehandledclient_options mechanismhint)r currentget_integrationAwsLambdaIntegrationclientr
configure_scopeclear_breadcrumbssysexc_infoallr options
capture_event)
argskwargshub integrationr, scoper0 sentry_eventr(
init_errors
t/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/sentry_sdk/integrations/aws_lambda.pysentry_init_errorz+_wrap_init_error..sentry_init_error' s k))*>?? :t.v.. .
(
*
* ; ;$$&&
*%'')))
*
*
*
*
*
*
*
*
*
*
*
*
*
*
* |~~H
;CMM
;%9 #)>'3 F F& & &" d
!!,T!::: ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; z4*6***s7 C, A=1 C,=B C,B AC,,C03C0 )r: r< s ` r; _wrap_init_errorr> % s$ + + + + +4 c fd}|S )Nc
B t | t r| d }t | }n| }d}t |t si }t j }| t }|
| |g|R i |S |j }| } |
5 }
d } t 5 |
|
t ||| |
d|j d d |dk r,|
dd |
d| |j rI| t& k r>| t& z
t( z } t+ | | t( z } | d d d n # 1 swxY w Y | d }
|
i }
t1 |
t2 j |j t8
}| || |d 5 | |g|R i || r| cd d d cd d d S # t> $ rS tA j! }tE ||j# d
dd \ }}|$ || tK | Y nw xY w | r| n # | r| w w xY wd d d n # 1 swxY w Y d d d d S # 1 swxY w Y d S )Nr
aws_region:
batch_requestT
batch_sizeheaders)opnamesource) aws_event aws_context)custom_sampling_contextr Fr! r$ r' )&
isinstancelistlendictr r) r* r+ r, get_remaining_time_in_millis
push_scoper
r. add_event_processor _make_request_event_processorset_taginvoked_function_arnsplittimeout_warningTIMEOUT_WARNING_BUFFERMILLIS_TO_SECONDSr startgetr r FUNCTION_AWS
function_namer start_transactionstop Exceptionr/ r0 r r2 r3 r )rL rM r4 r5 request_datarG r6 r7 r, configured_timer8 timeout_thread waiting_timerH transactionr0 r9 r( handlers r; sentry_handlerz%_wrap_handler..sentry_handlerF s i & & $Q?? 79kCDCCCFCC C %BBDD
^^
A . !N,..
+
+'')))))1$k?
+"B"H"H"M"Ma"P >>MM/4888MM,
;;;
/+'*@@@ (*@@)$*L &3$'*;;& &N #((***=
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+@ #&&y11G (? .3 K &&!*#.) ) '
.
.
."79kKDKKKFKK & .&++---)
.
.
.
.
.
.
.[A . A . A . A . A . A . A . A .l ! ' ' ' "|~~H)= '-~+7E"J"J* * *&L$
%%l%>>>X&&&&' '% .&++--- & .&++----.'
.
.
.
.
.
.
.
.
.
.
.
.
.
.
.[A . A . A . A . A . A . A . A . A . A . A . A . A . A . A . A . A . A .s .L?C/F:. L:F> >LF> A L K<! I -K< L AJ96K8J99K=K<K--K<0 L<L LL LLLr= )ri rj s ` r;
_wrap_handlerrk D s* d. d. d. d. d.L r? c t 5 t j } | t }|| d d d d S # 1 swxY w Y d S N)r
r r) r* r+ flush)r6 r7 s r; _drain_queuero s $ & & k))*>?? "
IIKKK
s =AA A c 0 e Zd ZdZddZed ZdS )r+ r Fc || _ d S rm )rZ )selfrZ s r; __init__z AwsLambdaIntegration.__init__ s . r? c , t } | st j d d S t | d st j d d S t | d }|r;| j fd}|| _ | j fd}|| _ | j fd}|| _ d S t | j j | j _ | j fd}|| _ d } || j j
| j _
|| j j | j _ d S )
NzfNot running in AWS Lambda environment, AwsLambdaIntegration disabled (could not find bootstrap module)handle_event_requestzjNot running in AWS Lambda environment, AwsLambdaIntegration disabled (could not find handle_event_request)handle_http_requestc : t | } | g|R i |S rm rk )request_handlerr4 r5 old_handle_event_requests r; sentry_handle_event_requestzDAwsLambdaIntegration.setup_once..sentry_handle_event_request s1 "/"@"@//Q$QQQ&QQQr? c : t | } | g|R i |S rm rx )ry r4 r5 old_handle_http_requests r; sentry_handle_http_requestzCAwsLambdaIntegration.setup_once..sentry_handle_http_request s1 "/"@"@..PPPPPPPr? c 0 t | i |S rm ro )r4 r5 old_to_jsons r; sentry_to_jsonz7AwsLambdaIntegration.setup_once..sentry_to_json s! "{D3F333r? c < t | } | |g|R i |S rm rx )lambda_runtime_clientry r4 r5 rz s r; r{ zDAwsLambdaIntegration.setup_once..sentry_handle_event_request sF #0"@"@//)?=A EK r? c fd}|S )Nc 0 t | i |S rm r )r4 r5 fs r; innerzKAwsLambdaIntegration.setup_once.._wrap_post_function..inner
s! NNN 1d-f---r? r= )r r s ` r; _wrap_post_functionz._wrap_post_function s# . . . . .
r? ) get_lambda_bootstrapr warninghasattrru rv to_jsonr> LambdaRuntimeClientpost_init_errorpost_invocation_resultpost_invocation_error) lambda_bootstrappre_37r{ r~ r r rz r} r s @@@r;
setup_oncez AwsLambdaIntegration.setup_once s 011 NR
F')?@@ NV
F)+@AA D '7'L $
R
R
R
R
R
5P 1&6&J #
Q
Q
Q
Q
Q
4N 0
+2K
4
4
4
4
4
(6 $ $ $CS 4DD D 0 @ (8'L $
5P 1
$#$8O
0 G $#$8N
0 F F Fr? N)F)__name__
__module__ __qualname__
identifierrs staticmethodr r= r? r; r+ r+ sM J/ / / / X X \X X Xr? r+ c dt j v rt j d S dt j v r\t j d } t | d r!t | j d r | j j S t | d r| j S | S d S )N bootstrap__main__awslambdaricmain)r/ modulesr r r )modules r; r r s ( ck!!{;'' s{ " "Z( 6- . . $7 #[4
4
$ *4 4
V[
)
) $# #
tr? c D t j }|f fd }|S )Nc }
|z
}| di } j j j j ||d|d< t
| j j d|d< | di }d v r d |d< t |d < d
v r d
|d < d v rt d |d < t r| d
i } d }|i }| d } | | d| | d }
|
| d|
d v r dd |d< n, dd rt j |d< t | | d< | S )Nextra)r` function_versionrX aws_request_id execution_duration_in_millisremaining_time_in_millislambda)url log_group
log_streamzcloudwatch logsrequest
httpMethodmethodr queryStringParameters query_stringrH useridentityuserArnidsourceIp
ip_addressbody data)rS
setdefaultr` r rX r _get_cloudwatch_logs_urllog_group_namelog_stream_namer^ _get_urlr r
r removed_because_raw_datar )r9 r(
start_timeremaining_time_in_milis
exec_durationr r user_infor r iprM rL configured_timeouts r; event_processorz6_make_request_event_processor..event_processorH s "-"J"J"L"L *-DD
''44 ( 6 + <$/$D ) 8,9(?
h ,KDD$3%5$
$
""9b11 9 $ $ ), 7GH !)[99 "i / /&/0G&HGN # ! !!091E!F!FGI # % % L$//;;I }}Z00H i((B~$$T2... j))B~$$\2666"""+--";";}}VT**
L #1"I"K"K"*7"3"3 Y r? )r utcnow)rL rM r r r s ``` r; rV rV D sF ""J7A ; ; ; ; ; ; ; ; z r? c & | dd }| d }|i }| dd }| dd }|r|r|rd ||| S d |j S )NpathrH HostzX-Forwarded-Protoz {}://{}{}zawslambda:///{})r^ formatr` )rL rM r rH hostprotos r; r r s == & &DmmI&&G ;;vt $ $D KK+T 2 2E 5 5$ 5!!%t444 # #K$= > >>r? c ^ d}t j dd }d | d rdnd|| j | j |t
d z
| t j t
d
z | }|S ) z
Generates a CloudWatchLogs console URL based on the context object
Arguments:
aws_context {Any} -- context from lambda handler
Returns:
str -- AWS Console URL to logs.
z%Y-%m-%dT%H:%M:%SZ
AWS_REGIONr zhttps://console.{domain}/cloudwatch/home?region={region}#logEventViewer:group={log_group};stream={log_stream};start={start_time};end={end_time}zcn-z amazonaws.cnzaws.amazon.comrB )seconds )domainregionr r r end_time)
r r^ r
startswithr r r strftimer r )rM r formatstringr r s r; r r s (L
[ r
*
*F -
f!'!2!25!9!9O~~?O , . 1!5!5!55?? MM/##i&:&:&::DD\RR
Jr? )1r/ copyr r r osr sentry_sdk.apir sentry_sdk.constsr sentry_sdk.hubr r
sentry_sdk.tracingr sentry_sdk.utilsr r
r r r sentry_sdk.integrationsr $sentry_sdk.integrations._wsgi_commonr sentry_sdk._compatr sentry_sdk._typesr typingr r r r r r r r r[ r\ r> rk ro r+ r rV r r r= r? r; r sp
( ( ( ( ( ( ( ( ) ) ) ) ) ) 8 8 8 8 8 8 8 8 ; ; ; ; ; ; 0 / / / / / @ @ @ @ @ @ & & & & & & + + + + + + / ==========8CH-...A >h h hV ` ` ` ` `; ` ` `F$ $ $NA A AH ? ? ? r?