Azure Event Grid触发Java函数部署后读取所有现有Blob文件问题

问题原因 #

当为Blob容器创建Event Grid订阅时，默认配置下Event Grid会发送容器中所有现有Blob的Microsoft.Storage.BlobCreated事件作为初始同步，导致函数部署后被批量触发读取旧文件。此外你的代码存在语法错误：变量名不能使用Java关键字byte。

解决方案 #

1. 修正代码语法错误 #

先把非法变量名替换为合法名称，同时将事件参数改为强类型EventGridEvent（需确保依赖com.microsoft.azure.functions:azure-functions-java-library）：

import com.microsoft.azure.functions.eventgrid.EventGridEvent;
import com.microsoft.azure.functions.eventgrid.StorageBlobCreatedEventData;

@FunctionName("MyEventGridTrigger")
@StorageAccount("AzureWebJobsStorage")
public void run(@EventGridTrigger(name = "eventGridTrigger") EventGridEvent event,
        @BlobInput(name = "blob", dataType = "binary", path = "{data.url}") byte[] blobBytes,
        final ExecutionContext context) {
    context.getLogger().info("Event Grid trigger function executed.");
    
    // 后续逻辑编写
}

2. 过滤非目标事件 #

在函数中添加逻辑，仅处理新创建/更新的Blob事件，排除订阅初始化时的旧Blob事件：

@FunctionName("MyEventGridTrigger")
@StorageAccount("AzureWebJobsStorage")
public void run(@EventGridTrigger(name = "eventGridTrigger") EventGridEvent event,
        @BlobInput(name = "blob", dataType = "binary", path = "{data.url}") byte[] blobBytes,
        final ExecutionContext context) {
    
    // 只处理Blob创建/更新类型的事件
    if (!"Microsoft.Storage.BlobCreated".equals(event.getEventType())) {
        context.getLogger().info("Skipping non-target event: " + event.getEventType());
        return;
    }

    // 解析事件数据，可通过事件时间或Blob元数据过滤旧文件
    StorageBlobCreatedEventData eventData = event.getData().toObject(StorageBlobCreatedEventData.class);
    String blobUrl = eventData.getUrl();
    
    // 示例：仅处理函数部署时间之后的事件（需自行记录部署时间）
    // Instant deployTime = Instant.parse("2024-01-01T00:00:00Z");
    // if (event.getEventTime().isBefore(deployTime)) { return; }

    context.getLogger().info("Processing new/updated blob: " + blobUrl);
    
    // 你的文件读取逻辑
}

3. 创建订阅时禁用初始同步 #

如果不想依赖代码过滤，可在创建Event Grid订阅时直接关闭现有事件同步：

• 门户创建：在“事件传递”环节取消勾选“发送所有现有事件”。
• Azure CLI创建：添加--no-include-existing-events参数：

az eventgrid event-subscription create \
  --name <你的订阅名称> \
  --source-resource-id /subscriptions/<订阅ID>/resourceGroups<资源组名>/providers/Microsoft.Storage/storageAccounts/<存储账户名> \
  --endpoint <你的函数端点> \
  --event-delivery-schema eventgridschema \
  --no-include-existing-events

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