使用OpenTelemetry对接Azure Monitor时，如何在处理器中过滤LogRecords？

我之前在做分布式应用对接OpenTelemetry和Azure Monitor（App Insights）的时候，也碰到过完全一样的需求——用ILogger规范打日志，但需要过滤掉不必要的日志，不然App Insights里的日志量会爆炸，还增加不必要的开销。下面给你两个最实用的实现方式：

方法一：自定义日志处理器（灵活度最高） #

如果你的过滤逻辑比较复杂（比如要结合业务属性、多条件判断），自定义一个LogProcessor是最好的选择。你只需要继承OpenTelemetry的BaseProcessor<LogRecord>，重写OnEnd方法来决定要不要跳过这条日志：

public class BusinessLogFilterProcessor : BaseProcessor<LogRecord>
{
    public override void OnEnd(LogRecord logRecord)
    {
        // 举个例子：只保留Warning及以上级别，且包含"BusinessCritical"标记的日志
        var isCriticalBusinessLog = logRecord.Attributes.TryGetValue("BusinessCritical", out var value) 
                                    && value is bool isCritical && isCritical;

        if (logRecord.LogLevel < LogLevel.Warning && !isCriticalBusinessLog)
        {
            // 调用Skip方法，这条日志就不会传到后续的导出器（比如Azure Monitor）
            Skip(logRecord);
        }

        base.OnEnd(logRecord);
    }
}

然后在注册OpenTelemetry的时候，把这个自定义处理器加到日志管道里，注意要放在导出器前面，这样先过滤再导出：

builder.Services.AddOpenTelemetry()
    .ConfigureResource(r => r.AddService("你的应用名称"))
    .WithLogging(logging => logging
        .AddProcessor<BusinessLogFilterProcessor>() // 先加过滤处理器
        .AddAzureMonitorLogExporter(exporter =>
        {
            exporter.ConnectionString = "你的Azure Monitor连接字符串";
        }));

方法二：用内置的AddFilter快速过滤 #

如果你的过滤逻辑比较简单（比如按日志级别、Logger名称过滤），直接用OpenTelemetry内置的AddFilter方法就行，不用写自定义处理器，代码更简洁：

builder.Services.AddOpenTelemetry()
    .ConfigureResource(r => r.AddService("你的应用名称"))
    .WithLogging(logging => logging
        .AddFilter(logRecord => 
        {
            // 示例：只保留来自"YourApp.Services"命名空间的Info及以上级别日志
            return logRecord.LoggerName.StartsWith("YourApp.Services") 
                && logRecord.LogLevel >= LogLevel.Information;
        })
        .AddAzureMonitorLogExporter(exporter =>
        {
            exporter.ConnectionString = "你的Azure Monitor连接字符串";
        }));

几个小提醒： #

• 处理器的执行顺序很重要：过滤类的处理器一定要放在导出器前面，不然已经导出了再过滤就没意义了
• 用ILogger打日志的时候，自定义属性会自动放到LogRecord.Attributes里，比如_logger.LogInformation("操作完成", new { BusinessCritical = true })，你就能在处理器里拿到这个BusinessCritical属性
• 别过度过滤：尽量只过滤掉明确不需要的日志，比如调试用的Verbose日志，或者重复的健康检查日志，避免漏掉排查问题需要的关键信息

内容来源于stack exchange