如何使用 Azure EventHub Trigger to Functions 返回检查点?

How to go back to a checkpoint with Azure EventHub Trigger to Functions?

我有一个使用 Azure Functions 应用程序实现的 EventHub 触发器。我的业务逻辑实现在那个函数中是错误的,必须更正它。我已经更正了我在 Functions App 上的实现,我如何将检查点更改为该 Azure Functions 以返回 24 小时并使流数据可用于 Functions App?

当我需要从头开始处理 Hub 中的事件时,我转到 Blob 存储 -> azure-webjobs-hosts 容器并删除了名称如 yournamespace.servicebus.windows.net/yourhub/$Default/X 的 blob。这些 blob 存储当前检查点,因此如果您重新启动 Function App,它将从第一个事件开始处理。

我知道这很老套,但适用于这种基本场景。也许有人会提出更好的方法。

问题仍然存在,您可能不知道 24 小时前每个分区使用的序列号,否则,Mikhail 的建议可能适用于修改后的步骤,即进入每个 blob 并编辑序列号,而不是删除所有blob 条目。

您可能应该从头开始。以下是步骤:

  1. 转到 EventHub 门户。
  2. 创建一个新的消费者组,例如将其命名为 "GroupB"
  3. 编辑您的 function.json 并将以下条目添加到触发器部分,

"consumerGroup": "GroupB"

  1. 保存您的更改。

您应该看到您的函数将从 GroupB 消费者组的最开始开始处理事件。