zoukankan      html  css  js  c++  java
  • zap+日志分级分文件+按时间切割日志整合demo

    实现功能

        info debug 级别的日志输出到 /path/log/demo.log
        warn error .... 级别的日志输出到 /path/log/demo_error.log
        日志自动按小时分割 最多保留7天的日志

    依赖的第三方包github地址

        https://github.com/uber-go/zap

        https://github.com/lestrrat-go/file-rotatelogs

    ​    zap提供日志分级,打点key-value参数等功能,而file-foratelogs则提供日志自动按时间分割的功能,github上star数比较多的 https://github.com/natefinch/lumberjack 也提供类似功能,但是是根据文件大小分片,感觉除非借助其他工具,否则找某个时间点的日志时,体验可能不是那么友好。

    demo代码

    package demo
    
    import (
        rotatelogs "github.com/lestrrat-go/file-rotatelogs"
        "go.uber.org/zap"
        "go.uber.org/zap/zapcore"
    )
    
    var Logger *zap.Logger
    
    func init() {
        // 设置一些基本日志格式 具体含义还比较好理解,直接看zap源码也不难懂
        encoder := zapcore.NewConsoleEncoder(zapcore.EncoderConfig{
            MessageKey:  "msg",
            LevelKey:    "level",
            EncodeLevel: zapcore.CapitalLevelEncoder,
            TimeKey:     "ts",
            EncodeTime: func(t time.Time, enc zapcore.PrimitiveArrayEncoder) {
                enc.AppendString(t.Format("2006-01-02 15:04:05"))
            },  
            CallerKey:    "file",
            EncodeCaller: zapcore.ShortCallerEncoder,
            EncodeDuration: func(d time.Duration, enc zapcore.PrimitiveArrayEncoder) {
                enc.AppendInt64(int64(d) / 1000000)
            },  
        })
        
        // 实现两个判断日志等级的interface
        infoLevel := zap.LevelEnablerFunc(func(lvl zapcore.Level) bool {
            return lvl < zapcore.WarnLevel
        })
        
        warnLevel := zap.LevelEnablerFunc(func(lvl zapcore.Level) bool {
            return lvl >= zapcore.WarnLevel
        })
        
        // 获取 info、warn日志文件的io.Writer 抽象 getWriter() 在下方实现
        infoWriter := getWriter("/path/log/demo.log")
        warnWriter := getWriter("/path/log/demo_error.log")
        
        // 最后创建具体的Logger
        core := zapcore.NewTee(
            zapcore.NewCore(*encoder, zapcore.AddSync(infoHook), infoLevel),
            zapcore.NewCore(*encoder, zapcore.AddSync(warnHook), warnLevel),
        )
        
        Logger = zap.New(core, zap.AddCaller())  // 需要传入 zap.AddCaller() 才会显示打日志点的文件名和行数, 有点小坑
    }
    
    func getWriter(filename string) io.Writer {
        // 生成rotatelogs的Logger 实际生成的文件名 demo.log.YYmmddHH
        // demo.log是指向最新日志的链接
        // 保存7天内的日志,每1小时(整点)分割一次日志
        hook, err := rotatelogs.New(
            filename+".%Y%m%d%H", // 没有使用go风格反人类的format格式
            rotatelogs.WithLinkName(filename),
            rotatelogs.WithMaxAge(time.Hour*24*7),
            rotatelogs.WithRotationTime(time.Hour),
        )   
    
        if err != nil {
            panic(err)
        }   
        return hook
    }
    

    ​    zap.NewCore接收的参数是io.Writer而不是自己包的struct,开发者可以按需传入自己需要的io.Writer 挺好。

  • 相关阅读:
    OrCAD原理图封装规则
    web的脚本安全-CSRF
    web的脚本安全-XSS
    数据库中左右连接
    如何解决Java.lang.NoClassDefFoundError
    css垂直居中
    网上免费的web service地址
    JS 正则表达式用法
    jQuery实现滚动条向下拉到一定的程度,然后这层就一直占着不管滚动条如何向下拉都不动了的效果
    Robot Framework + Selenium2Library环境下,结合Selenium Grid实施分布式自动化测试
  • 原文地址:https://www.cnblogs.com/ExMan/p/12264925.html
Copyright © 2011-2022 走看看