如何让Azure Event Hub监听器批量处理单条发送的事件？

关键配置调整（host.json） #

Azure Functions的Event Hub触发器自带核心配置项，专门控制批量接收逻辑，直接在host.json里设置即可：

• maxBatchSize：单次触发最多处理的事件数，比如设为1000（可根据业务场景调整）。当Event Hub内事件攒到这个数量时，函数会触发处理这批事件。
• maxWaitTime：等待事件积累的最长时间（单位：毫秒），比如设为5000（即5秒）。哪怕事件数没达到maxBatchSize，只要等待时间到了，函数也会触发处理当前攒下的事件。

示例host.json配置 #

{
  "version": "2.0",
  "extensions": {
    "eventHubs": {
      "batchCheckpointFrequency": 1,
      "eventProcessorOptions": {
        "maxBatchSize": 1000,
        "maxWaitTime": 5000
      }
    }
  }
}

为什么禁用再启用会批量接收？ #

禁用监听函数后，Event Hub里的小消息会持续积累，重新启用时，函数会一次性拉取到maxBatchSize上限的事件量，因此出现大批次处理的情况。上面的配置就是让函数在正常运行时也遵循这个逻辑——要么攒够指定数量，要么等够时间就触发，不会每条小消息都单独处理。

额外注意点 #

• 平衡延迟和批量大小：maxWaitTime设太长会增加数据处理延迟，maxBatchSize设太大可能导致函数处理超时（默认函数超时为5分钟），需结合业务容忍度调整。
• 分区与并发匹配：Event Hub的每个分区会单独应用这些批量配置，要根据分区数合理设置函数的并发实例数，避免资源浪费或处理不及时。
• 代码适配批量逻辑：确保函数代码按批量事件处理，比如C#中接收EventData[]而非单个EventData，再遍历处理每条事件，示例代码如下：

[FunctionName("EventHubListener")]
public static async Task Run(
    [EventHubTrigger("your-event-hub-name", Connection = "EventHubConnection")] EventData[] events,
    ILogger log)
{
    foreach (var eventData in events)
    {
        string messageBody = Encoding.UTF8.GetString(eventData.Body.Array, eventData.Body.Offset, eventData.Body.Count);
        log.LogInformation($"Processed message: {messageBody}");
    }
}

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