Создание диапазона OpenTelemetry из String TraceID

Чтобы установить связь родитель-потомок между диапазонами, заголовки должны использоваться в ситуациях, когда распространение контекста невозможно. В этом сценарии идентификатор трассировки и идентификатор диапазона содержатся в заголовках брокера сообщений, что позволяет подписчику создать новый диапазон с родительским идентификатором трассировки.

Решение

Следующие шаги могут быть использовано для создания контекста или диапазона на стороне подписчика с использованием идентификатора трассировки:

1. Определите функцию с идентификатором трассировки в качестве аргумента:

func constructNewSpanContext(traceID string) (spanContext trace.SpanContext, err error) {
    traceID, err := trace.TraceIDFromHex(traceID)
    if err != nil {
        return trace.SpanContext{}, err
    }
    return trace.NewSpanContext(trace.SpanContextConfig{
        TraceID: traceID,
    }), nil
}

2. Внутри канала вызовите функцию для создания контекста диапазона:

spanContext, err := constructNewSpanContext(request.TraceID)
if err != nil {
    log.Fatal(err)
}

3. Дополните контекст созданным контекстом диапазона:

requestContext := context.Background()
requestContext = trace.ContextWithSpanContext(requestContext, spanContext)

4. Создайте новый диапазон, используя расширенный контекст:

requestInLoopSpan, _ := otel.Tracer("requestInLoop").Start(requestContext, "requestInLoopSpan")

Выполняя эти шаги, вы можете успешно создать новый диапазон на стороне подписчика, используя идентификатор трассировки, извлеченный из заголовков сообщений, обеспечивая иерархическую связь между пролеты.