3

我的目标是通过几个组件来跟踪我的应用程序的整个过程。我正在使用 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 传输，但我不知道如何将一个新的跨度声明为最后一个子级。我设法做的就是将一个新的跟踪链接到父跟踪，但这不是我正在寻找的行为。

有人已经尝试过这样做吗？

问候，

4

2 回答 2

7

它被称为跟踪上下文传播，有多种格式，例如 w3c 跟踪上下文、jaeger、b3 等... https://github.com/open-telemetry/opentelemetry-specification/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
于 2021-07-27T23:43:53.973 回答
0

对于来到这里的其他人，这就是我根据@dalalstreetboi3739 的建议最终做的事情：（我意识到我得到的“trace_id”已经是一个符合 w3c 的跟踪头https://www.w3.org/TR/trace- context/#trace-context-http-headers-format允许我TraceContextTextMapPropagator直接使用）：

data = get_json()
trace_id_str = data['traceid']
carrier = {'traceparent': trace_id_str}

ctx = TraceContextTextMapPropagator().extract(carrier=carrier)
with tracer.start_as_current_span("/api/doit", ctx) as span:
   # do awesome stuff here
   # current span is now a child of the parent "trace_id"
   requests.get("http://what")
于 2021-10-26T08:06:56.753 回答