Azure Function Event Hub一次触发一批

Question

我正在开发一个通过事件中心获取更改通知的项目(https: //learn.microsoft.com/en-us/graph/change-notifications-delivery）。

我的Azure函数（事件接收器）批量接收事件。收到每个批次后，它会处理数据（做一些工作）。第二批更新第一批设置的值。

事件中心有 3 个分区。

当多个批次同时到达时就会出现问题。 。第二批在第一批更新值之前进入。

有没有办法一次只接收一批？

我不关心批次的顺序，但我想仅在处理第一个批次后才获取下一个批次触发器。

提前致谢。

Answer 1

谢谢BrunoLucas-9843和MughundhanRaveendran-MSFT 提供了宝贵的解释和一些解决方法。将您的建议作为答案发布以帮助其他社区成员。

• 查看这篇文章关于为函数提取一批 1 条消息的 maxBatchSize 配置，以及在传递单个事件与有序批次时降低成本的更好方法。

有没有办法让事件中心触发器等到第一批处理完毕？

• 一旦您发送事件并到达集线器，触发函数就会拉动该事件。还有天蓝色的函数并行性使事情变得更加复杂。

• 我能想到的最好方法是编写这样的方法：https://learn.microsoft.com/en-us/azure/event-hubs/event-hubs-dotnet-standard-getstarted-send#receive-events 并使用计时器触发器来拉动它每“X”分钟是处理一整批所需的平均时间（加上一些额外的时间以确保全部清除）。

我看到 azure hub 的逻辑应用触发器可以一次拉取固定数量的事件并等待：
https： //learn.microsoft.com/en-us/azure/connectors/connectors-create-api-azure-event-hubs#trigger-polling-behavior

此外，您可以尝试在 function.json 中将基数设置为 1 并在最后进行测试。
https： //learn.microsoft.com/en-us/azure/azure-functions/functions-bindings-event-hubs-trigger?tabs=csharp#configuration

是否可以使用Durable Function来实现顺序处理？

是的，通过利用上述建议的方法，也可以实现持久和正常的天蓝色功能。对于持久函数，您可以使用函数链接：https://learn.microsoft.com/en-us/azure/azure-functions/durable/durable-functions-overview?tabs=csharp#chaining。

在持久函数中，有协调器和活动函数，如果其中一个活动函数失败，它将向协调器返回错误响应。整个实例不会失败，你将能够处理异常