问题解决：在 Go 中使用 Azure ServiceBus 队列的 OpenTelemetry 传播

知识点掌握了，还需要不断练习才能熟练运用。下面golang学习网给大家带来一个Golang开发实战，手把手教大家学习《问题解决：在 Go 中使用 Azure ServiceBus 队列的 OpenTelemetry 传播》，在实现功能的过程中也带大家重新温习相关知识点，温故而知新，回头看看说不定又有不一样的感悟！

我有三个服务，它们订阅并发布到天蓝色服务总线上的单独队列。我刚刚为这些服务添加了开放遥测，但它似乎并未在服务之间传播跟踪 ID。

例如，单个跟踪理想情况下包括服务之间的流：

服务1 -> 队列1 -> 服务2 -> 队列2 -> 服务3

看起来我应该在服务之间注入/提取此信息，但关于如何执行此操作的文档/示例似乎有限，因为显然它应该使用 W3C 跟踪上下文“正常工作”？

如果有人能够提供任何见解或指导，告诉我应该做什么才能达到预期的结果，我将不胜感激。

非常感谢。

正确答案

我记得当我需要在多个 grpc 服务之间传播跟踪时，我对 opencensus 跟踪库做了类似的事情。我获取了现有的跟踪范围，将其馈送到 binary 函数，获取字节，将其设置为传出上下文中的数据，然后在接收端，我从传入上下文中提取跟踪范围并将其馈送到trace.startspanwithremoteparent。 p>

这是向上下文添加跟踪的 util 的实现：

package grpcutil

import (
    "context"
    "encoding/base64"

    "github.com/grpc-ecosystem/go-grpc-middleware/util/metautils"
    "go.opencensus.io/trace"
    "go.opencensus.io/trace/propagation"
    "google.golang.org/grpc/metadata"
)

const tracecontextmdkey = "trace_ctx"

func newtraceablecontext(ctx context.context, span *trace.span) context.context {
    return metadata.appendtooutgoingcontext(
        ctx,
        tracecontextmdkey, base64.stdencoding.encodetostring(propagation.binary(span.spancontext())),
    )
}

func getremotetracecontext(ctx context.context) (trace.spancontext, bool) {
    var tracectx []byte
    extctx := metautils.extractincoming(ctx).get(tracecontextmdkey)
    if len(extctx) > 0 {
        tracectx, _ = base64.stdencoding.decodestring(extctx)
    }
    return propagation.frombinary(tracectx)
}

接收端的样子：

remoteTraceCtx, _ := grpcutil.GetRemoteTraceContext(ctx)
_, span := trace.StartSpanWithRemoteParent(ctx, "name", remoteTraceCtx)
defer span.End()

希望这能为您指明正确的方向。

今天关于《问题解决：在 Go 中使用 Azure ServiceBus 队列的 OpenTelemetry 传播》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！