如何从Azure存储账户changefeed中区分Blob创建与内容修改事件

方案1：启用Blob版本控制（推荐） #

这是最可靠的识别方式，无需额外维护外部映射数据：

• 先为你的Azure存储账户开启Blob版本控制功能，开启后所有Blob的新增、覆盖操作都会生成独立的版本记录
• 变更流的BlobChangeFeedEventData中会额外携带PreviousBlobVersionId字段：
  • 首次新建Blob时，PreviousBlobVersionId值为null，直接判定为新建操作
  • 覆盖修改已有Blob内容时，PreviousBlobVersionId会携带上一个版本的ID，直接判定为内容修改操作

你可以直接在现有代码中新增判断逻辑，修改后的showEventData示例如下：

public static void showEventData(List<BlobChangeFeedEvent> changeFeedEvents)
{
    foreach (BlobChangeFeedEvent changeFeedEvent in changeFeedEvents)
    {
        string subject = changeFeedEvent.Subject;
        string eventType = changeFeedEvent.EventType.ToString();
        string eventTime = changeFeedEvent.EventTime.ToString();
        string operation = changeFeedEvent.EventData.BlobOperationName.ToString();
        // 新增读取版本ID字段
        string currentVersionId = changeFeedEvent.EventData.BlobVersionId?.ToString();
        string previousVersionId = changeFeedEvent.EventData.PreviousBlobVersionId?.ToString();

        string operationType = string.Empty;
        if (eventType == "BlobCreated")
        {
            operationType = previousVersionId == null ? "新建Blob" : "修改Blob内容";
        }
        // 其他事件类型逻辑自行补充

        Console.WriteLine("Subject: " + subject + "\n" +
        "Event Type: " + eventType + "\n" +
        "Event Time: " + eventTime + "\n" +
        "Operation Name: " + operation + "\n" +
        "实际操作类型: " + operationType + "\n" +
        "当前版本ID: " + currentVersionId + "\n" +
        "上一版本ID: " + previousVersionId);
    }
}

方案2：外部维护Blob状态映射（不开启版本控制时使用） #

如果无法开启版本控制，可以自行维护一张已存在Blob的映射表，存储规则为：

• Key：Blob的完整路径（即事件中的Subject字段值）
• Value：最近一次Blob的ETag或ContentMd5值

每次收到BlobCreated事件时执行判断：

• 映射表中不存在对应Key：判定为新建操作，将本次事件的ETag/ContentMd5存入映射表
• 映射表中存在对应Key：对比本次ETag/ContentMd5与存储的值，不一致则判定为内容修改操作，更新映射表中存储的值

注意：该方案需要自行保证映射表的一致性，出现异常中断时可能存在判断误差。

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