如何配置Azure Function的EventHubTrigger等待积累足量消息再触发

可以通过修改EventHub触发器的内置配置，实现等待积累指定数量消息后再触发函数执行，从而降低Azure Storage的写入次数。

核心配置参数 #

你需要修改函数项目根目录下的host.json文件，调整以下几个关键参数：

• minBatchSize：单次触发要求的最小消息条数，也就是你需要的积累触发阈值，可按需设置为50/100/200
• maxBatchSize：单次触发允许的最大消息条数，建议设置为你需要的批大小上限
• processorOptions.maxWaitTime：兜底最大等待时间，若指定时长内始终凑不够minBatchSize的消息，触发器会直接触发现有消息的处理，避免消息积压延迟过高
• batchCheckpointFrequency：每处理多少批消息后提交一次消费检查点，无特殊需求保持为1即可

配置示例 #

以下示例设置为最少积累50条消息触发，单次最大处理200条，最长等待5分钟兜底：

{
  "version": "2.0",
  "extensions": {
    "eventHubs": {
      "minBatchSize": 50,
      "maxBatchSize": 200,
      "batchCheckpointFrequency": 1,
      "processorOptions": {
        "maxWaitTime": "00:05:00"
      }
    }
  }
}

若需要最低100条或200条触发，直接修改minBatchSize的取值即可。

注意事项 #

• minBatchSize参数仅在Azure Function 3.x及更高版本运行时支持，更低版本运行时无该配置项
• 批大小统计是按Event Hub分区独立计算的，比如你设置minBatchSize为50，Event Hub有4个分区，则实际是每个分区各自积累到50条才会触发该分区的批处理，不是全局累计凑够50条触发
• 若使用弹性消费计划，maxWaitTime的取值不能超过你配置的函数执行超时时间（默认弹性计划执行超时为5分钟，最高可调整到10分钟）
• 参数调整完成后可通过函数监控面板的Avg Event Batch Size指标验证实际生效的批处理大小，结合业务延迟容忍度微调参数即可

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