qPh}% ddlmZddlmZddlmZddlmZmZm Z m Z m Z m Z m Z ddlmZmZddlmZmZmZmZddlmZddlmZmZ dd lm Z d d l"m#Z#d dl$m%Z%mZ&e rddl'mZmZdZ(dZ)e&jTejTe&jVejVe&jXejXe&jZejZe&j\ej\e&j^ej\iZ0GddZ1y#e!$rd Z YwxYw)) annotations)contextmanager)Token)OptionalDictSequencecastCallableIterator TYPE_CHECKING)contexttrace)SpanSpanKindLink StatusCode)get_current_span)extractinject)"_SUPPRESS_HTTP_INSTRUMENTATION_KEYsuppress_http_instrumentation)VERSION) Attributesr)rrz'https://opentelemetry.io/schemas/1.23.1z azure-corecNeZdZdZddddd ddZej ddd ddZeej dddd dd Z e edd dd Z e ddd Z dd Ze ddZe ddZe ddZe ddZe ddZy)OpenTelemetryTracera7A tracer that uses OpenTelemetry to trace operations. :keyword library_name: The name of the library to use in the tracer. :paramtype library_name: str :keyword library_version: The version of the library to use in the tracer. :paramtype library_version: str :keyword schema_url: Specifies the Schema URL of the emitted spans. Defaults to "https://opentelemetry.io/schemas/1.23.1". :paramtype schema_url: str :keyword attributes: Attributes to add to the emitted spans. :paramtype attributes: Mapping[str, AttributeValue] N) library_namelibrary_version schema_url attributescptj|xst|xst|xst||_y)N)instrumenting_module_nameinstrumenting_library_versionr r!)r get_tracer_DEFAULT_MODULE_NAMEr_DEFAULT_SCHEMA_URL_tracer)selfrrr r!s n/var/www/dev.core.comfenalco.cic-ware.com/crm/lib/python3.12/site-packages/azure/core/tracing/opentelemetry.py__init__zOpenTelemetryTracer.__init__>s3''&2&J6J*9*DW!8%8!   kindr!linksctj|tj}|j |}|j j ||||d}|S)a@Starts a span without setting it as the current span in the context. :param name: The name of the span :type name: str :keyword kind: The kind of the span. INTERNAL by default. :paramtype kind: ~azure.core.tracing.SpanKind :keyword attributes: Attributes to add to the span. :paramtype attributes: Mapping[str, AttributeValue] :keyword links: Links to add to the span. :paramtype links: list[~azure.core.tracing.Link] :return: The span that was started :rtype: ~opentelemetry.trace.Span F)r.r!r/record_exception)_KIND_MAPPINGSgetOpenTelemetrySpanKindINTERNAL _parse_linksr( start_span)r)namer.r!r/ otel_kind otel_links otel_spans r*r7zOpenTelemetryTracer.start_spanMs]*#&&t-B-K-KL &&u- LL++ !" , r,T)r.r!r/ end_on_exitc#K|j||||}tj|d|5}|dddy#1swYyxYww)aContext manager that starts a span and sets it as the current span in the context. .. code:: python with tracer.start_as_current_span("span_name") as span: # Do something with the span span.set_attribute("key", "value") :param name: The name of the span :type name: str :keyword kind: The kind of the span. INTERNAL by default. :paramtype kind: ~azure.core.tracing.SpanKind :keyword attributes: Attributes to add to the span. :paramtype attributes: Optional[Attributes] :keyword links: Links to add to the span. :paramtype links: Optional[Sequence[Link]] :keyword end_on_exit: Whether to end the span when exiting the context manager. Defaults to True. :paramtype end_on_exit: bool :return: The span that was started :rtype: Iterator[~opentelemetry.trace.Span] r-Fr1r<N)r7ruse_span)r)r8r.r!r/r<spans r*start_as_current_spanz)OpenTelemetryTracer.start_as_current_spanosM>t$:US ^^ 5k   J   s.A > A AA )r<c#nKtj|d|5}|dddy#1swYyxYww)aContext manager that takes a non-active span and activates it in the current context. :param span: The span to set as the current span :type span: ~opentelemetry.trace.Span :keyword end_on_exit: Whether to end the span when exiting the context manager. Defaults to True. :paramtype end_on_exit: bool :return: The span that was activated. :rtype: Iterator[~opentelemetry.trace.Span] Fr>N)rr?)clsr@r< active_spans r*r?zOpenTelemetryTracer.use_spans8^^ 5k       s5) 525cF|jtj|y)aSet the status of a span to ERROR with the provided description, if any. :param span: The span to set the ERROR status on. :type span: ~opentelemetry.trace.Span :param description: An optional description of the error. :type description: str ) descriptionN) set_statusrERROR)r@rFs r*set_span_error_statusz)OpenTelemetryTracer.set_span_error_statuss  ((kBr,c|sy g}|D]U}t|j}t|j}|j t ||j W|S#t$rttt |cYSwxYwN) rheadersget_current_span_otelget_span_contextappendOpenTelemetryLinkr!AttributeErrorr r)r)r/r:linkctxspan_ctxs r*r6z OpenTelemetryTracer._parse_linkss <J Pdll+05FFH!!"3Hdoo"NO P  <!23U; ; tjfd}|S)zPasses the current spans to the new context the function will be run in. :param func: The function that will be run in the new context :type func: callable :return: The wrapped function :rtype: callable cd} tj}|i||tj|SS#|tj|wwxYwrK)otel_context_moduleattachdetach)argskwargstokencurrent_contextfuncs r*call_with_current_contextzKOpenTelemetryTracer.with_current_context..call_with_current_contexts]E 6+22?CT,V,$'..u5%5$'..u5%s :A)rY get_current)rCr`rar_s ` @r*with_current_contextz(OpenTelemetryTracer.with_current_contexts .99; 6)(r,c i}t||S)aReturns the Trace Context header values associated with the current span. These are generally the W3C Trace Context headers (i.e. "traceparent" and "tracestate"). :return: A key value pair dictionary :rtype: dict[str, str] )r)rC trace_contexts r*get_trace_contextz%OpenTelemetryTracer.get_trace_contexts)+ }r,c\tjtjtdS)aEnabled automatic HTTP instrumentation suppression. Since azure-core already instruments HTTP calls, we need to suppress any automatic HTTP instrumentation provided by other libraries to prevent duplicate spans. This has no effect if no automatic HTTP instrumentation libraries are being used. :return: A token that can be used to detach the suppression key from the context :rtype: ~contextvars.Token T)rYrZ set_valuerrVs r*#_suppress_auto_http_instrumentationz7OpenTelemetryTracer._suppress_auto_http_instrumentations%#))*=*G*GHjlp*qrrr,c.tj|y)z|Detach a token from the context. :param token: The token to detach :type token: ~contextvars.Token N)rYr[)rCr^s r*_detach_from_contextz(OpenTelemetryTracer._detach_from_contexts ""5)r,) r Optional[str]rrlr rlr!Optional[Attributes]returnNone) r8strr.rr!rmr/Optional[Sequence[Link]]rnr) r8rpr.rr!rmr/rqr<boolrnIterator[Span])r@rr<rrrnrsrK)r@rrFrlrnro)r/rqrnz%Optional[Sequence[OpenTelemetryLink]])rnr)r`r rnr )rnzDict[str, str])rnr)r^rrnro)__name__ __module__ __qualname____doc__r+ _SpanKindr5r7rrA classmethodr? staticmethodrIr6rrcrfrirkr,r*rr0s  '+)-$(+/  $  '  "  )     &#+++/*.    )  (   D #+++/*. "" " ) " ( "" ""H9=  CC< ''))*   s s**r,rN)2 __future__r contextlibr contextvarsrtypingrrrr r r r opentelemetryr rYropentelemetry.tracerrr4rrPropentelemetry.trace.propagationrrMopentelemetry.propagaterropentelemetry.contextr ImportError_versionr_modelsrrxazure.core.tracingr'r&CLIENTCONSUMERPRODUCERSERVERr5 UNSPECIFIEDr2rr{r,r*rs #%TTT? V3IH 1@#+22 -66 -66 +22 -66 099 P*P*5I)H&IsC;;DD