分享
golang日志框架zap简洁配置
aoe5188 · · 3013 次点击 · · 开始浏览这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。
golang日志框架zap简洁配置
$ 前言
- zap是uber开源的一款高性能日志组件框架
$ 配置目标
- 日志按天分割,一天一个文件
- 只保留近七天的日志
- 错误日志输出堆栈
源码
package base
import (
"fmt"
rotatelogs "github.com/lestrrat-go/file-rotatelogs"
"go.uber.org/zap"
"go.uber.org/zap/zapcore"
"io"
"os"
"time"
)
var Log *zap.SugaredLogger
const (
output_dir = "./logs/"
out_path = "foot.log"
err_path = "foot.err"
)
func init() {
_, err := os.Stat(output_dir)
if err != nil {
if os.IsNotExist(err) {
err := os.Mkdir(output_dir, os.ModePerm)
if err != nil {
fmt.Printf("mkdir failed![%v]\n", err)
}
}
}
// 设置一些基本日志格式 具体含义还比较好理解,直接看zap源码也不难懂
encoder := zapcore.NewConsoleEncoder(zapcore.EncoderConfig{
MessageKey: "msg",
LevelKey: "level",
TimeKey: "ts",
//CallerKey: "file",
CallerKey: "caller",
StacktraceKey: "trace",
LineEnding: zapcore.DefaultLineEnding,
EncodeLevel: zapcore.LowercaseLevelEncoder,
//EncodeLevel: zapcore.CapitalLevelEncoder,
EncodeCaller: zapcore.ShortCallerEncoder,
EncodeTime: func(t time.Time, enc zapcore.PrimitiveArrayEncoder) {
enc.AppendString(t.Format("2006年01月02日 15:04:05"))
},
//EncodeDuration: zapcore.SecondsDurationEncoder,
EncodeDuration: func(d time.Duration, enc zapcore.PrimitiveArrayEncoder) {
enc.AppendInt64(int64(d) / 1000000)
},
})
// 实现两个判断日志等级的interface
infoLevel := zap.LevelEnablerFunc(func(lvl zapcore.Level) bool {
return true
})
warnLevel := zap.LevelEnablerFunc(func(lvl zapcore.Level) bool {
return lvl >= zapcore.WarnLevel
})
// 获取 info、warn日志文件的io.Writer 抽象 getWriter() 在下方实现
infoHook_1 := os.Stdout
infoHook_2 := getWriter(out_path)
errorHook := getWriter(err_path)
// 最后创建具体的Logger
core := zapcore.NewTee(
zapcore.NewCore(encoder, zapcore.AddSync(infoHook_1), infoLevel),
zapcore.NewCore(encoder, zapcore.AddSync(infoHook_2), infoLevel),
zapcore.NewCore(encoder, zapcore.AddSync(errorHook), warnLevel),
)
// 需要传入 zap.AddCaller() 才会显示打日志点的文件名和行数, 有点小坑
logger := zap.New(core, zap.AddCaller(), zap.AddStacktrace(zap.ErrorLevel))
Log = logger.Sugar()
defer logger.Sync()
}
func getWriter(filename string) io.Writer {
// 生成rotatelogs的Logger 实际生成的文件名 demo.log.YYmmddHH
// demo.log是指向最新日志的链接
// 保存7天内的日志,每1小时(整点)分割一次日志
hook, err := rotatelogs.New(
// 没有使用go风格反人类的format格式
output_dir+filename+".%Y%m%d",
rotatelogs.WithLinkName(filename),
rotatelogs.WithMaxAge(time.Hour*24*7),
rotatelogs.WithRotationTime(time.Hour*24),
)
if err != nil {
panic(err)
}
return hook
}
使用
package main
import "tesou.io/platform/foot-parent/foot-api/common/base"
func main() {
base.Log.Info("日志1")
base.Log.Info("日志2")
base.Log.Error("错误的日志")
base.Log.Info("日志3")
}
有疑问加站长微信联系(非本文作者)
入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889
关注微信3013 次点击 ∙ 1 赞
被以下专栏收入,发现更多相似内容
添加一条新回复
(您需要 后才能回复 没有账号 ?)
- 请尽量让自己的回复能够对别人有帮助
- 支持 Markdown 格式, **粗体**、~~删除线~~、
`单行代码` - 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
- 图片支持拖拽、截图粘贴等方式上传
收入到我管理的专栏 新建专栏
golang日志框架zap简洁配置
$ 前言
- zap是uber开源的一款高性能日志组件框架
$ 配置目标
- 日志按天分割,一天一个文件
- 只保留近七天的日志
- 错误日志输出堆栈
源码
package base
import (
"fmt"
rotatelogs "github.com/lestrrat-go/file-rotatelogs"
"go.uber.org/zap"
"go.uber.org/zap/zapcore"
"io"
"os"
"time"
)
var Log *zap.SugaredLogger
const (
output_dir = "./logs/"
out_path = "foot.log"
err_path = "foot.err"
)
func init() {
_, err := os.Stat(output_dir)
if err != nil {
if os.IsNotExist(err) {
err := os.Mkdir(output_dir, os.ModePerm)
if err != nil {
fmt.Printf("mkdir failed![%v]\n", err)
}
}
}
// 设置一些基本日志格式 具体含义还比较好理解,直接看zap源码也不难懂
encoder := zapcore.NewConsoleEncoder(zapcore.EncoderConfig{
MessageKey: "msg",
LevelKey: "level",
TimeKey: "ts",
//CallerKey: "file",
CallerKey: "caller",
StacktraceKey: "trace",
LineEnding: zapcore.DefaultLineEnding,
EncodeLevel: zapcore.LowercaseLevelEncoder,
//EncodeLevel: zapcore.CapitalLevelEncoder,
EncodeCaller: zapcore.ShortCallerEncoder,
EncodeTime: func(t time.Time, enc zapcore.PrimitiveArrayEncoder) {
enc.AppendString(t.Format("2006年01月02日 15:04:05"))
},
//EncodeDuration: zapcore.SecondsDurationEncoder,
EncodeDuration: func(d time.Duration, enc zapcore.PrimitiveArrayEncoder) {
enc.AppendInt64(int64(d) / 1000000)
},
})
// 实现两个判断日志等级的interface
infoLevel := zap.LevelEnablerFunc(func(lvl zapcore.Level) bool {
return true
})
warnLevel := zap.LevelEnablerFunc(func(lvl zapcore.Level) bool {
return lvl >= zapcore.WarnLevel
})
// 获取 info、warn日志文件的io.Writer 抽象 getWriter() 在下方实现
infoHook_1 := os.Stdout
infoHook_2 := getWriter(out_path)
errorHook := getWriter(err_path)
// 最后创建具体的Logger
core := zapcore.NewTee(
zapcore.NewCore(encoder, zapcore.AddSync(infoHook_1), infoLevel),
zapcore.NewCore(encoder, zapcore.AddSync(infoHook_2), infoLevel),
zapcore.NewCore(encoder, zapcore.AddSync(errorHook), warnLevel),
)
// 需要传入 zap.AddCaller() 才会显示打日志点的文件名和行数, 有点小坑
logger := zap.New(core, zap.AddCaller(), zap.AddStacktrace(zap.ErrorLevel))
Log = logger.Sugar()
defer logger.Sync()
}
func getWriter(filename string) io.Writer {
// 生成rotatelogs的Logger 实际生成的文件名 demo.log.YYmmddHH
// demo.log是指向最新日志的链接
// 保存7天内的日志,每1小时(整点)分割一次日志
hook, err := rotatelogs.New(
// 没有使用go风格反人类的format格式
output_dir+filename+".%Y%m%d",
rotatelogs.WithLinkName(filename),
rotatelogs.WithMaxAge(time.Hour*24*7),
rotatelogs.WithRotationTime(time.Hour*24),
)
if err != nil {
panic(err)
}
return hook
}
使用
package main
import "tesou.io/platform/foot-parent/foot-api/common/base"
func main() {
base.Log.Info("日志1")
base.Log.Info("日志2")
base.Log.Error("错误的日志")
base.Log.Info("日志3")
}