Azure函数事件中心触发器可靠性

Question

我对Azure函数的EventHubTrigger有点困惑。

我有一个物联网集线器，我正在使用它与eventhub兼容的endpoint来触发一个Azure函数，该函数将处理和存储接收到的数据。

但是，如果我的函数失败（=抛出异常），在函数调用期间正在处理的消息（或消息）将丢失。实际上，我希望Azure函数运行时在稍后再次处理消息。具体来说，我预计会有这种行为，因为EventHubTrigger正在功能应用存储帐户中保留检查点，以便跟踪事件流中必须继续的位置。

EventHubTrigger的文档甚至指出

如果所有函数执行成功且无错误，则将检查点添加到关联的存储帐户

但是，即使我故意在函数中抛出异常，检查点也会更新，消息也不会再次收到。

我对EventHubTriggers文档的理解是否错误，或者EventHubTriggers实现（或其文档）是否错误？

Answer 1

快速修复。因为，如果系统停机数小时，重试策略将不起作用。您可以调用进程。GetCurrentProcess（）。杀死（）；在异常处理中。这将阻止检查站向前移动。我已经用基于消费的功能应用程序测试过了。您将不会在日志中看到任何内容，但我添加了电子邮件，以通知出现了问题，并避免数据丢失，我已终止函数实例。希望这有帮助。我会在它和工作流程的其他部分上放一个博客，如果使用logic app的系统出现持续故障，我会在上面停止运行。

Answer 2

这篇文档看起来确实令人困惑。我猜它们是指函数应用程序主机本身的错误，而不是您的代码。函数执行中的异常不会停止处理和检查点过程。

事实上，事件集线器不是为单个消息重试而设计的。处理器分批工作，它可以将整个批标记为已处理（即在其之后创建检查点），也可以重试整个批（例如，如果进程崩溃）。

见本论坛问答。

如果您仍然需要从事件中心重新处理失败的事件（并且错误不会经常发生），您可以自己实现这种机制。例如。

1. 将输出队列绑定添加到Azure函数。
2. 在处理代码周围添加try-cat。
3. 如果抛出异常，将有问题的事件添加到队列中。
4. 有另一个带有队列触发器的函数来处理这些事件。

请注意，这样做的缺点是您将失去由事件集线器提供的排序保证（因为队列消息的处理将晚于其邻居）。