在Golang中将来自标头的traceId添加到发送到Loki服务器的日志中。

huangapple
go评论113阅读模式
英文:

Adding traceId from header to logs sent to Loki server in Golang

问题

我有一个名为LokiLogs的函数，它将日志发送到Loki服务器。我想在每个API调用中将一个名为traceId的标识符作为头部X-Trace-ID传递给日志。以下是我目前的代码：

  1. type StdoutLogger struct {
  2.   io.Writer
  3. }
  5. func (l *StdoutLogger) Print(v ...interface{}) {
  6.   vv := LogFormatter(v...)  //这个函数只是美化日志字符串，不会影响功能
  7.   log.Println(vv)
  9.   if len(vv.Message) > 0 {
  10.     slice := vv.Message[0]
  11.     LokiLogs(slice.Sql + " " + slice.SqlMessage)
  12.   }
  13. }
  15. func main() {
  16.    router := gin.Default()
  17.    .
  18.    .
  19.    db.LogMode(true)
  20.    db.SetLogger(&StdoutLogger{os.Stdout})
  21. }
  23. func LokiLogs(msg string) {
  24.   v := strconv.FormatInt(time.Now().UnixNano(), 10)
  26.   msg = msg + " " + "traceId="
  28.   Lokijson := map[string]interface{}{
  29.     "streams": []interface{}{
  30.         map[string]interface{}{
  31.             "stream": map[string]interface{}{
  32.                 "message": msg,
  33.                 "client_ip": GetOutboundIP(),
  34.                 "level": "info",
  35.                 "job":   "Test",
  36.             },
  37.             "values": []interface{}{
  38.                 []interface{}{
  39.                     string(v),
  40.                     msg,
  41.                 },
  42.             },
  43.         },
  44.     },
  45.   }
  47.   jsonValue, _ := json.Marshal(Lokijson)
  48.   url := os.Getenv("LOKI_URL")
  49.   resp, err := http.Post(url, "application/json", bytes.NewBuffer(jsonValue))
  50.   fmt.Println(resp, err)
  51. }

我已经使用一个日志中间件为每个API调用设置了一个名为traceId的头部，类似于c.Request.Header.Set("X-Trace-ID", traceID)。如何将这个traceId值传递给LokiLogs函数，以便它可以连接到msg字符串中，类似于traceId=Some UUID？

英文:

I have a function called LokiLogs which sends logs to the Loki server. I want to add a traceId to the logs that gets passed as a header X-Trace-ID in every API call. Here's the code I have so far:

  1. type StdoutLogger struct {
  2.   io.Writer
  3. }
  5. func (l *StdoutLogger) Print(v ...interface{}) {
  6.   vv := LogFormatter(v...)  //This function is just beautify the log string, it will not affect the functionality
  7.   log.Println(vv)
  9.   if len(vv.Message) > 0 {
  10.     slice := vv.Message[0]
  11.     LokiLogs(slice.Sql + " " + slice.SqlMessage)
  12.   }
  13. }
  15. func main() {
  16.    router := gin.Default()
  17.    .
  18.    .
  19.    db.LogMode(true)
  20.    db.SetLogger(&StdoutLogger{os.Stdout})
  21. }
  23. func LokiLogs(msg string) {
  24.   v := strconv.FormatInt(time.Now().UnixNano(), 10)
  26.   msg = msg + " " + "traceId="
  28.   Lokijson := map[string]interface{}{
  29.     "streams": []interface{}{
  30.         map[string]interface{}{
  31.             "stream": map[string]interface{}{
  32.                 "message": msg,
  33.                 "client_ip": GetOutboundIP(),
  34.                 "level": "info",
  35.                 "job":   "Test",
  36.             },
  37.             "values": []interface{}{
  38.                 []interface{}{
  39.                     string(v),
  40.                     msg,
  41.                 },
  42.             },
  43.         },
  44.     },
  45.   }
  47.   jsonValue, _ := json.Marshal(Lokijson)
  48.   url := os.Getenv("LOKI_URL")
  49.   resp, err := http.Post(url, "application/json", bytes.NewBuffer(jsonValue))
  50.   fmt.Println(resp, err)
  51. }

I have set a traceId header for every API call like this c.Request.Header.Set("X-Trace-ID", traceID) using a log middleware. How can I pass this traceId value to the LokiLogs function so that it can be concatenated to the msg string like this traceId=Some UUID?

答案1

得分: 1

看起来你的db.SetLogger可能来自jinzhu/gorm。那里的Logger接口实际上不允许你通过除了日志记录器实例之外的方式传递额外的细节，所以我认为你需要像这样的东西：

  1. type StdoutLogger struct {
  2.   io.Writer
  3.   TraceID string
  4. }

然后你的gin HandlerFunc需要使用gin.Context中的GetHeader从头部提取信息，并使用该信息构建一个特定于该请求的日志记录器实例，类似于这样：

  1. func (s *mystruct) MyHandler(c *gin.Context) {
  2.   thisTraceID := c.GetHeader("X-Trace-ID")
  3.   ...
  4.   db.SetLogger(&StdoutLogger{Writer: os.Stdout, TraceID: thisTraceID})
  5.   // db.Find/Exec/Save/...
  6. }

然后是

  1. func (l *StdoutLogger) Print(v ...interface{}) {
  2.   vv := LogFormatter(v...)  //这个函数只是美化日志字符串，不会影响功能
  3.   log.Println(vv)
  5.   if len(vv.Message) > 0 {
  6.     slice := vv.Message[0]
  7.     LokiLogs(l.TraceID, slice.Sql + " " + slice.SqlMessage)
  8.   }
  9. }
  11. func LokiLogs(traceID, msg string) {
  12.   ...
  13. }
英文:

It looks like your db.SetLogger is probably from jinzhu/gorm. The Logger interface there doesn't really allow you to pass additional details except through the logger instance, so I think you'd need something a bit like:

  1. type StdoutLogger struct {
  2.   io.Writer
  3.   TraceID string
  4. }

Then your gin HandlerFunc would need to extract the header from gin.Context using GetHeader, and use that to construct a logger instance specific to that request, something like:

  1. func (s *mystruct) MyHandler(c *gin.Context) {
  2.   thisTraceID := c.GetHeader("X-Trace-ID")
  3.   ...
  4.   db.SetLogger(&StdoutLogger{Writer: os.Stdout, TraceID: thisTraceID})
  5.   // db.Find/Exec/Save/...
  6. }

and then

  2. func (l *StdoutLogger) Print(v ...interface{}) {
  3.   vv := LogFormatter(v...)  //This function is just beautify the log string, it will not affect the functionality
  4.   log.Println(vv)
  6.   if len(vv.Message) > 0 {
  7.     slice := vv.Message[0]
  8.     LokiLogs(l.TraceID, slice.Sql + " " + slice.SqlMessage)
  9.   }
  10. }
  12. func LokiLogs(traceID, msg string) {
  13.   ...
  14. }
  15. ```
  17. </details>

huangapple
  • 本文由 发表于 2023年4月25日 13:39:38
  • 转载请务必保留本文链接：https://go.coder-hub.com/76097905.html
  • go
  • go-gin
  • grafana-loki
  • logging
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定