BlobCheckpointStore クラス

定義

名前空間:

Azure.Messaging.EventHubs.Primitives

アセンブリ:

Azure.Messaging.EventHubs.Processor.dll

パッケージ:

Azure.Messaging.EventHubs.Processor v5.10.0

永続化のために Azure Storage BLOB を使用して、イベント プロセッサ操作に必要なチェックポイントと所有権データとの対話を許可します。

public class BlobCheckpointStore : Azure.Messaging.EventHubs.Primitives.CheckpointStore

type BlobCheckpointStore = class
    inherit CheckpointStore

Public Class BlobCheckpointStore
Inherits CheckpointStore

継承

Object

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)	特定のパーティションのチェックポイントを作成または更新し、イベント プロセッサが読み取りを開始するパーティションのイベント ストリーム内の位置を識別します。