Skip to content

Instantly share code, notes, and snippets.

@rnyrnyrny
Last active April 8, 2025 19:40
Show Gist options
  • Select an option

  • Save rnyrnyrny/282fe705d6e8dc012e482582d7c8ec0b to your computer and use it in GitHub Desktop.

Select an option

Save rnyrnyrny/282fe705d6e8dc012e482582d7c8ec0b to your computer and use it in GitHub Desktop.
log using uber zap and lumberjack
// NOTE
// This gist was created long time ago.
// According to zap's doc, now we can use zapcore.AddSync to directly add lumberjack as a zap sync
// see https://github.com/uber-go/zap/blob/master/FAQ.md#does-zap-support-log-rotation
// So I wrote a new gist if anyone is interested:
// https://gist.github.com/rnyrnyrny/a6dc926ae11951b753ecd66c00695397
// ไธ‹้ข็š„ไปฃ็ ๅทฒ็ป่ฟ‡ๆ—ถไบ†๏ผŒ็Žฐๅœจ็›ดๆŽฅ็”จzapcore.AddSyncๅฐฑ่กŒ๏ผŒๅ‚่€ƒzapๆ–‡ๆกฃ
// thanks to:
// https://studygolang.com/articles/17394
// https://stackoverflow.com/questions/54395407/zap-logging-with-1-customized-config-and-2-lumberjack
package logger
import (
"fmt"
"net/url"
"go.uber.org/zap"
"go.uber.org/zap/zapcore"
lumberjack "gopkg.in/natefinch/lumberjack.v2"
)
const (
// DPanic, Panic and Fatal level can not be set by user
DebugLevelStr string = "debug"
InfoLevelStr string = "info"
WarningLevelStr string = "warning"
ErrorLevelStr string = "error"
)
var (
globalLogger *zap.Logger
devMode bool = false
)
type lumberjackSink struct {
*lumberjack.Logger
}
func (lumberjackSink) Sync() error {
return nil
}
func Init(logLevel string, logFile string, dev bool) error {
devMode = dev
var level zapcore.Level
switch logLevel {
case DebugLevelStr:
level = zap.DebugLevel
case InfoLevelStr:
level = zap.InfoLevel
case WarningLevelStr:
level = zap.WarnLevel
case ErrorLevelStr:
level = zap.ErrorLevel
default:
return fmt.Errorf("unknown log level %s", logLevel)
}
encoderConfig := zapcore.EncoderConfig{
TimeKey: "ts",
LevelKey: "level",
NameKey: "logger",
CallerKey: "caller",
MessageKey: "msg",
StacktraceKey: "stacktrace",
LineEnding: zapcore.DefaultLineEnding,
EncodeLevel: zapcore.LowercaseLevelEncoder,
EncodeTime: zapcore.ISO8601TimeEncoder,
EncodeDuration: zapcore.SecondsDurationEncoder,
EncodeCaller: zapcore.ShortCallerEncoder,
}
ll := lumberjack.Logger{
Filename: logFile,
MaxSize: 1024, //MB
MaxBackups: 30,
MaxAge: 90, //days
Compress: true,
}
zap.RegisterSink("lumberjack", func(*url.URL) (zap.Sink, error) {
return lumberjackSink{
Logger: &ll,
}, nil
})
loggerConfig := zap.Config{
Level: zap.NewAtomicLevelAt(level),
Development: dev,
Encoding: "console",
EncoderConfig: encoderConfig,
OutputPaths: []string{fmt.Sprintf("lumberjack:%s", logFile)},
}
_globalLogger, err := loggerConfig.Build()
if err != nil {
panic(fmt.Sprintf("build zap logger from config error: %v", err))
}
zap.ReplaceGlobals(_globalLogger)
globalLogger = _globalLogger
return nil
}
func NewSugar(name string) *zap.SugaredLogger {
return globalLogger.Named(name).Sugar()
}
@bihe

bihe commented Oct 30, 2020

Copy link
Copy Markdown

๐Ÿ‘

@brownchow

Copy link
Copy Markdown

๐Ÿ‘

@kevinmiao

