如何在多租户ASP.NET Core应用中为租户动态修改Serilog最低日志级别

一、核心思路 #

利用Serilog的日志上下文与自定义过滤器结合，通过内存级别的租户配置容器实现轻量的动态级别控制——既绕开全局日志级别的限制，又保证性能开销最小化。核心逻辑是：先将租户ID注入请求/消息上下文，再通过过滤器判断当前日志所属租户是否需要提升级别，最终由过滤器决定日志是否输出。

二、具体实现步骤 #

1. 注入并丰富租户ID上下文 #

首先要确保每个请求/消息的租户ID被提取并加入Serilog日志上下文：

// 租户识别中间件（处理Web请求）
public class TenantIdentificationMiddleware
{
    private readonly RequestDelegate _next;

    public TenantIdentificationMiddleware(RequestDelegate next)
    {
        _next = next;
    }

    public async Task InvokeAsync(HttpContext context)
    {
        // 从URL路由提取TenantId，可根据实际格式调整
        if (context.Request.RouteValues.TryGetValue("tenantId", out var tenantVal) && 
            tenantVal is string tenantId)
        {
            context.Items["TenantId"] = tenantId;
            // 将TenantId推入Serilog日志上下文，后续日志自动携带该属性
            using (LogContext.PushProperty("TenantId", tenantId))
            {
                await _next(context);
            }
        }
        else
        {
            await _next(context);
        }
    }
}

// Program.cs中注册中间件（需放在路由匹配前）
app.UseMiddleware<TenantIdentificationMiddleware>();

同时在Serilog初始化时启用日志上下文丰富：

builder.Host.UseSerilog((context, config) =>
{
    config.Enrich.FromLogContext()
          .WriteTo.File(
              path: "logs/{TenantId}/log-.txt",
              rollingInterval: RollingInterval.Day,
              // Sink级别设为最低，让过滤器做最终控制
              restrictedToMinimumLevel: LogEventLevel.Debug
          );
});

2. 实现租户级别动态配置容器 #

用线程安全的内存容器存储需要临时提升级别的租户信息，支持动态更新：

public static class TenantLogLevelOverride
{
    // 线程安全字典，Key为租户ID，Value为目标日志级别
    private static readonly ConcurrentDictionary<string, LogEventLevel> _tenantLevels = new();

    // 设置/更新租户日志级别
    public static void SetLevel(string tenantId, LogEventLevel level)
    {
        _tenantLevels.AddOrUpdate(tenantId, level, (_, _) => level);
    }

    // 获取租户日志级别，无配置则返回null
    public static LogEventLevel? GetLevel(string tenantId)
    {
        _tenantLevels.TryGetValue(tenantId, out var level);
        return level;
    }

    // 移除租户级别配置
    public static void RemoveLevel(string tenantId)
    {
        _tenantLevels.TryRemove(tenantId, out _);
    }
}

3. 添加Serilog自定义过滤器 #

在Serilog配置中加入过滤器，根据租户配置动态判断日志是否输出：

builder.Host.UseSerilog((context, config) =>
{
    var globalMinLevel = LogEventLevel.Error; // 全局默认最低级别
    config.Enrich.FromLogContext()
          .Filter.ByIncludingOnly(evt =>
          {
              // 先判断日志是否携带TenantId属性
              if (evt.Properties.TryGetValue("TenantId", out var tenantProp) && 
                  tenantProp is ScalarValue tenantScalar && 
                  tenantScalar.Value is string tenantId)
              {
                  // 读取租户配置的级别，无配置则用全局级别
                  var tenantMinLevel = TenantLogLevelOverride.GetLevel(tenantId);
                  return tenantMinLevel.HasValue ? evt.Level >= tenantMinLevel.Value : evt.Level >= globalMinLevel;
              }
              // 无TenantId的请求/消息使用全局级别
              return evt.Level >= globalMinLevel;
          })
          .WriteTo.File(
              path: "logs/{TenantId}/log-.txt",
              rollingInterval: RollingInterval.Day,
              restrictedToMinimumLevel: LogEventLevel.Debug
          );
});

4. 动态更新租户级别（管理员接口） #

提供简单的API接口用于临时调整指定租户的日志级别（需加权限控制）：

[ApiController]
[Route("api/admin/tenant-log-level")]
[Authorize(Roles = "Admin")]
public class TenantLogLevelController : ControllerBase
{
    [HttpPost("{tenantId}")]
    public IActionResult SetTenantLevel(string tenantId, [FromBody] LogEventLevel level)
    {
        TenantLogLevelOverride.SetLevel(tenantId, level);
        return Ok($"租户 {tenantId} 日志级别已设为 {level}");
    }

    [HttpDelete("{tenantId}")]
    public IActionResult RemoveTenantLevel(string tenantId)
    {
        TenantLogLevelOverride.RemoveLevel(tenantId);
        return Ok($"已移除租户 {tenantId} 的日志级别配置");
    }
}

5. 队列消息处理器适配 #

如果是队列消息（如RabbitMQ、Hangfire），只需在消息处理前将租户ID推入LogContext即可，过滤器逻辑完全复用：

public async Task ProcessMessage(MyQueueMessage message)
{
    using (LogContext.PushProperty("TenantId", message.TenantId))
    {
        // 消息处理逻辑
        Log.Debug("处理租户 {TenantId} 的消息", message.TenantId);
    }
}

三、性能优化说明 #

• 用ConcurrentDictionary存储租户配置，保证线程安全的同时读取性能为O(1)，无锁开销。
• 过滤器逻辑仅做简单的属性读取和字典查询，避免复杂计算或IO操作，性能损耗可忽略。
• File Sink的级别设为最低（Debug），减少Sink内部的级别判断开销，将控制逻辑集中在过滤器层。

内容的提问来源于stack exchange，提问作者Mayur Agarwal