Kratos 日志

日志

Logging 中間件用于打印服務(wù)收到或發(fā)起的請求詳情。

使用方法

grpc server

在 ?grpc.ServerOption? 中引入 ?logging.Server()?, 則會在每次收到 gRPC 請求的時候打印詳細(xì)請求信息。

logger := log.DefaultLogger
var opts = []grpc.ServerOption{
    grpc.Middleware(
        logging.Server(logger),
    ),
}
srv := grpc.NewServer(opts...)

grpc client

在 ?grpc.WithMiddleware? 中引入 ?logging.Client()?, 則會在每次發(fā)起 grpc 請求的時候打印詳細(xì)請求信息。

logger := log.DefaultLogger
conn, err := transgrpc.DialInsecure(
    context.Background(),
    grpc.WithEndpoint("127.0.0.1:9000"),
     grpc.WithMiddleware(
        logging.Client(logger),
    ),
)

http server

在 ?http.ServerOption? 中引入 ?logging.Server()?, 則會在每次收到 Http 請求的時候打印詳細(xì)請求信息。

logger := log.DefaultLogger
var opts = []http.ServerOption{
    http.Middleware(
        logging.Server(logger),
    ),
}
srv := http.NewServer(opts...)

http client

在 ?http.WithMiddleware? 中引入 ?logging.Client()?, 則會在每次發(fā)起 Http 請求的時候打印詳細(xì)請求信息。

logger := log.DefaultLogger
conn, err := http.NewClient(
    context.Background(),
    http.WithMiddleware(
        logging.Client(logger),
    ),
    http.WithEndpoint("127.0.0.1:8000"),
)

Logging 中間件在server 中只打印 trace_id 不采集數(shù)據(jù)

grpc-server internal/server/grpc.go

exporter, err := stdouttrace.New(stdouttrace.WithWriter(ioutil.Discard))
if err != nil {
    fmt.Printf("creating stdout exporter: %v", err)
    panic(err)
}
tp := tracesdk.NewTracerProvider(
    tracesdk.WithBatcher(exporter),
    tracesdk.WithResource(resource.NewSchemaless(
        semconv.ServiceNameKey.String(Name)),
    ))
var opts = []grpc.ServerOption{
        grpc.Middleware(
            tracing.Server(tracing.WithTracerProvider(tp)),
        ),
    }
srv := grpc.NewServer(opts...)

日志增加trace_id字段 cmd/項(xiàng)目名/main.go

logger := log.With(log.NewStdLogger(os.Stdout),
        "ts", log.DefaultTimestamp,
        "caller", log.DefaultCaller,
        "service.id", id,
        "service.name", Name,
        "service.version", Version,
        "trace_id", tracing.TraceID(),
        "span_id", tracing.SpanID(),
    )

日志打印trace_id

log.WithContext(ctx).Errorf("創(chuàng)建xxx失敗: %s", err)