BlobCheckpointStore クラス
定義
重要
一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。
永続化のために Azure Storage BLOB を使用して、イベント プロセッサ操作に必要なチェックポイントと所有権データとの対話を許可します。
public class BlobCheckpointStore : Azure.Messaging.EventHubs.Primitives.CheckpointStore
type BlobCheckpointStore = class
inherit CheckpointStore
Public Class BlobCheckpointStore
Inherits CheckpointStore
- 継承
コンストラクター
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) |
特定のパーティションのチェックポイントを作成または更新し、イベント プロセッサが読み取りを開始するパーティションのイベント ストリーム内の位置を識別します。 |
適用対象
Azure SDK for .NET