含IAsyncCollector<CloudEvent>的Azure函数作为EventGrid订阅目标报错

问题现象 #

使用Bicep创建EventGrid主题事件订阅时，尽管目标Azure函数已存在，但添加EventGrid输出绑定后，报错Resource should pre-exist before attempting this operation.；移除该输出绑定后，事件订阅可成功创建。

核心原因 #

当函数包含EventGrid输出绑定时，Azure在创建EventGrid事件订阅前会验证目标函数的可用性：

• 输出绑定依赖的ImporterTopicEndpoint和ImporterTopicKey对应的EventGrid主题必须已存在，且函数应用的应用设置中已正确配置这两个参数
• 如果输出绑定的依赖资源（目标主题或配置）缺失，函数会处于无法正常初始化的状态，EventGrid会判定该函数资源“未就绪”，从而抛出资源预存在的错误

解决方案 #

1. 确保输出绑定依赖的资源与配置已就绪 #

• 先部署ImporterTopic对应的EventGrid主题资源，确保其状态正常
• 在函数应用的应用设置中，正确配置ImporterTopicEndpoint（主题的终结点URL）和ImporterTopicKey（主题的访问密钥）

2. 调整Bicep部署依赖链 #

明确资源部署顺序，避免依赖倒置：

// 1. 先部署输出绑定依赖的EventGrid主题
resource importerTopic 'Microsoft.EventGrid/topics@2023-12-15-preview' = {
  name: 'ImporterTopic'
  location: resourceGroup().location
}

// 2. 配置函数应用的应用设置，注入主题的终结点和密钥
resource funcAppSettings 'Microsoft.Web/sites/config@2023-01-01' = {
  parent: funcFilesManagement
  name: 'appsettings'
  properties: {
    ImporterTopicEndpoint: importerTopic.properties.endpoint
    ImporterTopicKey: listKeys(importerTopic.id, '2023-12-15-preview').key1
  }
}

// 3. 最后创建EventGrid事件订阅，依赖函数和应用设置
resource evgsProcessNewFileOnFilescom 'Microsoft.EventGrid/topics/eventSubscriptions@2023-12-15-preview' = {
  parent: customTopic
  name: 'ProcessNewFileOn'
  dependsOn: [funcFilesManagement, funcAppSettings]
  properties: {
    destination: {
      properties: {
        resourceId: '${funcFilesManagement.id}/functions/ProcessNewFile'
        maxEventsPerBatch: 1
        preferredBatchSizeInKilobytes: 64
      }
      endpointType: 'AzureFunction'
    }
    filter: {
      includedEventTypes: [
        'new-file'
      ]
      enableAdvancedFilteringOnArrays: true
    }
    labels: []
    eventDeliverySchema: 'CloudEventSchemaV1_0'
    retryPolicy: {
      maxDeliveryAttempts: 30
      eventTimeToLiveInMinutes: 1440
    }
  }
}

3. 验证函数状态 #

• 部署完成后，进入Azure门户的函数应用页面，检查ProcessNewFile函数的状态是否为“就绪”
• 如果函数仍有初始化错误，查看函数的日志输出，确认输出绑定的配置是否正确

用户提供的原始代码：

Bicep事件订阅代码

resource evgsProcessNewFileOnFilescom 'Microsoft.EventGrid/topics/eventSubscriptions@2023-12-15-preview' = {
  parent: customTopic
  name: 'ProcessNewFileOn'
  dependsOn: [funcFilesManagement]
  properties: {
    destination: {
      properties: {
        resourceId: '${funcFilesManagement.id}/functions/ProcessNewFile'
        maxEventsPerBatch: 1
        preferredBatchSizeInKilobytes: 64
      }
      endpointType: 'AzureFunction'
    }
    filter: {
      includedEventTypes: [
        'new-file'
      ]
      enableAdvancedFilteringOnArrays: true
    }
    labels: []
    eventDeliverySchema: 'CloudEventSchemaV1_0'
    retryPolicy: {
      maxDeliveryAttempts: 30
      eventTimeToLiveInMinutes: 1440
    }
  }
}

函数定义代码

[FunctionName("ProcessNewFile")]
public async Task ProcessNewFile(
    [EventGridTrigger] CloudEvent @event,
    [EventGrid(TopicEndpointUri = "ImporterTopicEndpoint", TopicKeySetting = "ImporterTopicKey")] IAsyncCollector<CloudEvent> eventCollector,
    ILogger log)

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