如何配置sigs.k8s.io/controller-runtime/pkg/log/zap实现分级别日志输出？

云原生阿岚

2026-6-23

按日志级别分流输出到stdout和stderr的实现方案

完全可行，你需要自定义zap的Core组件，实现不同级别日志输出到不同写入器的逻辑。以下是具体实现步骤和代码：

核心思路

分别创建指向stdout和stderr的写入器
为两个写入器配置对应的日志级别过滤规则：
- stderr仅接收Error及更高级别的日志
- stdout接收Debug、Info、Warn级别的日志
通过zapcore.NewTee合并两个Core，最终生成符合需求的Logger

完整代码示例

import (
	"os"

	"go.uber.org/zap"
	"go.uber.org/zap/zapcore"
	ctrl "sigs.k8s.io/controller-runtime"
	"sigs.k8s.io/controller-runtime/pkg/log/zap"
)

func main() {
	// 1. 定义写入器
	stdoutWriter := zapcore.AddSync(os.Stdout)
	stderrWriter := zapcore.AddSync(os.Stderr)

	// 2. 配置编码器（可根据需求调整，这里用controller-runtime默认的编码器配置）
	encoderConfig := zap.EncoderConfig()
	encoder := zapcore.NewJSONEncoder(encoderConfig)
	// 如果需要控制台格式的日志，替换为下面的编码器
	// encoder := zapcore.NewConsoleEncoder(encoderConfig)

	// 3. 定义级别过滤规则
	// stderr: 仅允许Error及更高级别
	stderrLevel := zapcore.LevelEnablerFunc(func(lvl zapcore.Level) bool {
		return lvl >= zapcore.ErrorLevel
	})
	// stdout: 允许Debug到Warn级别（排除Error及以上）
	stdoutLevel := zapcore.LevelEnablerFunc(func(lvl zapcore.Level) bool {
		return lvl < zapcore.ErrorLevel
	})

	// 4. 创建两个Core并合并
	core := zapcore.NewTee(
		zapcore.NewCore(encoder, stdoutWriter, stdoutLevel),
		zapcore.NewCore(encoder, stderrWriter, stderrLevel),
	)

	// 5. 创建Logger并设置给controller-runtime
	logger := zap.New(zap.UseCore(core))
	ctrl.SetLogger(logger)

	// 后续业务逻辑...
}