在所有应用程序日志中启用 Golang Logrus Opentelemetry Trace ID 和 Span ID

本篇文章向大家介绍《在所有应用程序日志中启用 Golang Logrus Opentelemetry Trace ID 和 Span ID》，主要包括，具有一定的参考价值，需要的朋友可以参考一下。

我正在尝试为每个应用程序日志启用跟踪 id 和跨度 id。我正在使用 opentelemtry api 进行注入，并使用 logrus labrary 进行日志记录。下面是一个示例代码，我可以在其中启用所有日志中输入的跟踪/跨度，但跟踪和跨度 id 值始终为 0。

#server.go#

package main

import (
    log "github.com/sirupsen/logrus"
    "fmt"
    "context"
    "os"
    "net/http"
    "go.opentelemetry.io/otel/trace"
     stdout "go.opentelemetry.io/otel/exporters/stdout/stdouttrace"
     sdktrace "go.opentelemetry.io/otel/sdk/trace"
     "go.opentelemetry.io/otel/sdk/resource"
     semconv "go.opentelemetry.io/otel/semconv/v1.10.0"
     "go.opentelemetry.io/otel"
     "go.opentelemetry.io/contrib/propagators/b3"
     "go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp"
)

func init() {
  log.setformatter(customlogger{
                formatter:    log.jsonformatter{fieldmap: log.fieldmap{
                "msg": "message",
                }},
        })
  log.setoutput(os.stdout)
  log.setlevel(log.infolevel)
}


func inittracer() (*sdktrace.tracerprovider, error) {
        exporter, err := stdout.new(stdout.withprettyprint())
        if err != nil {
                return nil, err
        }

        tp := sdktrace.newtracerprovider(
                sdktrace.withsampler(sdktrace.alwayssample()),
                sdktrace.withbatcher(exporter),
                sdktrace.withresource(resource.newwithattributes(semconv.schemaurl, semconv.servicenamekey.string("preferencesservice"))),
        )
        otel.settracerprovider(tp)
        b3 := b3.new()
        otel.settextmappropagator(b3)
        return tp, err
}


func main() {
    ctx := context.background()
    tp, err := inittracer()
    if err != nil {
           log.error(err)
    }
    defer func() {
           if err := tp.shutdown(ctx); err != nil {
                  log.error("error shutting down tracer provider: %v", err)
           }
    }()

    otelhandler := otelhttp.newhandler(http.handlerfunc(func(w http.responsewriter, _ *http.request) {
        log.info("about end point printning...")
        fmt.fprintln(w, "about page")
    }),"about")
    http.handle("/about", otelhandler)
    log.info("listening...")
    log.fatal(http.listenandserve(":8080", nil))
}

type customlogger struct {
        formatter    log.jsonformatter
}

func (l customlogger) format(entry *log.entry) ([]byte, error) {
        span := trace.spanfromcontext(entry.context)
        entry.data["trace_id"] = span.spancontext().traceid().string()
        entry.data["span_id"] = span.spancontext().spanid().string()
        //below injection is just to understand what context has
        entry.data["context"] = span.spancontext()
        return l.formatter.format(entry)
}

#client.go#

package main

import (
    "fmt"
    "io/ioutil"
    "log"
    "net/http"
)

func main() {

    resp, err := http.get("http://localhost:8080/about")

    if err != nil {
        log.fatal(err)
    }

    defer resp.body.close()

    body, err := ioutil.readall(resp.body)

    if err != nil {
        log.fatal(err)
    }

    fmt.println(string(body))
}

#输出：#

{"Context":{"TraceID":"00000000000000000000000000000000","SpanID":"0000000000000000","TraceFlags":"00","TraceState":"","Remote":false},"level":"info","message":"Listening...","span_id":"0000000000000000","time":"2022-06-30T12:34:21+05:30","trace_id":"00000000000000000000000000000000"}
{"Context":


**Below Line Should have Proper Trace ID and Span ID**
{"TraceID":"00000000000000000000000000000000","SpanID":"0000000000000000","TraceFlags":"00","TraceState":"","Remote":false},"level":"info","message":"About End Point Printning...","span_id":"0000000000000000","time":"2022-06-30T12:34:28+05:30","trace_id":"00000000000000000000000000000000"}




