将 dd-trace-go 用于工作人员跨度 ID

如何解决将 dd-trace-go 用于工作人员跨度 ID

我正在尝试为我的工作人员设置 dd-trace-go，它侦听活动的 mq 队列并处理消息。但是，如果我将上下文传递给另一个函数，我将无法获得跨度 ID。这是一个演示：

package main

import (
    "context"

    "github.com/davecgh/go-spew/spew"
    "gopkg.in/DataDog/dd-trace-go.v1/ddtrace/tracer"
)

func main() {
    tracer.Start(
        tracer.WithServiceName("my-worker"),tracer.WithGlobalTag("env","dev"),)
    defer tracer.Stop()

    ctx := context.Background()


    // for loop to listen a message here
    // for every loop,init contextWithCancel
    ctxWithCancel,cancelFunction := context.WithCancel(ctx)

    span,_ := tracer.StartSpanFromContext(ctxWithCancel,"Listen",tracer.ServiceName("my-worker"))

    spew.Dump(ctxWithCancel)
    spew.Dump(span.Context().TraceID())

    test(ctxWithCancel)
    cancelFunction()
}

// callback to process the message
func test(c context.Context) {
    span,_ := tracer.SpanFromContext(c)
    spew.Dump("inside test function")
    spew.Dump(span.Context().TraceID())
}

输出为：

(*context.cancelCtx)(0xc00006ce80)(context.Background.WithCancel)
(uint64) 6512722789050192664
(string) (len=20) "inside test function"
(uint64) 0

为什么测试函数中的跟踪 ID 是 0 而不是 6512722789050192664 ？谢谢