如何将Asp.Net Core 6.0应用日志以CSV块Blob形式存入Azure Blob存储

直接给可落地的轻量方案，全程用Azure官方SDK，无多余第三方依赖即可跑通。

1. 安装前置依赖 #

通过NuGet安装官方组件即可：

• Azure.Storage.Blobs：Azure Blob存储官方客户端库，默认操作的就是Block Blob类型，完全符合块Blob的要求
• 框架自带的Microsoft.Extensions.Logging无需额外升级，6.0版本自带的日志抽象层足够支撑扩展

2. 添加配置项 #

在appsettings.json中加入日志相关配置，生产环境建议将连接字符串存入密钥管理服务或用托管标识鉴权，不要硬编码：

{
  "AzureBlobLogSettings": {
    "ConnectionString": "<替换为你的Azure存储账户连接字符串>",
    "ContainerName": "<替换为提前创建好的Blob容器名，需全小写符合Azure命名规则>",
    "LogFilePrefix": "appruntime-log",
    "BatchWriteCount": 50,
    "FlushIntervalSec": 60
  }
}

参数说明：

• BatchWriteCount：攒够指定条数日志再批量写入Blob，避免单条写入产生大量冗余请求
• FlushIntervalSec：无论日志是否攒够批次，最长间隔指定时间就强制刷入存储，防止日志积压
• 日志文件默认按天切分，最终生成的Blob名格式类似appruntime-log-20240520.csv，均为标准块Blob

3. 定义核心类型 #

先定义强类型配置和日志条目结构，避免硬编码魔法值：

// 配置强类型映射类
public class BlobCsvLogOptions
{
    public string ConnectionString { get; set; } = string.Empty;
    public string ContainerName { get; set; } = string.Empty;
    public string LogFilePrefix { get; set; } = "app-log";
    public int BatchWriteCount { get; set; } = 50;
    public int FlushIntervalSec { get; set; } = 60;
}

// 单条日志结构，对应CSV列
public class CsvLogItem
{
    public DateTimeOffset LogTime { get; set; }
    public string Level { get; set; } = string.Empty;
    public string Category { get; set; } = string.Empty;
    public string Content { get; set; } = string.Empty;
    public string? ExceptionTrace { get; set; }
}

4. 实现核心写入逻辑 #

核心逻辑拆成两部分，避免阻塞业务线程：

1. 自定义Logger组件，业务代码产生日志时不直接发起网络请求，只把日志条目放入线程安全的内存队列
2. 后台托管服务定时从队列拉取日志，转成标准CSV格式，批量写入对应日期的块Blob

关键实现注意点 #

• CSV格式合规处理：必须做字段转义，只要字段内容包含逗号、双引号、换行符，就用双引号包裹整个字段，字段内的双引号替换为两个双引号，符合RFC4180标准，避免打开CSV时列错位。转义逻辑可直接复用：

  private static string EscapeCsv(string field)
  {
      if (string.IsNullOrWhiteSpace(field)) return string.Empty;
      if (field.Contains(',') || field.Contains('"') || field.Contains('\r') || field.Contains('\n'))
      {
          return $"\"{field.Replace("\"", "\"\"")}\"";
      }
      return field;
  }
  

• 块Blob类型校验：用BlobClient上传时不要指定Blob类型为Append，SDK默认创建的就是Block Blob；不要用AppendBlobClient，其生成的是追加Blob，不符合类型要求。
• 性能保障：所有Blob网络操作全部放在后台线程执行，业务线程写日志仅做入队操作，耗时在微秒级，不会影响接口响应速度。
• 异常兜底：写Blob失败时最多重试3次，仍然失败就把日志输出到控制台兜底，绝对不能抛异常导致业务请求中断。
• 表头处理：当天第一次创建对应日期的CSV Blob时，第一行先写入固定表头LogTime,Level,Category,Content,ExceptionTrace，后续写入直接追加CSV行即可。

5. 服务注册 #

在Program.cs中注册相关服务，把自定义日志组件接入框架日志管道：

var builder = WebApplication.CreateBuilder(args);

// 绑定日志配置
builder.Services.Configure<BlobCsvLogOptions>(builder.Configuration.GetSection("AzureBlobLogSettings"));
// 注册线程安全日志队列
builder.Services.AddSingleton<ConcurrentQueue<CsvLogItem>>();
// 注册后台日志刷入服务
builder.Services.AddHostedService<BlobCsvLogBackgroundWriter>();
// 注册自定义日志提供器，不会影响原有控制台、调试日志的正常输出
builder.Logging.AddProvider<BlobCsvLogProvider>();

// 保留你原有的服务注册逻辑，比如AddControllers、AddSwaggerGen等
// builder.Services.AddControllers();

var app = builder.Build();

// 保留你原有的中间件配置逻辑
// app.UseAuthorization();
// app.MapControllers();

app.Run();

可选优化项 #

• 生产环境不要用存储账户密钥连接，换成Azure托管标识授权，不需要在配置中存储连接字符串，安全性更高
• 日志量特别大的场景可以按小时切分CSV文件，避免单个Blob体积过大，后续排查下载更方便
• 如果不想自行维护自定义日志逻辑，也可以对接Serilog，配置Azure Blob Sink后自定义输出模板为CSV格式即可，核心逻辑和上述实现一致。

内容的提问来源于stack exchange，提问作者P John Raj