你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn

BlobCheckpointStore 类

定义

允许与事件处理程序操作所需的检查点和所有权数据交互,使用 Azure 存储 Blob 进行持久性。

public class BlobCheckpointStore : Azure.Messaging.EventHubs.Primitives.CheckpointStore
type BlobCheckpointStore = class
    inherit CheckpointStore
Public Class BlobCheckpointStore
Inherits CheckpointStore
继承
BlobCheckpointStore

构造函数

BlobCheckpointStore(BlobContainerClient)

初始化 BlobCheckpointStore 类的新实例。

方法

ClaimOwnershipAsync(IEnumerable<EventProcessorPartitionOwnership>, CancellationToken)

尝试声明要处理的指定分区的所有权。 此操作由负载均衡用于在活动事件处理程序之间分配处理事件中心和使用者组配对的分区的责任。

GetCheckpointAsync(String, String, String, String, CancellationToken)

请求特定分区的检查点信息,使事件处理程序能够继续从流中的下一个事件读取。

ListOwnershipAsync(String, String, String, CancellationToken)

请求给定事件中心和使用者组配对的每个协作事件处理程序实例之间的分区的所有权分配列表。 此操作在负载均衡期间用于允许处理器发现其他活动协作者,并决定如何最好地平衡它们之间的工作。

UpdateCheckpointAsync(String, String, String, String, Int64, Nullable<Int64>, CancellationToken)

创建或更新特定分区的检查点,标识处理器应从该分区的事件流中读取的位置。

适用于