在处理分布式系统时,维护组件之间的上下文和跟踪关系至关重要。在这种情况下,发布者使用消息标头来传播跟踪信息,我们仍然可以使用接收到的 TraceID 字符串在订阅者端构建 OpenTelemetry Span。
至创建一个与其父级正确链接的span,我们需要将从请求标头中提取的traceID和spanID字符串转换为trace.TraceID和trace.SpanID对象。我们使用以下函数来实现这一点:
<code class="go">var traceID trace.TraceID traceID, err = trace.TraceIDFromHex(request.TraceID) var spanID trace.SpanID spanID, err = trace.SpanIDFromHex(request.SpanID)</code>
使用traceID和spanID对象,我们可以构造一个SpanContext。我们需要将 Remote 标志设置为 false,表示该 Span 不会导出到远程系统:
<code class="go">var spanContextConfig trace.SpanContextConfig spanContextConfig.TraceID = traceID spanContextConfig.SpanID = spanID spanContextConfig.TraceFlags = 01 spanContextConfig.Remote = false spanContext = trace.NewSpanContext(spanContextConfig)</code>
创建新 Span有了这个构造好的 SpanContext,我们首先需要用它丰富一个新的上下文:
<code class="go">requestContext := context.Background() requestContext = trace.ContextWithSpanContext(requestContext, spanContext)</code>
然后,我们可以使用丰富的上下文启动一个新的子范围:
<code class="go">var requestInLoopSpan trace.Span childContext, requestInLoopSpan := otel.Tracer("inboundmessage").Start(requestContext, "requestInLoopSpan")</code>
这个子元素span 将链接到发布者端的父 span,从而允许在整个分布式系统中进行正确的上下文传播。
以上是如何在分布式系统中从字符串 TraceID 创建 OpenTelemetry Span?的详细内容。更多信息请关注PHP中文网其他相关文章!