{
        "Name": "About",
        "SpanContext": {
                "TraceID": "cb4dc4953a633fbe9b41c19a0870e9d6",
                "SpanID": "b7346b7aba15e074",
                "TraceFlags": "01",
                "TraceState": "",
                "Remote": false
        },
        "Parent": {
                "TraceID": "00000000000000000000000000000000",
                "SpanID": "0000000000000000",
                "TraceFlags": "00",
                "TraceState": "",
                "Remote": false
        },
        "SpanKind": 2,
        "StartTime": "2022-06-30T12:34:28.838523497+05:30",
        "EndTime": "2022-06-30T12:34:28.838858989+05:30",
        "Attributes": [
                {
                        "Key": "net.transport",
                        "Value": {
                                "Type": "STRING",
                                "Value": "ip_tcp"
                        }
                },
                {
                        "Key": "net.peer.ip",
                        "Value": {
                                "Type": "STRING",
                                "Value": "127.0.0.1"
                        }
                },
                {
                        "Key": "net.peer.port",
                        "Value": {
                                "Type": "INT64",
                                "Value": 41900
                        }
                },
                {
                        "Key": "net.host.name",
                        "Value": {
                                "Type": "STRING",
                                "Value": "localhost"
                        }
                },
                {
                        "Key": "net.host.port",
                        "Value": {
                                "Type": "INT64",
                                "Value": 8080
                        }
                },
                {
                        "Key": "http.method",
                        "Value": {
                                "Type": "STRING",
                                "Value": "GET"
                        }
                },
                {
                        "Key": "http.target",
                        "Value": {
                                "Type": "STRING",
                                "Value": "/about"
                        }
                },
                {
                        "Key": "http.server_name",
                        "Value": {
                                "Type": "STRING",
                                "Value": "About"
                        }
                },
                {
                        "Key": "http.user_agent",
                        "Value": {
                                "Type": "STRING",
                                "Value": "Go-http-client/1.1"
                        }
                },
                {
                        "Key": "http.scheme",
                        "Value": {
                                "Type": "STRING",
                                "Value": "http"
                        }
                },
                {
                        "Key": "http.host",
                        "Value": {
                                "Type": "STRING",
                                "Value": "localhost:8080"
                        }
                },
                {
                        "Key": "http.flavor",
                        "Value": {
                                "Type": "STRING",
                                "Value": "1.1"
                        }
                },
                {
                        "Key": "http.wrote_bytes",
                        "Value": {
                                "Type": "INT64",
                                "Value": 11
                        }
                },
                {
                        "Key": "http.status_code",
                        "Value": {
                                "Type": "INT64",
                                "Value": 200
                        }
                }
        ],
        "Events": null,
        "Links": null,
        "Status": {
                "Code": "Unset",
                "Description": ""
        },
        "DroppedAttributes": 0,
        "DroppedEvents": 0,
        "DroppedLinks": 0,
        "ChildSpanCount": 0,
        "Resource": [
                {
                        "Key": "service.name",
                        "Value": {
                                "Type": "STRING",
                                "Value": "PreferencesService"
                        }
                }
        ],
        "InstrumentationLibrary": {
                "Name": "go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp",
                "Version": "semver:0.32.0",
                "SchemaURL": ""
        }
}

不确定错误在哪里/什么，但如果有人将我引导到正确的方向，我如何将跟踪 id 和跨度 id 注入到所有日志中，这将会很有帮助。

注意：我不想将请求上下文传递给所有函数。寻找其他选择

正确答案

问题是 span := trace.spanfromcontext(entry.context) 无法获取 span 上下文。

也许你应该将 req.context() 注入 logrus 然后打印日志

    otelhandler := otelhttp.newhandler(http.handlerfunc(func(w http.responsewriter, req *http.request) {
        //log.info("about end point printning...")
        // inject req.context
        log.withcontext(req.context()).info("about end point printning...")
        fmt.fprintln(w, "about page")
    }), "about")

运行server.go，然后运行client.go，输出为

{"Context":{"TraceID":"00000000000000000000000000000000","SpanID":"0000000000000000","TraceFlags":"00","TraceState":"","Remote":false},"level":"info","message":"Listening...","span_id":"0000000000000000","time":"2022-07-02T21:39:49+08:00","trace_id":"00000000000000000000000000000000"}
{"Context":{"TraceID":"7cab2739ea2c5b2d3e6a08cfb57858a9","SpanID":"ec5ba151b6823658","TraceFlags":"01","TraceState":"","Remote":false},"level":"info","message":"About End Point Printning...","span_id":"ec5ba151b6823658","time":"2022-07-02T21:39:54+08:00","trace_id":"7cab2739ea2c5b2d3e6a08cfb57858a9"}

注意：第一行不打印traceid是因为没有请求

希望对您有帮助。

终于介绍完啦！小伙伴们，这篇关于《在所有应用程序日志中启用 Golang Logrus Opentelemetry Trace ID 和 Span ID》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！