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.10 ▾
|
odigos
/
etc
/
odigos-vmagent
/
instrumentations
/
python
/
opentelemetry
/
instrumentation
/
__pycache__
/
utils.cpython-311.pyc
|
|---|
§
QÄg} ã óø d dl Zd dlmZ d dlmZ d dlmZmZ d dl m
Z
m Z m Z m
Z
d dlmZ d dlmZmZ d dlmZmZ d d lmZ d d
lmZ d d lmZ e¦ « Z d Z d$d
e de e de
e e f de
e e f fdZ d%de!de"de"defdZ#d
e
e$e f de fdZ% d$dZ&de fdZ'de(fd Z)d Z*de"fd Z+de"fd Z,ed e de d fd!¦ « Z-ede d fd"¦ « Z.ede d fd#¦ « Z/dS )&é N)Úcontextmanager)Ú
import_module)ÚescapeÚsub)ÚDictÚIterableÚSequenceÚUnion)Ú ObjectProxy)ÚcontextÚtrace)Ú"_SUPPRESS_HTTP_INSTRUMENTATION_KEYÚ _SUPPRESS_INSTRUMENTATION_KEY)Úextract)Ú
StatusCode)Ú TraceContextTextMapPropagatorÚsuppress_instrumentationÚ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-0z7lll2b/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, ; sx õ fcÑ "Ô "ð ÝÔ Ð à
||ÝÔ Ð Ø
}}ÝÔ Ð Ø
}} }ÝÔ Ð Ø
}}}ÝÔ Ð Ý Ô Ðr" r c óî t | t ¦ « r | dd¦ « \ }}n&# t $ r}t d| d¦ « |d}~ww xY wt |¦ « } t
||¦ « } n)# t $ r }t d| d| d¦ « |d}~ww xY wt
| |d¦ « }|r=t |t ¦ « r*t |d ¦ « r t | ||j ¦ « dS dS dS dS )
aM Given a function that was wrapped by wrapt.wrap_function_wrapper, unwrap it
The object containing the function to unwrap may be passed as dotted module path string.
Args:
obj: Object that holds a reference to the wrapped function or dotted import path as string
attr (str): Name of the wrapped function
ú.é zCannot parse 'z' as dotted import pathNzCannot import 'z' from 'ú'Ú __wrapped__) r( r ÚrsplitÚ
ValueErrorÚ ImportErrorr r ÚAttributeErrorr ÚhasattrÚsetattrr1 )r r Ú module_pathÚ
class_nameÚexcÚmoduleÚfuncs r Úunwrapr= T s\ õ #sÑÔð
ð Ø&)§j¢j°°aÑ&8Ô&8Ñ #KøÝð ð ð Ý Ø= Ð=Ð=Ð=ñô àð
øøøøð øøøõ {Ñ+Ô+ð Ý& *Ñ-Ô-CCøÝ ð ð ð Ý Ø? *Ð?Ð?°fÐ?Ð?Ð?ñô àð
øøøøð øøøõ
3dÑ #Ô #DØ ð -
4¥Ñ-Ô-ð -µ'¸$À
Ñ2NÔ2Nð -ÝT4Ô+Ñ,Ô,Ð,Ð,Ð,ð-ð -ð -ð -ð -ð -s, 1 ±
A»AÁAÁ'A8 Á8
B ÂBÂB 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_namerB Úcontext_carrierÚcontext_getterr ÚtokenÚctxÚ span_kindÚspans
r Ú _start_internal_or_server_spanrS q 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_quoter] 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_valuesrb ¦ s" ð HÝ×ÒhÑ Ô Ð Ø Or" c óH t t |¦ « | dd| ¦ « S )Nz(?!$)Ú )r r )Ú python_pathÚ directoryÚpath_separators r Ú _python_path_without_directoryrh ± s3 Ý Ý 9Ñ Ô Ð4~Ð4Ð4Ð4Ø
Øñ ô ð r" c óh t j t ¦ « pt j t ¦ « S r )r Ú get_valuer Ú#_SUPPRESS_INSTRUMENTATION_KEY_PLAIN© r" r Úis_instrumentation_enabledrm ¹ s0 åÔÕ7Ñ8Ô8ð BÝ Ô Õ @Ñ AÔ Að ð r" c óR t ¦ « ot j t ¦ « S r )rm r rj r rl r" r Ú is_http_instrumentation_enabledro À 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 rH Ú set_valuerE Údetach)rp rP ÚkeyrO s r Ú_suppress_instrumentationrv Æ s è è õ Ô
Ñ
Ô
CØð 0ð 0ÝÔ T¨3Ñ/Ô/Ý N3Ñ Ô Eð Ø
åuÑ Ô Ð Ð Ð øuÑ Ô Ð Ð øøøs ÁA Á A6c # óx K t t t ¦ « 5 dV ddd¦ « dS # 1 swxY w Y dS ©rr N)rv r rk rl r" r r r Ó s è è õ
#Ý%Õ'Jñ
ô
ð ð ð ðð ð ñ ô ð ð ð ð ð ð ð øøøð ð ð ð ð ð s /¯3¶3c # ól K t t ¦ « 5 dV ddd¦ « dS # 1 swxY w Y dS rx )rv r rl r" r Ú suppress_http_instrumentationrz Ü s è è õ
#Õ#EÑ FÔ Fð ð Ø
ðð ð ñ ô ð ð ð ð ð ð ð øøøð ð ð ð ð ð s )©-°-r )TF)0Ú urllib.parserW Ú
contextlibr Ú importlibr Úrer r Útypingr r r r
Úwraptr Ú
opentelemetryr r
Úopentelemetry.contextr r Úopentelemetry.propagater Úopentelemetry.tracer Ú,opentelemetry.trace.propagation.tracecontextr r_ rk Úanyr r! r) Úboolr, Úobjectr= rS r] Údictrb rh rm ro rv r rz rl r" r ú<module>r s ðð Ð Ð Ð Ø %Ð %Ð %Ð %Ð %Ð %Ø #Ð #Ð #Ð #Ð #Ð #Ø Ð Ð Ð Ð Ð Ð Ð Ø 2Ð 2Ð 2Ð 2Ð 2Ð 2Ð 2Ð 2Ð 2Ð 2Ð 2Ð 2à Ð Ð Ð Ð Ð à (Ð (Ð (Ð (Ð (Ð (Ð (Ð (ðð ð ð ð ð ð ð ð ,Ð +Ð +Ð +Ð +Ð +Ø *Ð *Ð *Ð *Ð *Ð *ðð ð ð ð ð ð +Ð
*Ñ
,Ô
,
ð ð $ð EIð
ð
Ø ð
Ø" 3-ð
Ø37¸¸S¸´>ð
à #s(^ð
ð
ð
ð
ð Ø ð ð Ø ð àð ð ð ð ð ð ð ð ð2-fckÔ"ð -¨#ð -ð -ð -ð -ðF ð
'ð 'ð 'ð 'ðT%Sð %ð %ð %ð %ð 4ð ð ð ð ðð ð ð Dð ð ð ð ð¨ð ð ð ð ð ð Sð ¨X°d¬^ð ð ð ñ ð ð ð (¨4¤.ð ð ð ñ ðð ð x°¤~ð ð ð ñ ðð ð r"