Copy link
Copy Markdown

๐Ÿ‘

@alc6

alc6 commented Jun 25, 2021

Copy link
Copy Markdown

๐Ÿ‘

@cmsong-shina

Copy link
Copy Markdown

Nice and cool script saved my time.๐Ÿ‘

But globalLogger in line 87 will not be assigned as global variable globalLogger in line 28.

It just shadowing now, and cause panic at here, due to s.base is nil.

It sould be

func Init(logLevel string, logFile string, dev bool) error {
    // ...
    _globalLogger, err := loggerConfig.Build()
	if err != nil {
		panic(fmt.Sprintf("build zap logger from config error: %v", err))
	}
	zap.ReplaceGlobals(_globalLogger)
    globalLogger = _globalLogger
	return nil
}

Isn't it?

@rnyrnyrny

Copy link
Copy Markdown
Author

Nice and cool script saved my time.๐Ÿ‘

But globalLogger in line 87 will not be assigned as global variable globalLogger in line 28.

It just shadowing now, and cause panic at here, due to s.base is nil.

It sould be

func Init(logLevel string, logFile string, dev bool) error {
    // ...
    _globalLogger, err := loggerConfig.Build()
	if err != nil {
		panic(fmt.Sprintf("build zap logger from config error: %v", err))
	}
	zap.ReplaceGlobals(_globalLogger)
    globalLogger = _globalLogger
	return nil
}

Isn't it?

You're right. I've updated the code.

@timdadd

timdadd commented Oct 31, 2021

Copy link
Copy Markdown

ZAP build returns *Logger, error not logger, therefore globalLogger zap.Logger should be a pointer globalLogger *zap.Logger
Or am I missing something?

@rnyrnyrny

Copy link
Copy Markdown
Author

ZAP build returns *Logger, error not logger, therefore globalLogger zap.Logger should be a pointer globalLogger *zap.Logger Or am I missing something?

fixed

@rnyrnyrny

Copy link
Copy Markdown
Author

ZAP build returns *Logger, error not logger, therefore globalLogger zap.Logger should be a pointer globalLogger *zap.Logger Or am I missing something?

fixed

@chinglinwen

chinglinwen commented Nov 17, 2021

Copy link
Copy Markdown

found that, log filename need to prefix lumberjack://, otherwise still calling the fileSink ( which don't do rotate ).

@duanbiaowu

duanbiaowu commented Aug 5, 2022

Copy link
Copy Markdown

The following code works:

package main

import (
	"go.uber.org/zap"
	"go.uber.org/zap/zapcore"
	"gopkg.in/natefinch/lumberjack.v2"
)

func main() {
	lumberJackLogger := &lumberjack.Logger{
		Filename:   "server.log",
		MaxSize:    1,
		MaxBackups: 3,
		MaxAge:     1,
		Compress:   true,
	}

	writeSyncer := zapcore.AddSync(lumberJackLogger)
	encoder := zapcore.NewJSONEncoder(zapcore.EncoderConfig{
		LevelKey:       "L",
		TimeKey:        "T",
		MessageKey:     "M",
		NameKey:        "N",
		CallerKey:      "C",
		FunctionKey:    "F",
		StacktraceKey:  "S",
		LineEnding:     "\r\n",
		EncodeTime:     zapcore.ISO8601TimeEncoder,
		EncodeDuration: zapcore.SecondsDurationEncoder,
		EncodeLevel:    zapcore.LowercaseLevelEncoder,
		EncodeCaller:   zapcore.ShortCallerEncoder,
	})
	core := zapcore.NewCore(encoder, writeSyncer, zapcore.DebugLevel)

	logger := zap.New(core, zap.AddStacktrace(zap.DebugLevel))
	defer func(logger *zap.Logger) {
		_ = logger.Sync()
	}(logger)

	for i := 0; i < 10240; i++ {
		logger.Debug("hello world")
	}

        // Now, you can see some server*.log files
}

@wu0407

wu0407 commented Aug 16, 2022

Copy link
Copy Markdown
writeSyncer := zapcore.AddSync(lumberJackLogger)

๐Ÿ‘

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment