是否可以在运行时更新 zap 记录器的日志级别?
Is it possible to update the log level of a zap logger at runtime?
我用 kubebuilder
创建了一个记录器,它基于 zap 记录器:
import (
"flag"
"github.com/gin-gonic/gin"
"net/http"
"os"
"go.uber.org/zap/zapcore"
uzap "go.uber.org/zap"
// Import all Kubernetes client auth plugins (e.g. Azure, GCP, OIDC, etc.)
// to ensure that exec-entrypoint and run can make use of them.
_ "k8s.io/client-go/plugin/pkg/client/auth"
"k8s.io/apimachinery/pkg/runtime"
utilruntime "k8s.io/apimachinery/pkg/util/runtime"
clientgoscheme "k8s.io/client-go/kubernetes/scheme"
ctrl "sigs.k8s.io/controller-runtime"
"sigs.k8s.io/controller-runtime/pkg/healthz"
"sigs.k8s.io/controller-runtime/pkg/log/zap"
)
var (
scheme = runtime.NewScheme()
setupLog = ctrl.Log.WithName("setup")
)
var zapOpts []uzap.Option
zapOpts = append(zapOpts, uzap.AddCaller())
zapOpts = append(zapOpts, uzap.AddCallerSkip(1))
zapOpts = append(zapOpts, uzap.AddStacktrace(uzap.DebugLevel))
opts := zap.Options{
Development: developmentFlag,
StacktraceLevel: stacktraceLevel,
Level: level,
Encoder: encoder,
ZapOpts: zapOpts,
}
opts.BindFlags(flag.CommandLine)
flag.Parse()
ctrl.SetLogger(zap.New(zap.UseFlagOptions(&opts)))
现在我想在 运行 时将日志级别更改为 zapcore.InfoLevel
。我没有找到任何 SetLogLevel
或类似的 API.
我需要创建新的选项然后设置新级别吗?
我还需要使用 sigs.k8s.io/controller-runtime/pkg/log/zap
库设置记录器。记录器的接口来自 go-logr
,它实现了 logr.Logger
接口。如果我尝试将其更改为 zapcore.NewCore
,那么我将无法再使用 ctrl.SetLogger
设置记录器。
我想保留选项以更新 zap.Options
的所有选项并更改日志级别,并且仍然使用来自 sigs.k8s.io/controller-runtime/pkg/log/zap
的 zap。
是否可以用
sigs.k8s.io/controller-runtime/pkg/log/zap
和 sigs.k8s.io/controller-runtime
?
更好的答案:作为,使用zap.AtomicLevel
。有关详细信息,请参阅他们的回答。
另一种选择是创建一个带有自定义 LevelEnabler
函数的核心。您可以使用 zap.LevelEnablerFunc
to convert a closure to a zapcore.LevelEnabler
.
相关文档:
LevelEnabler decides whether a given logging level is enabled when logging a message.
LevelEnablerFunc is a convenient way to implement zapcore.LevelEnabler with an anonymous function.
然后该函数可能 return true
或 false
基于在 运行 时间发生变化的一些其他变量:
// will be actually initialized and changed at run time
// based on your business logic
var infoEnabled bool
errorUnlessEnabled := zap.LevelEnablerFunc(func(level zapcore.Level) bool {
// true: log message at this level
// false: skip message at this level
return level >= zapcore.ErrorLevel || infoEnabled
})
core := zapcore.NewCore(
zapcore.NewJSONEncoder(zap.NewProductionEncoderConfig()),
os.Stdout,
errorUnlessEnabled,
)
logger := zap.New(core)
logger.Info("foo") // not logged
infoEnabled = true
logger.Info("foo again") // logged
PS:这段代码是人为设计的。您的程序将必须在 运行 时间执行初始化、值更改以及对 infoEnabled
变量进行适当的同步(如果需要)。
您可以 运行 操场上的这个例子:https://play.golang.org/p/oT3nvnP1Bwc
是 it is possible 使用 AtomicLevel
。来自文档:
atom := zap.NewAtomicLevel()
// To keep the example deterministic, disable timestamps in the output.
encoderCfg := zap.NewProductionEncoderConfig()
encoderCfg.TimeKey = ""
logger := zap.New(zapcore.NewCore(
zapcore.NewJSONEncoder(encoderCfg),
zapcore.Lock(os.Stdout),
atom,
))
defer logger.Sync()
logger.Info("info logging enabled")
atom.SetLevel(zap.ErrorLevel)
logger.Info("info logging disabled")
我用 kubebuilder
创建了一个记录器,它基于 zap 记录器:
import (
"flag"
"github.com/gin-gonic/gin"
"net/http"
"os"
"go.uber.org/zap/zapcore"
uzap "go.uber.org/zap"
// Import all Kubernetes client auth plugins (e.g. Azure, GCP, OIDC, etc.)
// to ensure that exec-entrypoint and run can make use of them.
_ "k8s.io/client-go/plugin/pkg/client/auth"
"k8s.io/apimachinery/pkg/runtime"
utilruntime "k8s.io/apimachinery/pkg/util/runtime"
clientgoscheme "k8s.io/client-go/kubernetes/scheme"
ctrl "sigs.k8s.io/controller-runtime"
"sigs.k8s.io/controller-runtime/pkg/healthz"
"sigs.k8s.io/controller-runtime/pkg/log/zap"
)
var (
scheme = runtime.NewScheme()
setupLog = ctrl.Log.WithName("setup")
)
var zapOpts []uzap.Option
zapOpts = append(zapOpts, uzap.AddCaller())
zapOpts = append(zapOpts, uzap.AddCallerSkip(1))
zapOpts = append(zapOpts, uzap.AddStacktrace(uzap.DebugLevel))
opts := zap.Options{
Development: developmentFlag,
StacktraceLevel: stacktraceLevel,
Level: level,
Encoder: encoder,
ZapOpts: zapOpts,
}
opts.BindFlags(flag.CommandLine)
flag.Parse()
ctrl.SetLogger(zap.New(zap.UseFlagOptions(&opts)))
现在我想在 运行 时将日志级别更改为 zapcore.InfoLevel
。我没有找到任何 SetLogLevel
或类似的 API.
我需要创建新的选项然后设置新级别吗?
我还需要使用 sigs.k8s.io/controller-runtime/pkg/log/zap
库设置记录器。记录器的接口来自 go-logr
,它实现了 logr.Logger
接口。如果我尝试将其更改为 zapcore.NewCore
,那么我将无法再使用 ctrl.SetLogger
设置记录器。
我想保留选项以更新 zap.Options
的所有选项并更改日志级别,并且仍然使用来自 sigs.k8s.io/controller-runtime/pkg/log/zap
的 zap。
是否可以用
sigs.k8s.io/controller-runtime/pkg/log/zap
和 sigs.k8s.io/controller-runtime
?
更好的答案:作为zap.AtomicLevel
。有关详细信息,请参阅他们的回答。
另一种选择是创建一个带有自定义 LevelEnabler
函数的核心。您可以使用 zap.LevelEnablerFunc
to convert a closure to a zapcore.LevelEnabler
.
相关文档:
LevelEnabler decides whether a given logging level is enabled when logging a message.
LevelEnablerFunc is a convenient way to implement zapcore.LevelEnabler with an anonymous function.
然后该函数可能 return true
或 false
基于在 运行 时间发生变化的一些其他变量:
// will be actually initialized and changed at run time
// based on your business logic
var infoEnabled bool
errorUnlessEnabled := zap.LevelEnablerFunc(func(level zapcore.Level) bool {
// true: log message at this level
// false: skip message at this level
return level >= zapcore.ErrorLevel || infoEnabled
})
core := zapcore.NewCore(
zapcore.NewJSONEncoder(zap.NewProductionEncoderConfig()),
os.Stdout,
errorUnlessEnabled,
)
logger := zap.New(core)
logger.Info("foo") // not logged
infoEnabled = true
logger.Info("foo again") // logged
PS:这段代码是人为设计的。您的程序将必须在 运行 时间执行初始化、值更改以及对 infoEnabled
变量进行适当的同步(如果需要)。
您可以 运行 操场上的这个例子:https://play.golang.org/p/oT3nvnP1Bwc
是 it is possible 使用 AtomicLevel
。来自文档:
atom := zap.NewAtomicLevel()
// To keep the example deterministic, disable timestamps in the output.
encoderCfg := zap.NewProductionEncoderConfig()
encoderCfg.TimeKey = ""
logger := zap.New(zapcore.NewCore(
zapcore.NewJSONEncoder(encoderCfg),
zapcore.Lock(os.Stdout),
atom,
))
defer logger.Sync()
logger.Info("info logging enabled")
atom.SetLevel(zap.ErrorLevel)
logger.Info("info logging disabled")