Azure Eventhub - 如何将同一批事件重新发送/重播到同一 Eventhub 客户端

Question

比方说，当处理来自 Azure EventHub 的批量事件时发生 transient 故障并且 transient 故障即使在重试后仍然持续，那么可以从处理器向 Eventhub 抛出哪种异常？以便 Azure eventhub 能够再次将同一批事件发送(重播)到同一处理器实例(不向前移动检查指针)进行重新处理。

包“Microsoft.Azure.WebJobs.Extensions.EventHubs”版本=“5.1.2”

Azure 函数是在具有 KEDA 扩展配置的 AKS 上运行的客户端

Answer 1

简而言之 - 您的代码不会抛出异常，导致 Azure Function 应用中的检查点停止。

函数具有独特的模型，因为检查点是自动的，并且无论正在执行的处理代码成功还是失败，它都会向前推进。

当您的函数遇到无法处理事件的错误时，最常见的模式是将其设置为死信，以便其他应用程序将来可以重新访问并处理它。更多细节和其他需要考虑的模式可以在文章 Resilient Event Hubs and Functions design 中找到。 .

如果这些在您的应用程序场景中都不起作用，那么您的最佳途径可能是考虑不使用 Functions 作为主机平台，而是直接在应用程序中使用事件处理器。这将使您完全控制何时发出检查点。