azure-functions - 在本地运行时，带有 QueueTrigger 的 Azure 函数(.Net Core 上的 v2)不支持 BatchSize

Question

我正在使用 host.json 文件中的以下配置在本地使用 QueueTrigger 测试我的 Azure 功能(面向 .Net Core 的 v2)

“队列”:{
“批量大小”:1，
“新批次阈值”:0
}

目的是限制每个 Function App 实例一次只能处理一个队列 msg。

根据 this Azure function doc ,

If you want to minimize parallel execution for queue-triggered functions in a function app, you can set the batch size to 1. This setting eliminates concurrency only so long as your function app runs on a single virtual machine (VM).

在 host.json 文件中，有这些配置

{
“队列”:{
"maxPollingInterval": 2000,
"visibilityTimeout": "00:00:30",
“批量大小”:16，
"maxDequeueCount": 5,
“新批次阈值”:8
}
}

在我们的例子中，我不是要消除并发性，而是要确保每个函数应用实例一次只能处理一个队列 msg。然后，如果我们横向扩展函数应用以在多个 VM 上运行，则每个 VM 都可以保证一次仅处理一个队列 msg。更具体地说，计划是在App Service计划下运行azure功能，而不是Consumption计划(b/c你对Consumption计划的控制很少)，并设置Scale Out规则来监控一个队列，最多N 个实例 (VM)。这种设置允许我们让每个 VM 一次运行一个 azure 函数应用程序实例，最多 N 个 VM。

当我在本地测试时，我的 azure 函数总是同时从队列中获取多个消息，即使在 host.json 文件中使用“BatchSize: 1”配置也是如此。我想知道它是否是 b/c 我正在本地 Azure 函数运行时测试它。我还没有在 Azure 中测试过这个。希望它在 Azure 中按预期工作。

Answer 1

问题原来是“队列”没有嵌套在“扩展”下

示例:

{
    "version": "2.0",
    "extensions": {
        "queues": {
            "maxPollingInterval": "00:00:02",
            "visibilityTimeout" : "00:00:30",
            "batchSize": 16,
            "maxDequeueCount": 5,
            "newBatchThreshold": 8
        }
    }
}

在这种情况下，引用的扩展名( Microsoft.Azure.WebJobs.Extensions.Storage 也应该至少是 3.0.1，因为之前有 a bug 并将 newBatchThreshold 设置为 0。