Kratos 漫游指南 3

本篇讲讲Kratos日志组件的使用方式。

在服务上线后，我们可以使用日志来观察程序的行为、诊断问题或者配置相应的告警等。定义良好的结构化日志，能够提高日志的检索效率，使处理问题变得更加方便。

设计理念

为了方便使用，Kratos定义了两个层面的抽象，Logger统一了日志的接入方式，Helper接口统一的日志库的调用方式。

在不同的公司、使用不同的基础架构，可能对日志的打印方式、格式、输出的位置等要求各有不同。Kratos为了更加灵活地适配和迁移到各种环境，把日志组件也进行了抽象，这样就可以把业务代码里日志的使用，和日志底层具体的实现隔离开来，提高整体的可维护性。

Kratos的日志库主要有如下特性：

Logger用于对接各种日志库或日志平台，可以用现成的或者自己实现
Helper是在您的项目代码中实际需要调用的，用于在业务代码里打日志
Filter用于对输出日志进行过滤或魔改（通常用于日志脱敏）
Valuer用于绑定一些全局的固定值或动态值（比如时间戳、traceID或者实例id之类的东西）到输出日志中

Helper - 在项目代码中打日志

Helper：高级日志接口，提供了一系列带有日志等级和格式化方法的帮助函数，通常业务逻辑中建议使用这个，能够简化日志代码。

你可以认为它是一个对Logger的包装，简化了打印时需要传入的参数。

它的用法基本上是下面的样子，后面会介绍具体的使用方法

helper.Info("hello")
helper.Errorf("hello %s", "eric")

Logger - 适配各种日志输出方式

Logger：这个是底层日志接口，用于快速适配各种日志库到框架中来，仅需要实现一个最简单的Log方法。

type Logger interface {
	Log(level Level, keyvals ...interface{}) error
}

Level参数用来标识日志的等级，可以在level.go中找到。

keyvals是一个平铺的键值数组，它的长度需要是偶数，奇数位上的是key，偶数位上的是value。

这个Logger接口在实现完毕后的使用，简单来讲就是如下的样子：

logger.Log(log.LevelInfo, "msg", "hello", "instance_id", 123)

很显然,直接用它有点难受，所以我们建议在项目中用Helper。

它的意义在于，通过简单使用Logger接口，能够快速把您的日志库适配进来，并且用Helper来统一打印的行为。

日志等级

对于日志等级的定义在level.go中，您可以在使用底层的Log方法时传入它们，它们会被输出到日志的level字段中。在高级接口Helper使用特定的带日志等级的方法比如.Infof等，会自动应用等级，无需自己绑定等级。

log.LevelDebug
log.LevelInfo
log.LevelWarn
log.LevelError
log.LevelFatal

适配实现

我们已经在contrib/log实现好了一些插件，用于适配目前常用的日志库，您也可以参考它们的代码来实现自己需要的日志库的适配：

std 标准输出，Kratos内置
fluent 输出到fluentd
zap 适配了uber的zap日志库

使用

Kratos日志库使用十分简单，和大部分日志库类似。

DefaultLogger 默认logger

如果觉得创建logger很麻烦，可以直接用框架默认初始化好的log.DefaultLogger实例，它底层直接调用了go标准库的log，可以打到标准输出。

stdLogger

框架内置实现了stdLogger，能够打印到标准输出。使用NewStdLogger方法传入一个io.Writer即可。

初始化

首先你需要创建一个Logger，这里可以选：自带的std打印到标准输出，或者在contrib下面找一个已经实现好的适配，或者用自己实现的Logger。

import "github.com/go-kratos/kratos/v2/log"

h := NewHelper(yourlogger)

//用默认logger可以直接用
h := NewHelper(log.DefaultLogger)

或者在contrib/log里面找一个插件用，比如这里我们想用fluentd：

import "github.com/go-kratos/kratos/contrib/log/fluent/v2"

logger, err := fluent.NewLogger("unix:///var/run/fluent/fluent.sock")
if err != nil {
	return 
}
h := log.NewHelper(logger)

您可以指定默认的日志打印到的字段，不设的话默认为msg

NewHelper(logger, WithMessageKey("message"))

打印日志

注意：调用Fatal等级的方法会在打印日志后中断程序运行，请谨慎使用。

直接打印不同等级的日志，会默认打到messageKey里,默认是msg

h.Debug("Are you OK?")
h.Info("42 is the answer to life, the universe, and everything")
h.Warn("We are under attack!")
h.Error("Houston, we have a problem.")
h.Fatal("So Long, and Thanks for All the Fish.")

格式化打印不同等级的日志，方法都以f结尾

h.Debugf("Hello %s", "boy")
h.Infof("%d is the answer to life, the universe, and everything", 233)
h.Warnf("We are under attack %s!", "boss")
h.Errorf("%s, we have a problem.", "Master Shifu")
h.Fatalf("So Long, and Thanks for All the %s.", "banana")

格式化打印不同等级的日志，方法都以w结尾，参数为key value对，可以输入多组。

