如何缓解Azure场景下AppendBlock的BlobModifiedWhileReading错误？

针对你遇到的BlobModifiedWhileReading错误，本质是高并发场景下读操作（ExistsAsync）与写操作（AppendBlockAsync）触发的Blob模式切换冲突，以下是几个可行的缓解方案：

1. 移除冗余存在性检查，合并创建逻辑 #

你的代码中ExistsAsync属于冗余操作——CreateIfNotExistsAsync本身会自动检查Blob是否存在，无需额外调用读操作。移除该检查后，能减少一次触发读优化模式的操作，从根源降低冲突概率：

// 直接调用CreateIfNotExistsAsync，无需提前检查存在性
await appendBlobClient.CreateIfNotExistsAsync();
using var ms = new MemoryStream(blockContent);
await appendBlobClient.AppendBlockAsync(ms);

2. 针对冲突错误实现重试机制 #

即使优化了创建逻辑，极高并发下仍可能出现模式冲突，此时可为AppendBlockAsync添加定向重试策略，专门处理BlobModifiedWhileReading错误：

int retryCount = 0;
const int maxRetries = 3;
bool operationSuccess = false;

while (!operationSuccess && retryCount < maxRetries)
{
    try
    {
        await appendBlobClient.CreateIfNotExistsAsync();
        using var ms = new MemoryStream(blockContent);
        await appendBlobClient.AppendBlockAsync(ms);
        operationSuccess = true;
    }
    catch (RequestFailedException ex) 
        when (ex.ErrorCode == "BlobModifiedWhileReading" && retryCount < maxRetries)
    {
        retryCount++;
        // 采用指数退避等待，避免短时间内重复冲突
        await Task.Delay(TimeSpan.FromMilliseconds(100 * Math.Pow(2, retryCount)));
    }
}

也可通过配置Blob客户端的内置重试规则实现：

var blobClientOptions = new BlobClientOptions
{
    Retry =
    {
        Mode = RetryMode.Exponential,
        MaxRetries = 3,
        Delay = TimeSpan.FromMilliseconds(100),
        MaxDelay = TimeSpan.FromSeconds(2),
        // 指定仅重试模式冲突对应的错误状态码
        ErrorStatusCodes = { 412 }
    }
};

var appendBlobClient = new AppendBlobClient(
    connectionString, containerName, blobName, blobClientOptions);

3. 采用分区策略分散并发压力 #

将写入请求分散到多个Blob上，降低单个Blob的并发读写频率：

• 时间分区：按小时/天生成新Blob（命名规则如data-20240520-15），不同时间段的消息写入对应Blob
• Event Hub分区绑定：直接将Event Hub的每个分区对应到一个独立Blob，利用Event Hub的分区特性天然分散并发
• 业务属性分区：根据消息中的业务字段（如用户ID、设备ID）哈希分区，同一分组的消息写入同一个Blob

4. 批量追加减少写操作次数 #

将多个Event Hub消息批量收集后再执行一次AppendBlockAsync，减少单个Blob的写操作频率，降低冲突概率。比如在Azure Function中配置Event Hub批量触发器：

public async Task Run(
    [EventHubTrigger("your-hub-name", Connection = "EventHubConn", BatchSize = 100)] EventData[] events)
{
    var batchContent = new StringBuilder();
    foreach (var evt in events)
    {
        var message = Encoding.UTF8.GetString(evt.Body.ToArray());
        batchContent.AppendLine(message);
    }

    var appendBlobClient = new AppendBlobClient(connectionString, containerName, blobName);
    await appendBlobClient.CreateIfNotExistsAsync();
    using var ms = new MemoryStream(Encoding.UTF8.GetBytes(batchContent.ToString()));
    await appendBlobClient.AppendBlockAsync(ms);
}

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