G)f dZddlmZddlmZddlmZddlmZddl m Z ddl m Z m Z ddlmZeeZd e j$fd e j&d eed e j(e j&d efdZd e j,fd e j&d eede j.e j&d d fdZgZej4e dZej9dD]KZej=Z ej?e e!edejEMe jJea&d e jNfdZ(de jNd d fdZ)y #e#$rejIdewxYw)ax API for propagation of context. The propagators for the ``mysql.opentelemetry.propagators.composite.CompositePropagator`` can be defined via configuration in the ``OTEL_PROPAGATORS`` environment variable. This variable should be set to a comma-separated string of names of values for the ``opentelemetry_propagator`` entry point. For example, setting ``OTEL_PROPAGATORS`` to ``tracecontext,baggage`` (which is the default value) would instantiate ``mysql.opentelemetry.propagators.composite.CompositePropagator`` with 2 propagators, one of type ``mysql.opentelemetry.trace.propagation.tracecontext.TraceContextTextMapPropagator`` and other of type ``mysql.opentelemetry.baggage.propagation.W3CBaggagePropagator``. Notice that these propagator classes are defined as ``opentelemetry_propagator`` entry points in the ``pyproject.toml`` file of ``opentelemetry``. Example:: import flask import requests from opentelemetry import propagate PROPAGATOR = propagate.get_global_textmap() def get_header_from_flask_request(request, key): return request.headers.get_all(key) def set_header_into_requests_request(request: requests.Request, key: str, value: str): request.headers[key] = value def example_route(): context = PROPAGATOR.extract( get_header_from_flask_request, flask.request ) request_to_downstream = requests.Request( "GET", "http://httpbin.org/get" ) PROPAGATOR.inject( set_header_into_requests_request, request_to_downstream, context=context ) session = requests.Session() session.send(request_to_downstream.prepare()) .. _Propagation API Specification: https://github.com/open-telemetry/opentelemetry-specification/blob/main/specification/context/api-propagators.md ) getLogger)environ)Optional)Context)OTEL_PROPAGATORS) compositetextmap) entry_pointsNcarriercontextgetterreturnc:tj|||S)aZUses the configured propagator to extract a Context from the carrier. Args: 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. carrier: and 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: an optional Context to use. Defaults to root context if not set. )r )get_global_textmapextract)r r r s c/var/www/html/flask-app/venv/lib/python3.12/site-packages/mysql/opentelemetry/propagate/__init__.pyrrSs$   ' ' ' HHsetterc<tj|||y)aUses the configured propagator to inject a Context into the carrier. Args: carrier: An object that contains a representation of HTTP headers. Should be paired with setter, which should know how to set header values on the carrier. context: An optional Context to use. Defaults to current context if not set. setter: An optional `Setter` object that can set values on the carrier. )r rN)rinject)r r rs rrrhs Hrztracecontext,baggage,opentelemetry_propagator)groupnamez(Failed to load configured propagator: %sctSN_HTTP_TEXT_FORMATrrrrs rhttp_text_formatc|ayrr)r s rset_global_textmapr"s )r)*__doc__loggingrosrtypingr#mysql.opentelemetry.context.contextr)mysql.opentelemetry.environment_variablesrmysql.opentelemetry.propagatorsrr ,mysql.opentelemetry.util._importlib_metadatar __name__loggerdefault_getterCarrierTGetterrdefault_setterSetterr propagatorsgetenviron_propagatorssplit propagatorstripappendnextiterload Exception exceptionCompositePropagatorrTextMapPropagatorrr"rrrr@s6p7F>E 8  "&/6/E/EI   I g I NN7++ ,I I."&/6/E/EI   I g I NN7++ ,I I& "gkk &++C0J!!#J D 8' df  (2I11+>G55)//) ) CZP s +8EE3