如何让Azure Function忽略历史Blob事件仅响应当前事件？

针对你遇到的大容器（100万Blob）下Blob触发器持续接收历史事件的问题，这是因为当容器Blob数量超过10k时，Functions runtime会切换到扫描存储日志来跟踪Blob变化，这个过程会回溯历史日志导致触发旧事件。下面是几个有效的解决方案：

1. 配置触发器的startTime参数 #

这是最直接的方法，通过在触发器配置中指定开始监听的时间，让runtime只处理该时间点之后的Blob事件。

在你的Function的function.json文件中，找到Blob触发器的配置项，添加startTime字段，值为ISO 8601格式的时间（比如你部署或重启Function的时间）：

{
  "bindings": [
    {
      "name": "myBlob",
      "type": "blobTrigger",
      "direction": "in",
      "path": "your-container-name/{name}",
      "connection": "AzureWebJobsStorage",
      "startTime": "2024-05-20T00:00:00Z"
    }
  ]
}

设置后，runtime会忽略所有早于该时间的Blob变更事件，只处理新产生的事件。

2. 在代码中手动过滤历史事件 #

如果无法修改触发器配置，或者需要更灵活的控制，可以在Function代码中添加时间过滤逻辑，跳过早于指定阈值的Blob。

以C#为例，你可以通过lastModified参数获取Blob的修改时间，和预设的阈值对比：

public static void Run(Stream myBlob, string name, DateTimeOffset lastModified, ILogger log)
{
    // 替换成你希望开始处理的时间点
    var threshold = new DateTimeOffset(2024, 5, 20, 0, 0, 0, TimeSpan.Zero);
    
    if (lastModified < threshold)
    {
        log.LogInformation($"跳过历史Blob: {name}，最后修改时间: {lastModified}");
        return;
    }

    // 这里写你的Blob处理逻辑
    log.LogInformation($"正在处理Blob: {name}");
}

其他语言（比如Python、JavaScript）也可以通过类似的方式获取Blob的修改时间并过滤。

3. 改用Event Grid触发器替代原生Blob触发器 #

原生Blob触发器在大容器场景下的日志扫描机制容易导致历史事件触发，而Event Grid是主动推送模式，只有当Blob发生创建/修改操作时才会发送事件，不会回溯历史。

具体步骤：

• 在Azure门户中创建Event Grid订阅，目标选择你的Azure Function（作为webhook）
• 订阅的事件类型选择Microsoft.Storage.BlobCreated和Microsoft.Storage.BlobModified
• 在订阅的过滤条件中，可以设置只接收订阅创建之后的事件，或者添加更精细的过滤规则（比如Blob前缀）

这种方式不仅能避免历史事件，还能提升大容器下的触发性能，更适合百万级Blob的场景。

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