我正在使用azure-eventhub官方lib从EventHub的主题中读取事件。我希望能够在接收器停止读取时使用EventHub保持接收器组的最后一个偏移量，因此当我再次开始读取时，可以从停止的位置开始。这是在Kafka中使用提交策略完成的，但是在azure-eventhub库中找不到任何类似的东西。 azure-eventhub或eventhub的任何其他python库中是否有类似的东西？
您可以在python中使用事件处理器主机将检查点设置为Blob存储。
详细的示例代码在github中为here，我们将其用于检查点。
使用事件处理器主机]之前，您应该具有/创建用于保存检查点的azure storage account。并在该Azure存储帐户中输入create a container。示例代码中的storage account使用account key /container/ here。
在示例中，此行代码context.checkpoint_async()用于设置检查点。
[如果您还有其他疑问，请告诉我。