Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
Repository URL to install this package:
|
Version:
0.1.2 ▾
|
odigos
/
etc
/
odigos-vmagent
/
instrumentations
/
python
/
opentelemetry
/
instrumentation
/
__pycache__
/
utils.cpython-311.pyc
|
|---|
§
×gð ã óÐ d dl Zd dlmZ d dlmZmZ d dlmZm Z m
Z
d dl m Z d dl
mZmZ d dlmZmZ d dlmZ d d lmZ d d
lmZ e¦ « Z d"d ed e
e d
eeef deeef fdZ d#de de de defdZ defdZ d"dZ!defdZ"de#fdZ$d Z%de fd Z&de fd Z'ed ede d fd ¦ « Z(ede d fd ¦ « Z)ede d fd!¦ « Z*dS )$é N)Úcontextmanager)ÚescapeÚsub)ÚDictÚIterableÚSequence)Ú ObjectProxy)ÚcontextÚtrace)Ú"_SUPPRESS_HTTP_INSTRUMENTATION_KEYÚ _SUPPRESS_INSTRUMENTATION_KEY)Úextract)Ú
StatusCode)Ú TraceContextTextMapPropagatorÚobjÚ
attributesÚexistingÚreturnc ó i }|r| |¦ « |D ]'}t | |d ¦ « }|t |¦ « ||< (|S ©N)ÚupdateÚgetattrÚstr)r r r Ú extractedÚattrÚvalues úJ/tmp/pip-target-6culloxw/lib/python/opentelemetry/instrumentation/utils.pyÚ extract_attributes_from_objectr ) sa ð IØð #Ø×ÒÑ"Ô"Ð"Øð )ð )ÝT 4Ñ(Ô(Ø Ð Ý ! %jjIdOøØ Ðó TFÚstatusÚallow_redirectÚ server_spanc óô t | t ¦ « s t j S | dk r t j S | dk r t j S | dk r|r t j S | dk r|r t j S t j S )z}Converts an HTTP status code to an OpenTelemetry canonical status code
Args:
status (int): HTTP status code
éd i+ i ió )Ú
isinstanceÚintr ÚUNSETÚERROR)r r! r" s r Úhttp_status_to_status_coder) 6 sx õ fcÑ "Ô "ð ÝÔ Ð à
||ÝÔ Ð Ø
}}ÝÔ Ð Ø
}} }ÝÔ Ð Ø
}}}ÝÔ Ð Ý Ô Ðr r c ó® t | |d¦ « }|r=t |t ¦ « r*t |d¦ « r t | ||j ¦ « dS dS dS dS )zÏGiven a function that was wrapped by wrapt.wrap_function_wrapper, unwrap it
Args:
obj: Object that holds a reference to the wrapped function
attr (str): Name of the wrapped function
NÚ __wrapped__)r r% r ÚhasattrÚsetattrr+ )r r Úfuncs r Úunwrapr/ O sx õ 3dÑ #Ô #DØ ð -
4¥Ñ-Ô-ð -µ'¸$À
Ñ2NÔ2Nð -ÝT4Ô+Ñ,Ô,Ð,Ð,Ð,ð-ð -ð -ð -ð -ð -r c ó> dx}x}}t j ¦ « t j u r7t ||¬¦ « }t j |¦ « }t j j }n$t j ¦ « }t j j }|
|||||¬¦ « } | |fS )aÀ Returns internal or server span along with the token which can be used by caller to reset context
Args:
tracer : tracer in use by given instrumentation library
span_name (string): name of the span
start_time : start time of the span
context_carrier : object which contains values that are
used to construct a Context. This object
must be paired with an appropriate getter
which understands how to extract a value from it.
context_getter : an object which contains a get function that can retrieve zero
or more values from the carrier and a keys function that can get all the keys
from carrier.
N)Úgetter)Únamer
ÚkindÚ
start_timer ) r Úget_current_spanÚ INVALID_SPANr r
ÚattachÚSpanKindÚSERVERÚ get_currentÚINTERNALÚ
start_span)
ÚtracerÚ span_namer4 Úcontext_carrierÚcontext_getterr ÚtokenÚctxÚ span_kindÚspans
r Ú _start_internal_or_server_spanrE [ s¤ ð0 #Ð"EÐ"C)Ý Ô Ñ Ô ¥5Ô#5Ð5Ð5Ýo¨nÐ=Ñ=Ô=ÝsÑ#Ô#ÝNÔ) åÔ!Ñ#Ô#ÝNÔ+ Ø × Ò Ø
ØØ
Ø Ø ð ñ ô Dð ;Ðr c ó¨ t | t t f¦ « s| S t j | ¦ « }| dd¦ « S )Nú%z%%)r% r ÚbytesÚurllibÚparseÚquoteÚreplace)ÚsÚquoteds r Ú
_url_quoterO
sH Ý a#u Ñ &Ô &ð ØÝ
\×
Ò
Ñ
"Ô
"Fð
>>#tÑ $Ô $Ð$r c ó> i } t | ¦ « | S )zs
Return the OpenTelemetry Trace and Span IDs if Span ID is set in the
OpenTelemetry execution context.
)Ú
propagatorÚinject)Ú_headerss r Ú_get_opentelemetry_valuesrT s" ð HÝ×ÒhÑ Ô Ð Ø Or c óH t t |¦ « | dd| ¦ « S )Nz(?!$)Ú )r r )Ú python_pathÚ directoryÚpath_separators r Ú _python_path_without_directoryrZ s3 Ý Ý 9Ñ Ô Ð4~Ð4Ð4Ð4Ø
Øñ ô ð r c ó< t j t ¦ « rdS dS )NFT)r
Ú get_valuer
© r r Úis_instrumentation_enabledr^ £ s ÝÔÕ6Ñ7Ô7ð ØuØ 4r c óR t ¦ « ot j t ¦ « S r )r^ r
r\ r r] r r Ú is_http_instrumentation_enabledr` © s, Ý %Ñ 'Ô 'ð µÔ0AÝ*ñ1ô 1ð -ð r Úkeysc ' óò K t j ¦ « }| D ]}t j |d|¦ « }t j |¦ « } dV t j |¦ « dS # t j |¦ « w xY w)ú,Suppress instrumentation within the context.TN)r
r: Ú set_valuer7 Údetach)ra rB ÚkeyrA s r Ú_suppress_instrumentationrg ¯ s è è õ Ô
Ñ
Ô
CØð 0ð 0ÝÔ T¨3Ñ/Ô/Ý N3Ñ Ô Eð Ø
åuÑ Ô Ð Ð Ð øuÑ Ô Ð Ð øøøs ÁA Á A6c # ól K t t ¦ « 5 dV ddd¦ « dS # 1 swxY w Y dS ©rc N)rg r
r] r r Úsuppress_instrumentationrj ¼ s è è õ
#Õ#@Ñ AÔ Að ð Ø
ðð ð ñ ô ð ð ð ð ð ð ð øøøð ð ð ð ð ð ó )©-°-c # ól K t t ¦ « 5 dV ddd¦ « dS # 1 swxY w Y dS ri )rg r r] r r Ú suppress_http_instrumentationrm à s è è õ
#Õ#EÑ FÔ Fð ð Ø
ðð ð ñ ô ð ð ð ð ð ð ð øøøð ð ð ð ð ð rk r )TF)+Ú urllib.parserI Ú
contextlibr Úrer r Útypingr r r Úwraptr Ú
opentelemetryr
r Úopentelemetry.contextr r
Úopentelemetry.propagater Úopentelemetry.tracer Ú,opentelemetry.trace.propagation.tracecontextr rQ Úanyr r r& Úboolr) r/ rE rO ÚdictrT rZ r^ r` rg rj rm r] r r ú<module>r{ sÜ ðð Ð Ð Ð Ø %Ð %Ð %Ð %Ð %Ð %Ø Ð Ð Ð Ð Ð Ð Ð Ø +Ð +Ð +Ð +Ð +Ð +Ð +Ð +Ð +Ð +à Ð Ð Ð Ð Ð à (Ð (Ð (Ð (Ð (Ð (Ð (Ð (ðð ð ð ð ð ð ð ð ,Ð +Ð +Ð +Ð +Ð +Ø *Ð *Ð *Ð *Ð *Ð *ðð ð ð ð ð ð +Ð
*Ñ
,Ô
,
ð EIð
ð
Ø ð
Ø" 3-ð
Ø37¸¸S¸´>ð
à #s(^ð
ð
ð
ð
ð Ø ð ð Ø ð àð ð ð ð ð ð ð ð ð2 -cð -ð -ð -ð -ð$ ð
'ð 'ð 'ð 'ðT%Sð %ð %ð %ð %ð 4ð ð ð ð ðð ð ð Dð ð ð ð ð ¨ð ð ð ð ð ð Sð ¨X°d¬^ð ð ð ñ ð ð ð (¨4¤.ð ð ð ñ ðð ð x°¤~ð ð ð ñ ðð ð r