OpenTelemetry Python - 如何将新的跨度实例化为给定trace_id的子跨度

Question

我的目标是通过多个组件对应用程序的整个过程进行跟踪。我正在使用 GCP 和 Pub/Sub 消息队列在组件之间传递信息（用 Python 开发）。

我目前正在尝试通过创建一个新的跨度作为根跟踪的子跨度来在组件 A 和组件 B 之间保持相同的根跟踪。

这是一个小图：

Component A            ---> Pub/Sub message       ---> component B
(create the root trace)      (contain information)      (new span for root trace)

我有一个给定的trace_id和span_id我的父母，我可以通过 Pub/Sub 传输，但我不知道如何声明一个新的跨度作为最后一个的子跨度。我所做的就是将新跟踪链接到父跟踪，但这不是我正在寻找的行为。

有人已经尝试过做类似的事情吗？

问候，

Answer 1

它被称为跟踪上下文传播，有多种格式，例如 w3c 跟踪上下文、jaeger、b3 等... https://github.com/open-telemetry/opentelemetry-specation/blob/b46bcab5fb709381f1fd52096a19541370c7d1b3/specification/context/api-propagators。 md#propagators-distribution。为此，您必须使用传播器的注入/提取方法之一。这是使用 W3CTraceContext 传播器的简单示例。

from opentelemetry import trace
from opentelemetry.sdk.trace import TracerProvider
from opentelemetry.sdk.trace.export import (BatchSpanProcessor,
                                            ConsoleSpanExporter)
from opentelemetry.trace.propagation.tracecontext import \
    TraceContextTextMapPropagator

trace.set_tracer_provider(TracerProvider())
trace.get_tracer_provider().add_span_processor(BatchSpanProcessor(ConsoleSpanExporter()))

tracer = trace.get_tracer(__name__)

prop = TraceContextTextMapPropagator()
carrier = {}

# Injecting the context into carrier and send it over

with tracer.start_as_current_span("first-span") as span:
    prop.inject(carrier=carrier)
    print("Carrier after injecting span context", carrier)


# Extracting the remote context from carrier and starting a new span under same trace.

ctx = prop.extract(carrier=carrier)
with tracer.start_as_current_span("next-span", context=ctx):
    pass