以 Golang 为基础，手动提取 OpenTelemetry 上下文到字符串中的方法

在IT行业这个发展更新速度很快的行业，只有不停止的学习，才不会被行业所淘汰。如果你是Golang学习者，那么本文《以 Golang 为基础，手动提取 OpenTelemetry 上下文到字符串中的方法》就很适合你！本篇内容主要包括##content_title##，希望对大家的知识积累有所帮助，助力实战开发！

我正在构建一个简单的客户端服务器应用程序，我希望跨客户端执行跟踪到调用第二个服务器微服务的服务器微服务。

简单来说，并不比 cli -> servicea -> serviceb 复杂。

我面临的挑战是如何序列化上下文 - 我看过的大多数文档似乎都进行某种形式的自动 http 标头注入（例如 https://opentelemetry.lightstep.com/core-concepts /context-propagation/) ，但我无权访问它。我需要序列化（我认为）客户端中跟踪/跨度的上下文并将其推送到服务器，我将在服务器上重新水化它。 （请注意，我希望这个更简单，但我无法弄清楚）。

所以该对象看起来像这样（称为“工作”）：

args := &types.submitargs{
        serializedotelcontext: serializedotelcontext,
    }

    job := &types.job{}

    tracer := otel.gettracerprovider().tracer("myservice.org")
    _, span := tracer.start(ctx, "submitting job to rpc")
    err := system.jsonrpcmethod(rpchost, rpcport, "submit", args, job)

提交到 jsonrpcmethod 的函数在这里：

func jsonrpcmethod(
    host string,
    port int,
    method string,
    req, res interface{},
) error {
    client, err := rpc.dialhttp("tcp", fmt.sprintf("%s:%d", host, port))
    if err != nil {
        return fmt.errorf("error in dialing. %s", err)
    }
    return client.call(fmt.sprintf("jobserver.%s", method), req, res)
}

接收它的函数在这里：

func (server *JobServer) Submit(args *types.SubmitArgs, reply *types.Job) error {
    //nolint
    job, err := server.RequesterNode.Scheduler.SubmitJob(args.Spec, args.Deal)
    if err != nil {
        return err
    }
    *reply = *job
    return nil
}

我的问题是如何在接收函数（上面的“提交”）中从发送方提取跟踪/跨度？

正确答案

这里用一个小程序来说明用法。希望这能让大家清楚。

package main

import (
    "context"
    "fmt"

    "go.opentelemetry.io/otel/exporters/stdout/stdouttrace"
    "go.opentelemetry.io/otel/propagation"
    sdktrace "go.opentelemetry.io/otel/sdk/trace"
)

func main() {

    // common init
    // You may also want to set them as globals
    exp, _ := stdouttrace.New(stdouttrace.WithPrettyPrint())
    bsp := sdktrace.NewSimpleSpanProcessor(exp) // You should use batch span processor in prod
    tp := sdktrace.NewTracerProvider(
        sdktrace.WithSampler(sdktrace.AlwaysSample()),
        sdktrace.WithSpanProcessor(bsp),
    )

    propgator := propagation.NewCompositeTextMapPropagator(propagation.TraceContext{}, propagation.Baggage{})

    ctx, span := tp.Tracer("foo").Start(context.Background(), "parent-span-name")
    defer span.End()

    // Serialize the context into carrier
    carrier := propagation.MapCarrier{}
    propgator.Inject(ctx, carrier)
    // This carrier is sent accros the process
    fmt.Println(carrier)

    // Extract the context and start new span as child
    // In your receiving function
    parentCtx := propgator.Extract(context.Background(), carrier)
    _, childSpan := tp.Tracer("foo").Start(parentCtx, "child-span-name")
    childSpan.AddEvent("some-dummy-event")
    childSpan.End()
}

到这里，我们也就讲完了《以 Golang 为基础，手动提取 OpenTelemetry 上下文到字符串中的方法》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！