向Blob流写入数据：如何处理失败与清理操作？

嘿，针对你在用Azure Storage流式写入Blob时遇到的失败处理和清理难题，我整理了几个在生产环境里挺实用的方案，帮你搞定这个问题：

不管写入成功与否，流的正确释放是基础中的基础。如果你的BlobStreamContainer里的流实现了IDisposable（比如Azure SDK返回的CloudBlobStream或者BlockBlobClient.OpenWriteAsync的返回流），一定要把它放进using块里——哪怕抛出异常，CLR也会自动帮你释放资源，避免内存泄漏或者无效连接占用：

// 同步场景
using (var streamContainer = new BlobStreamContainer("target-file-name", blobClient.OpenWriteAsync().Result))
{
    // 这里执行你的边处理边写入逻辑
    if (somecondition)
    {
        // 写入操作
        streamContainer.Stream.Write(buffer, 0, buffer.Length);
    }
}

// 异步场景记得用await using
await using (var streamContainer = new BlobStreamContainer("target-file-name", await blobClient.OpenWriteAsync()))
{
    await streamContainer.Stream.WriteAsync(buffer, 0, buffer.Length);
}

流式写入中途失败时，Azure Storage可能会留下不完整的Blob文件（尤其是Block Blob或者Append Blob场景），这时候得主动清理这些无效文件，避免占用存储资源：

1. 在异常捕获中主动删除无效Blob #

用try-catch块捕获写入相关的异常（比如StorageException、IOException），然后调用Blob客户端的删除方法。注意先判断Blob是否存在，避免无意义的删除请求：

var blobClient = new BlobClient(connectionString, containerName, targetFileName);
BlobStreamContainer streamContainer = null;

try
{
    streamContainer = new BlobStreamContainer(targetFileName, await blobClient.OpenWriteAsync());
    // 执行你的边处理边写入逻辑
    if (somecondition)
    {
        await streamContainer.Stream.WriteAsync(buffer, 0, buffer.Length);
    }
}
catch (Exception ex)
{
    // 先检查Blob是否存在，再删除
    if (await blobClient.ExistsAsync())
    {
        // 连快照一起删，避免残留
        await blobClient.DeleteAsync(DeleteSnapshotsOption.IncludeSnapshots);
    }
    // 抛出异常或者记录日志，方便排查问题
    throw new InvalidOperationException("写入Blob失败，已自动清理无效文件", ex);
}
finally
{
    // 兜底确保流被释放，避免资源泄漏
    streamContainer?.Stream.Dispose();
}

如果是用Block Blob的分块写入，中途失败可以直接删除——未完成的分块不会自动合并成完整Blob，但Azure会临时保留这些分块，主动删除更稳妥。

2. 用生命周期管理规则做兜底 #

如果担心代码层面的清理有遗漏（比如进程崩溃、网络中断导致代码没走到删除逻辑），可以给存储容器配置生命周期管理规则，自动清理不完整的Blob：

• 比如给Blob加个自定义索引标签IsComplete: false，写入完成后改成IsComplete: true；
• 然后在Azure门户的存储容器“生命周期管理”里加规则：删除LastModified超过1小时且IsComplete为false的Block Blob。
  规则的核心配置大概是这样：

{
  "rules": [
    {
      "name": "cleanup-incomplete-blobs",
      "enabled": true,
      "type": "Lifecycle",
      "definition": {
        "actions": {
          "baseBlob": {
            "delete": {
              "daysAfterModificationGreaterThan": 0.04 // 约1小时
            }
          }
        },
        "filters": {
          "blobTypes": ["blockBlob"],
          "blobIndexMatch": [
            {
              "name": "IsComplete",
              "value": "false"
            }
          ]
        }
      }
    }
  ]
}

为了避免误删有效Blob，建议在写入完成后给Blob加个“完成标记”：

• 可以加元数据Status: Completed，或者用上面提到的Blob索引标签IsComplete: true；
• 清理的时候只删除没有这个标记的Blob，这样即使写入成功后出现其他异常，也不会误删有效文件：

// 写入完成后设置标记
await blobClient.SetMetadataAsync(new Dictionary<string, string> { { "Status", "Completed" } });
// 或者设置索引标签
await blobClient.SetTagsAsync(new Dictionary<string, string> { { "IsComplete", "true" } });

如果是用Append Blob做流式写入，中途失败后已写入的块会保留。如果不需要这些部分数据，直接删除整个Blob即可；如果需要保留已写入内容，可以在异常里记录已写入的位置，后续恢复写入时从该位置继续追加。

内容的提问来源于stack exchange，提问作者Matt Burland