卓越飞翔博客卓越飞翔博客

卓越飞翔 - 您值得收藏的技术分享站
技术文章34487本站已运行393

是否可以在运行时更新 zap 记录器的日志级别?

是否可以在运行时更新 zap 记录器的日志级别?

php小编西瓜在运行时更新zap记录器的日志级别是一个常见的需求。zap是一个强大的日志记录工具,可以帮助我们捕获和记录应用程序的运行信息。通常情况下,我们需要在应用程序启动时设置zap的日志级别,但是有时候我们希望能够在运行时动态地更新日志级别,以便根据实际需要进行调整。在zap中,我们可以通过使用zap的Logger接口提供的方法来实现这个功能。具体来说,我们可以使用`zap.Info()`、`zap.Debug()`、`zap.Warn()`等方法来动态地更新日志级别。这样,我们就可以根据需要在运行时灵活地调整zap的日志记录行为了。

问题内容

我使用 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/zapsigs.k8s.io/controller-runtime

解决方法

更好的答案:按照@oliver dain的建议,使用 zap.atomiclevel。有关详细信息,请参阅他们的回答。

另一个选项是使用自定义 levelenabler 函数创建核心。您可以使用 zap.levelenablerfunc 将闭包转换为 zapcore.levelenabler

相关文档:

levelenabler 决定在记录消息时是否启用给定的日志记录级别。

levelenablerfunc 是使用匿名函数实现 zapcore.levelenabler 的便捷方法。

该函数可能会根据运行时更改的其他变量返回 truefalse

// 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 变量上实现初始化、运行时值更改以及正确的同步(如果需要)。

您可以在 playground 中运行此示例:https://play.golang.org/p/ ot3nvnp1bwc

卓越飞翔博客
上一篇: 使用通道将数据从一个 goroutine 传递到另一个 goroutine 时出现的问题
下一篇: 返回列表
留言与评论(共有 0 条评论)
   
验证码:
隐藏边栏