如何确保BlobTrigger仅在Blob新增时触发而非生命周期策略删除时触发？

我有一个使用BlobTrigger指向Azure存储的Function App，代码如下：

[FunctionName("ProcessFiles")]
public async Task Run([BlobTrigger("container-path/{name}", Connection = "myconnection")] Stream myBlob, string name, ILogger log)
{
    //Processing Logic here
}

同时我配置了生命周期管理策略，容器中存放超过3个月的文件会被自动删除，策略配置如下：

{
  "rules": [
    {
      "enabled": false,
      "name": "Delete 1 day or older",
      "type": "Lifecycle",
      "definition": {
        "actions": {
          "baseBlob": {
            "delete": {
              "daysAfterModificationGreaterThan": 1
            }
          }
        },
        "filters": {
          "blobTypes": [
            "blockBlob"
          ]
        }
      }
    }
  ]
}

现在的问题是，文件被生命周期策略删除时，BlobTrigger会再次触发，导致文件被重复处理。禁用该策略后问题消失，但我需要仅在新文件添加时执行处理逻辑，而非删除时。该方案已上线，无法修改BlobStorage Trigger，希望通过内部属性判断操作类型并执行逻辑，求可行解决办法？

方法1：检查Blob的存在状态 #

修改函数参数，注入CloudBlob对象（需引用Microsoft.Azure.Storage.Blob NuGet包），通过判断Blob是否存在来过滤删除触发：

[FunctionName("ProcessFiles")]
public async Task Run([BlobTrigger("container-path/{name}", Connection = "myconnection")] CloudBlob myBlob, string name, ILogger log)
{
    if (!await myBlob.ExistsAsync())
    {
        log.LogInformation($"Blob {name} has been deleted, skip processing.");
        return;
    }

    // 执行原处理逻辑
    // Processing Logic here
}

当生命周期策略删除Blob后，触发的函数中myBlob.ExistsAsync()会返回false，直接跳过处理即可。

方法2：读取触发器元数据判断操作类型 #

BlobTrigger触发时会携带BlobEventType元数据，删除操作对应值为Deleted。通过绑定IDictionary<string, string>类型的元数据参数获取该值：

[FunctionName("ProcessFiles")]
public async Task Run([BlobTrigger("container-path/{name}", Connection = "myconnection")] Stream myBlob, string name, IDictionary<string, string> metadata, ILogger log)
{
    if (metadata.TryGetValue("BlobEventType", out var eventType) && 
        eventType.Equals("Deleted", StringComparison.OrdinalIgnoreCase))
    {
        log.LogInformation($"Received delete event for blob {name}, skip processing.");
        return;
    }

    // 执行原处理逻辑
    // Processing Logic here
}

注意：该元数据仅在基于事件网格的BlobTrigger中有效，若你的Function是旧版本，需确认已启用事件网格集成（新版本默认启用）。

方法3：记录已处理Blob清单 #

在函数处理完成后，将Blob名称和处理时间记录到Azure Table Storage（或其他持久化存储），触发时先检查清单，避免重复处理：

// 构造函数注入TableStorage客户端
private readonly CloudTable _processedBlobsTable;

public YourFunctionClass(CloudTableClient tableClient)
{
    _processedBlobsTable = tableClient.GetTableReference("ProcessedBlobs");
    _processedBlobsTable.CreateIfNotExistsAsync().Wait();
}

[FunctionName("ProcessFiles")]
public async Task Run([BlobTrigger("container-path/{name}", Connection = "myconnection")] Stream myBlob, string name, ILogger log)
{
    // 检查是否已处理过该Blob
    var retrieveOp = TableOperation.Retrieve<ProcessedBlob>("ProcessedBlobs", name);
    var result = await _processedBlobsTable.ExecuteAsync(retrieveOp);
    if (result.Result != null)
    {
        log.LogInformation($"Blob {name} already processed, skip.");
        return;
    }

    // 执行原处理逻辑
    // Processing Logic here

    // 写入处理记录
    var entity = new ProcessedBlob(name) { ProcessedTime = DateTime.UtcNow };
    var insertOp = TableOperation.Insert(entity);
    await _processedBlobsTable.ExecuteAsync(insertOp);
}

// Table实体类定义
public class ProcessedBlob : TableEntity
{
    public ProcessedBlob(string blobName)
    {
        PartitionKey = "ProcessedBlobs";
        RowKey = blobName;
    }
    public ProcessedBlob() { }
    public DateTime ProcessedTime { get; set; }
}

这种方法兼容性最强，无论触发原因是什么，都能确保同一Blob只被处理一次。

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