如何在gRPC服务器存根中从ctx创建OpenTelem计跨度

Question

我的Go gRPC服务器安装了

>

Google跟踪范围导出器：

import texporter "github.com/GoogleCloudPlatform/opentelemetry-operations-go/exporter/trace"
...
gcp, err := texporter.NewExporter()
...
tracer := trace.NewTracerProvider(trace.WithSyncer(traceExporter),
    trace.WithSampler(trace.AlwaysSample()))
otel.SetTracerProvider(tracer)

Otelgrpc拦截器在gRPC服务器上注册。

unaryInterceptors := grpc_middleware.WithUnaryServerChain(
    otelgrpc.UnaryServerInterceptor(),
)
streamInterceptors := grpc_middleware.WithStreamServerChain(
    otelgrpc.StreamServerInterceptor(),
)

现在，我正在尝试在RPC实现中创建一个跟踪范围，以便为该方法创建子范围，例如：

func (s *srv) Test(ctx context.Context, req *pb.Request) (*pb.TestResponse, error) {
    // create a span here
    span1 := [??????].Start()
    doWork1()
    span1.End()

    span2 := [??????].Start()
    doWork2()
    span2.End()
    ...
}

然而，从OpenTelemetry文档中还不清楚人们是如何做到这一点的。

离我最近的是奥特尔。GetTracerProvider（）。Tracer（“这里有一些字符串？”） 提供启动（ctx）（ctx，Span）。但我不清楚这里要提供什么字符串（我的导出器没有文档所示的url），这似乎很不方便。

我在想有一种类似于otelgrpc的东西。span fromCTX（ctx）方法在某个地方拉动跟踪器，创建一个带有rpc ctx的span，我找不到它。遗憾的是，OT gRPC Go上的文档非常缺乏。

Answer 1

因为您正在使用github。com/GoogleCloudPlatform/opentelemetry操作，您应该使用自身来创建span，而不是opentelemetry。

可以创建如下新范围：

    // Create custom span.
    tracer := otel.TraceProvider().Tracer("example.com/trace")
    err = func(ctx context.Context) error {
        ctx, span := tracer.Start(ctx, "foo")
        defer span.End()

        // Do some work.

        return nil
    }(ctx)

有关更多详细信息，您可以参考OpenTelemeter Google Cloud Trace Exporter