如何防止Azure函数重复处理已处理的Blob？

这确实是个常见的痛点——重命名后的Blob因为还是csv格式，会被原来的{name}.csv过滤规则再次触发。不过有几种靠谱的方法可以解决这个问题，按推荐程度排序：

1. 直接在host.json中配置排除规则（最高效） #

从Azure Functions v3版本开始，你可以通过host.json的扩展配置，让BlobTrigger直接排除带-Processed后缀的文件，从根源上避免触发。

只需要在你的函数项目根目录下的host.json中添加以下配置：

{
  "version": "2.0",
  "extensions": {
    "blobs": {
      "trigger": {
        "filter": {
          "exclude": "*-Processed.csv"
        }
      }
    }
  }
}

这里的exclude规则用通配符*匹配任意前缀，只要文件名以-Processed.csv结尾，就会被BlobTrigger忽略。如果你的Blob存放在容器的子文件夹里，比如data/{name}.csv，那可以把排除规则改成data/*-Processed.csv，适配你的路径结构。

这种方式的好处是完全在触发层面过滤，函数根本不会被调用，节省资源又高效。

2. 在函数代码中提前判断（最简单直接） #

如果暂时没法修改host.json，或者需要更灵活的判断逻辑，那可以在函数入口处先检查文件名，遇到带-Processed的就直接跳过处理。

举个C#的例子：

[FunctionName("ProcessCsvBlob")]
public static void Run(
    [BlobTrigger("your-container/{name}.csv", Connection = "AzureWebJobsStorage")] Stream blobStream,
    string name,
    ILogger log)
{
    // 检查文件名是否包含已处理标记，是则直接返回
    if (name.Contains("-Processed"))
    {
        log.LogInformation($"Skipping already processed blob: {name}.csv");
        return;
    }

    // 这里写你的Blob处理逻辑...

    // 处理完成后重命名Blob的代码
}

如果是Python函数，代码大概是这样：

import azure.functions as func
import logging

def main(blob: func.InputStream):
    # 提取文件名（去掉容器路径）
    file_name = blob.name.split("/")[-1]
    if "-Processed" in file_name:
        logging.info(f"Skipping processed blob: {file_name}")
        return

    # 你的处理逻辑...

这种方法虽然会触发函数，但会快速跳过不必要的处理，实现起来零配置成本。

3. 改用事件网格触发（最灵活） #

如果你的场景需要更复杂的过滤规则，比如不仅要看文件名，还要结合Blob的创建时间、大小等属性，可以考虑把BlobTrigger换成Event Grid Trigger。

你需要先给Blob存储账户配置事件网格订阅，然后在订阅的过滤规则中添加：

• 事件类型选择Microsoft.Storage.BlobCreated
• 高级过滤规则：subject字段不包含-Processed.csv

这样只有符合条件的Blob创建事件才会触发你的函数，完全避免无效调用。不过这个方法需要额外配置事件网格，适合复杂场景。

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