如何实现每条Azure服务总线队列消息对应一个Azure Function实例

场景与需求 #

• 使用Azure服务总线队列触发Azure Functions
• 运行时版本1，消耗计划，基于.NET4.8开发
• 核心需求：每条队列消息对应一个Function实例（如200条消息对应200个实例）
• 限制：无法升级到运行时v4或.NET6，会话模式不可用

当前问题 #

已配置以下属性但仅启动单个实例，未实现多实例并行处理：

"maxConcurrentCalls": 1, "maxConcurrentSessions": 1, "maxMessageBatchSize": 1, "minMessageBatchSize": 1

针对v1版本的解决方案 #

1. 修正host.json配置（v1专属结构） #

v1版本的Service Bus触发器配置为host.json顶级节点，需调整为：

{
  "serviceBus": {
    "maxConcurrentCalls": 1,
    "prefetchCount": 1
  }
}

• maxConcurrentCalls=1：限制单个实例同时处理1条消息
• prefetchCount=1：限制单个实例仅预取1条消息，避免单实例占用多条消息导致其他实例无消息可处理

2. 门户应用设置配置（部署后生效） #

如果通过Azure门户管理配置，添加以下应用设置：

• AzureWebJobsServiceBus.MaxConcurrentCalls = 1
• AzureWebJobsServiceBus.PrefetchCount = 1

3. 触发多实例缩放的关键条件 #

确保满足以下条件，平台才会启动多实例：

• 队列中存在足够数量的待处理消息（如200条）
• 单条消息执行时长需达到一定阈值（建议1-2秒）：若消息处理过快，单个实例即可完成全部处理，平台不会触发缩放
• 未触及消耗计划默认实例上限（v1消耗计划默认最大实例数为200，满足需求）

4. 排查与验证 #

• 查看Azure Monitor的函数实例数指标，确认是否有实例自动启动
• 检查消息锁时长：确保锁时长大于单条消息处理时间，避免锁过期导致重复处理
• 排查函数日志：确认是否有实例启动失败或缩放限制的相关报错

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