h.Debugw("custom_key", "Are you OK?")
h.Infow("custom_key", "42 is the answer to life, the universe, and everything")
h.Warnw("custom_key", "We are under attack!")
h.Errorw("custom_key", "Houston, we have a problem.")
h.Fatalw("custom_key", "So Long, and Thanks for All the Fish.")

使用底层的Log接口直接打印key和value

h.Log(log.LevelInfo, "key1", "value1")

Valuer 设置全局字段

在业务日志中，通常我们会在每条日志中输出一些全局的字段，比如时间戳，实例id，追踪id，用户id，调用函数名等，显然在每条日志中手工写入这些值很麻烦。为了解决这个问题，可以使用Valuer。您可以认为它是logger的“中间件”，用它来打一些全局的信息到日志里。

log.With方法会返回一个新的Logger，把参数的Valuer绑上去。

注意要按照key,value的顺序对应写入参数。

使用方法如下：

logger = log.With(logger, "ts", log.DefaultTimestamp, "caller", log.DefaultCaller)

框架默认提供了如下Valuer供使用，您也可以参考它们的代码实现自定义Valuer。

log.Caller 打印出调用日志方法的文件名和函数名
log.Timestamp 打印时间戳
tracing.TraceID 打印TraceID
tracing.SpanID 打印SpanID

Filter 日志过滤

有时日志中可能会有敏感信息，需要进行脱敏，或者只打印级别高的日志，这时候就可以使用Filter来对日志的输出进行一些过滤操作，通常用法是使用Filter来包装原始的Logger，用来创建Helper使用。

它提供了如下参数：

FilterLevel 按照日志等级过滤，低于该等级的日志将不会被输出。例如这里传入FilterLevel(log.LevelError)，则debug/info/warn日志都会被过滤掉不会输出，error和fatal正常输出。
FilterKey(key ...string) FilterOption 按照key过滤，这些key的值会被***遮蔽
FilterValue(value ...string) FilterOption 按照value过滤，匹配的值会被***遮蔽
FilterFunc(f func(level Level, keyvals ...interface{}) bool) 使用自定义的函数来对日志进行处理，keyvals里为key和对应的value，按照奇偶进行读取即可

h := NewHelper(
	NewFilter(logger,
		// 等级过滤
		FilterLevel(log.LevelError),

		// 按key遮蔽
		FilterKey("username"),

		// 按value遮蔽
		FilterValue("hello"),

		// 自定义过滤函数
		FilterFunc(
			func (level Level, keyvals ...interface{}) bool {
				if level == LevelWarn {
					return true
				}
				for i := 0; i < len(keyvals); i++ {
					if keyvals[i] == "password" {
						keyvals[i+1] = fuzzyStr
					}
				}
				return false
			}
		),
	),
)

h.Log(log.LevelDebug, "msg", "test debug")
h.Info("hello")
h.Infow("password", "123456")
h.Infow("username", "kratos")
h.Warn("warn log")

绑定context

设置context，使用如下方法将返回一个绑定指定context的helper实例

newHelper := h.WithContext(ctx)

请求日志中间件

我们在middleware/logging提供了一个日志中间件，使用它可以记录server端或client端每个请求的路由、参数、耗时等信息。使用时建议配合Filter对请求参数日志进行脱敏，避免敏感信息泄漏。

这个middleware的代码也十分清晰地展示了如何在中间件里获取和处理请求和返回信息，具有很大的参考价值，您可以基于它的代码实现自己的日志中间件等。

kratos-layout

在我们的默认项目模板中，我们在cmd/server/main.go的main()函数，即程序入口处初始化了logger实例，并注入了一些全局的日志值，它们会被打到所有输出的日志中。

您可以修改这里使用的logger，来进行自定义打印的值，或者更换为自己需要的logger实现。

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(),
)

这个logger将通过依赖注入工具wire的生成，注入到项目的各层中，供其内部使用。

一个具体的内部使用例子可以参考internal/service/greeter.go

我们在这里将注入进来的logger实例，用log.NewHelper包装成Helper，绑定到service上，这样就可以在这一层调用这个绑定的的helper对象来打日志了。

func NewGreeterService(uc *biz.GreeterUsecase, logger log.Logger) *GreeterService {
	return &GreeterService{uc: uc, log: log.NewHelper(logger)} // 初始化和绑定helper
}

func (s *GreeterService) SayHello(ctx context.Context, in *v1.HelloRequest) (*v1.HelloReply, error) {
	// 打印日志
	s.log.WithContext(ctx).Infof("SayHello Received: %v", in.GetName())

	return &v1.HelloReply{Message: "Hello " + in.GetName()}, nil
}

其它几个层级的初始化和使用方式也是一样的，在biz层和data层中我们也给了logger注入的样例，您可以进行参考。

参考

kratos log文档

注意：本系列内容为go-kratos项目官方文档的beta版，首发在『farer.org』，『Go语言进阶公众号』，在发布一段时间后会被整合进官方文档中，内容的后续迭代在官方文档中进行，如果发现文档内容与本文一致请勿惊慌。