gpt4 book ai didi

go - 从 opentelemetry 的请求 header 中提取跟踪器的正确方法

转载 作者:行者123 更新时间:2023-12-05 05:57:13 31 4
gpt4 key购买 nike

我有 krakend apigateway,它使用 opentracing 并将请求 header 作为 X-B3-... 发送以进行跟踪,我的服务使用 opentelemetry。
这就是我现在在 jaeger 上看到的。
enter image description here

enter image description here

我希望服务跨度在 apigateways 下。

我做过的解决方法:
这是使用 chi 路由器的请求的确切处理程序。

func (env *Env) getCommentForBlogRouter(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()

keys := []string{"X-B3-Traceid", "X-B3-Spanid", "X-B3-Sampled"}
var carrier propagation.HeaderCarrier = propagation.HeaderCarrier{}
for _, k := range keys {
carrier.Set(strings.ToLower(k), r.Header[k][0])
}

var propagator propagation.TextMapPropagator = otel.GetTextMapPropagator()
ctx = propagator.Extract(ctx, carrier)

// fmt.Println(ctx)
tr := otel.Tracer("Handler: blog-comments")
ctx, span := tr.Start(ctx, "handler span")
defer span.End()

blogId := r.URL.Query().Get("blog-id")
span.SetAttributes(attribute.Key("blog-id").String(fmt.Sprint(blogId)))

var spanDB trace.Span
ctx, spanDB = tr.Start(ctx, "Select row")

comments, err := env.comments.GetForBlog(blogId)
spanDB.End()

var spanRes trace.Span
_, spanRes = tr.Start(ctx, "Sending Response")
defer spanRes.End()

if err != nil {
fmt.Println(err)
SendError(w, http.StatusInternalServerError, "Something went wrong")
return
}

if comments == nil {
comments = []models.Comment{}
}
SendResponse(w, http.StatusOK, map[string]interface{}{
"data": comments,
})
}

最佳答案

好的,我想出了如何让它发挥作用。我添加了这个中间件,它将请求上下文与 header traceID、spanID 和 traceFlags 同步。在此之后,我们可以根据需要创建跟踪器和跨度。

func Tracing(next http.Handler) http.Handler {
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
traceID, _ := trace.TraceIDFromHex(r.Header["X-B3-Traceid"][0])
spanID, _ := trace.SpanIDFromHex(r.Header["X-B3-Spanid"][0])
var traceFlags trace.TraceFlags
if r.Header["X-B3-Sampled"][0] == "1" {
traceFlags = trace.FlagsSampled
}

spanContext := trace.NewSpanContext(trace.SpanContextConfig{
TraceID: traceID,
SpanID: spanID,
TraceFlags: traceFlags,
})

ctx := trace.ContextWithSpanContext(r.Context(), spanContext)

r = r.WithContext(ctx)
next.ServeHTTP(w, r)
})
}

关于go - 从 opentelemetry 的请求 header 中提取跟踪器的正确方法,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/68881728/

31 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com