Azure函数：使用队列触发器和消费计划上的FunctionalPpscaleLimit扩展和并发

Question

我在Linux消费计划上有一个Azure函数应用程序，它有两个队列触发器。两个队列触发器都将＜code＞batchSize

如果我希望允许这两个队列触发器并发运行，但不希望它们的规模超过这个范围，那么将< code > functionAppScaleLimit 设置为< code>2是否足以实现这一点？

编辑：添加了新的示例，感谢@Hury沈为这些示例提供框架

现在，我想我将继续使用最后一个示例，但在将来，如果我升级到高级计划，我可以安全地将＜code＞functionAppScaleLimit＜code＞设置为＜code＞2＜code＞或＜code＞3＜code＞。我还将测试两个队列触发器，它们使用2的functionAppScaleLimit，侦听不同的存储队列，但我怀疑最安全的做法是为该场景中的每个队列触发器创建单独的Azure函数应用程序。

编辑 2：在一个函数应用中为两个队列触发器添加示例

在< code > functionAppScaleLimit 设置为< code>2的情况下，两个队列触发器同时运行，看起来规模限制不起作用。微软的人能解释一下吗？官方文档(https://docs . Microsoft . com/en-us/azure/Azure-functions/functions-scale # limit-scale-out)中并没有警告这个设置处于预览模式，然而我们可以清楚地看到，当限制设置为2时，Azure函数正在向外扩展到4个实例。在下面的例子中，看起来限制得到了遵守，但是功能不是我想要的，我们仍然看到@Hury Shen的回答中存在的等待。

结论< br >要使用队列触发器来限制Azure函数中的并发性和控制缩放，您必须将您的Azure函数限制为每个函数应用程序使用一个队列触发器，并使用< code>batchSize和< code > functionAppScaleLimit 设置。如果使用多个队列触发器，您将会遇到可能导致超时的竞争条件和等待。

Answer 1

是的，您只需要将functionAppScaleLimit设置为2。但关于消费计划，你需要了解一些机制。我用＜code＞batchSize（我在函数app的“应用程序设置”中将＜code＞WEBSITE_MAX_DYNAMIC_APPLICATION_SCALE_OUT＜/code＞设置为 ，而不是设置＜code＞功能ppscaleLimit＜/code>，它们是相同的）。我用下面的代码进行测试：

import logging
import azure.functions as func
import time

def main(msg: func.QueueMessage) -> None:
    logging.info('=========sleep start')
    time.sleep(30)
    logging.info('=========sleep end')
    logging.info('Python queue trigger function processed a queue item: %s',
                 msg.get_body().decode('utf-8'))

我将“s2”到“s4”的单元格设为黄色，因为这段时间指的是功能任务的执行时间。

根据excel的截图，我们可以推断出以下几点：

最大实例数只能扩展到2，因为我们可以找到它在excel表的每行中不存在两个以上的黄色单元格。因此，正如您在问题中提到的，该函数不能扩展到2个以上的实例。

2.你想让这两个队列触发器同时运行，可以实现。但是实例会通过消耗机制横向扩展。简单来说，当一个函数实例被一条消息触发，还没有完成任务，现在有另一条消息进来时，它不能确保使用另一个实例。第二条消息可能正在等待第一个实例。我们无法控制是否启用另一个实例。

=====更新==============================

由于我不太清楚您的描述，我不确定您要侦听多少个存储队列，以及您在这边创建了多少函数应用程序和QueueTrigger函数。我总结我的测试结果如下，供您参考：

1.对于您关于＜code＞的问题，您在保费计划中描述的最大突发事件是否与此不同我认为如果我们选择premium plan，实例也将使用相同的消费计划机制进行扩展。

2.如果需要监听两个存储队列，当然我们应该创建两个QueueTrigger函数来监听每个存储队列。

3.如果您只需要监听一个存储队列，我将使用三种情况进行测试（在所有三种情况下，我将最大规模实例设置为2）：

A） 在一个函数应用程序中创建一个QueueTrigger函数，以侦听一个存储队列。这是我在原始答案中测试的，excel表显示了实例将根据消费计划的机制扩展，我们无法控制它。

B） 在一个函数应用程序中创建两个QueueTrigger函数，以侦听同一存储队列。结果与案例A几乎相同，我们无法控制使用多少实例来处理消息。

C）创建两个函数应用程序并在每个函数应用程序中创建一个QueueTrigger函数以侦听相同的存储队列。结果也类似于情况A和B，不同之处在于最大实例可以缩放到4，因为我创建了两个函数应用程序（它们都可以缩放到2个实例）。

总之，我认为这三种情况都是相似的。虽然我们选择了第三种情况，但是创建两个函数应用程序，每个应用程序中有一个QueueTrigger函数。我们也不能确保第二个消息立即被处理，它仍然可能被处理到第一个实例，并等待第一个实例完成处理第一个消息。

因此，在这篇文章< code >中，您当前问题的答案是将functionAppScaleLimit设置为2足以实现这一点吗？是:如果您希望两个实例能够并发运行，我们无法确保这一点。如果您只想用两个实例来处理消息，答案是肯定的。