c# - 使用新的 .NET SDK Azure.Messaging.EventHubs 通过 EventProcessorClient 进行检查点

标签 c# .net azure azure-eventhub azure-sdk-.net

如何使用 new Azure SDK 在特定时间或指定数量的事件后定期保存检查点?

该示例仅使用 "InMemoryPartitionManager"这不会保存当前状态。

然后有一个BlobPartitionManager它将状态保存在 blob 存储中,但似乎它保存了每个事件的状态,如果有很多事件,这可能会变得相当昂贵。

在 EventProcessorClient 和 BlobPartitionManager 上我都找不到任何仅在特定时间间隔内保存的选项。

最佳答案

据我所知,“BlobPartitionManager”是一个很好的解决方案。它只是在读取操作后将一个小于 1kb 的 json 文件存储在 azure blob 存储中。所以我认为它不会占用你太多的存储空间。可以引用这个tutorial要了解更多有关存储 blob 的价格,我认为存储这么小的东西并不太贵。

关于c# - 使用新的 .NET SDK Azure.Messaging.EventHubs 通过 EventProcessorClient 进行检查点,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/58978369/

相关文章:

c# - 此数据集不支持 GET 表方法 - 未实现

c# - 强制刷新到 Observable.Buffer c#

C# Excel VSTO - 可以移动数据透视表吗?

Git 推送到 Azure 失败(RPC 失败)

c# - 测试方法 : async Task TestSth() does not work with . NET 4.0

c# - 用于在 C# 中的 .vdproj 文件中查找和替换任何产品名称值的 .NET 正则表达式

c# Linq for XML : tag. 后代不允许询问所有后代

c# - 错误 : Can't choose dates on a DatePicker that fall outside a floating VSTO Add-In

azure - 横向扩展时限制*标准* azure webjob 的实例数量

sql-server - 在租户中找不到 Active Directory 对象 ''