如何让Azure Function App从IoT Hub多分区同步按序读取事件？

1. 借助中间队列实现全局串行处理 #

• 利用IoT Hub的路由功能，将所有分区的事件转发到Azure Service Bus队列或Storage队列，通过队列的先进先出特性统一归集所有事件。
• 配置队列触发的Function：在host.json中设置extensions.queues.batchSize=1和extensions.queues.maxConcurrentCalls=1，同时在Function App的应用设置里添加FUNCTIONS_WORKER_PROCESS_COUNT=1，强制单线程逐个处理队列消息，确保所有事件按时间顺序串行执行。

2. 自定义事件处理器+全局分布式锁 #

• 基于.NET实现自定义IEventProcessor，在事件处理逻辑中加入全局分布式锁（比如Redis锁、CosmosDB文档锁）：
  • 处理事件前先获取全局锁，保证同一时间只有一个事件在处理
  • 完成事件处理和CosmosDB状态更新后立即释放锁
  • 注意设置合理的锁超时时间，同时添加锁获取失败的重试逻辑，避免出现长时间阻塞

3. 调整IoT Hub分区数量（仅适用于未上线项目） #

• 如果项目还处于初期阶段，可以将IoT Hub的分区数设置为1，这样所有设备的事件都会进入同一个分区，Event Processor Host只会启动一个处理线程，天然实现串行处理。但这种方式会限制IoT Hub的最大吞吐量，不适合高并发场景。

当前配置补充优化 #

如果继续使用IoT Hub Trigger，需要在host.json中补充maxConcurrentCalls配置，确保单个分区内的事件串行处理，但这无法解决多分区并行的问题，需结合上述方案：

"eventHub": {
  "eventProcessorOptions": {
    "maxBatchSize": 1,
    "prefetchCount": 10,
    "maxConcurrentCalls": 1
  }
}

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