Uber Zap Logger:如何用字符串在每个日志条目前面添加
我正在使用我的应用程序作为SystemD服务，并且需要为JournalD添加一个入门级<LEVEL>，例如：
<6> this is info
<7> this is debug
<4> this is warning否则，JournalD将所有条目处理为相同的级别，我希望使用它的高级功能只显示一定级别的日志。
如何使用uber-zap库为每个日志条目加上正确的级别标签(比如，对于信息，它将是<6>)？
编辑:这是我的记录器配置的相关部分：
var config zap.Config
if production {
config = zap.NewProductionConfig()
config.Encoding = `console`
config.EncoderConfig.TimeKey = "" // no time as SystemD adds timestamp
} else {
config = zap.NewDevelopmentConfig()
}
config.DisableStacktrace = true
config.EncoderConfig.EncodeLevel = zapcore.CapitalColorLevelEncoder // colors
config.OutputPaths = []string{"stdout"}回答 1
Stack Overflow用户
发布于 2021-12-27 07:52:27
您可以使用嵌入zapcore.Encoder的自定义编码器。
嵌入编码器可以“免费”实现所有方法，配置与现在的配置相同。然后，您只能使用所需的附加逻辑实现EncodeEntry。
注意:如果您计划使用结构化日志记录(例如logger.With() )，则仍然需要实现Clone()。更多信息：Why custom encoding is lost after calling logger.With in Uber Zap?
回到您的主要问题，这是一个工作示例；请参阅代码中的注释以获得更多解释：
type prependEncoder struct {
// embed a zapcore encoder
// this makes prependEncoder implement the interface without extra work
zapcore.Encoder
// zap buffer pool
pool buffer.Pool
}
// implementing only EncodeEntry
func (e *prependEncoder) EncodeEntry(entry zapcore.Entry, fields []zapcore.Field) (*buffer.Buffer, error) {
// new log buffer
buf := e.pool.Get()
// prepend the JournalD prefix based on the entry level
buf.AppendString(e.toJournaldPrefix(entry.Level))
buf.AppendString(" ")
// calling the embedded encoder's EncodeEntry to keep the original encoding format
consolebuf, err := e.Encoder.EncodeEntry(entry, fields)
if err != nil {
return nil, err
}
// just write the output into your own buffer
_, err = buf.Write(consolebuf.Bytes())
if err != nil {
return nil, err
}
return buf, nil
}
// some mapper function
func (e *prependEncoder) toJournaldPrefix(lvl zapcore.Level) string {
switch lvl {
case zapcore.DebugLevel:
return "<7>"
case zapcore.InfoLevel:
return "<6>"
case zapcore.WarnLevel:
return "<4>"
}
return ""
}稍后，您将使用自定义编码器构造具有自定义核心的记录器。您使用现在使用的相同的编码器初始化嵌入式字段。下面看到的选项模拟了当前的选项。
package main
import (
"go.uber.org/zap"
"go.uber.org/zap/buffer"
"go.uber.org/zap/zapcore"
"os"
)
func getConfig() zap.Config {
// your current config options
return config
}
func main() {
cfg := getConfig()
// constructing our prependEncoder with a ConsoleEncoder using your original configs
enc := &prependEncoder{
Encoder: zapcore.NewConsoleEncoder(cfg.EncoderConfig),
pool: buffer.NewPool(),
}
logger := zap.New(
zapcore.NewCore(
enc,
os.Stdout,
zapcore.DebugLevel,
),
// this mimics the behavior of NewProductionConfig.Build
zap.ErrorOutput(os.Stderr),
)
logger.Info("this is info")
logger.Debug("this is debug")
logger.Warn("this is warn")
}测试运行输出(INFO以蓝色打印，调试用粉红色，警告以黄色，如您的zapcore.CapitalColorLevelEncoder)：
<6> INFO this is info
<7> DEBUG this is debug
<4> WARN this is warnhttps://stackoverflow.com/questions/70489167
复制相似问题
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号