PluggableCheckpointStoreEventProcessor<TPartition> クラス
定義
重要
一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。
特定のコンシューマー グループの特定のイベント ハブのすべてのパーティションでイベントを使用するカスタム処理ロジックを使用して、イベント プロセッサを作成するためのベースを提供します。 プロセッサは、同じ Event Hub とコンシューマー グループのペアリングに対して他のインスタンスと共同作業を行い、共通のストレージ プラットフォームを使用して通信することで作業を共有できます。 フォールト トレランスも組み込まれているため、エラーが発生した場合にプロセッサに回復性を持たせます。
public abstract class PluggableCheckpointStoreEventProcessor<TPartition> : Azure.Messaging.EventHubs.Primitives.EventProcessor<TPartition> where TPartition : EventProcessorPartition, new()type PluggableCheckpointStoreEventProcessor<'Partition (requires 'Partition :> EventProcessorPartition and 'Partition : (new : unit -> 'Partition))> = class
inherit EventProcessor<'Partition (requires 'Partition :> EventProcessorPartition and 'Partition : (new : unit -> 'Partition))>Public MustInherit Class PluggableCheckpointStoreEventProcessor(Of TPartition)
Inherits EventProcessor(Of TPartition)型パラメーター
- TPartition
操作が実行されているパーティションのコンテキスト。
- 継承
注釈
インスタンス間 PluggableCheckpointStoreEventProcessor<TPartition> でパーティションを共有するための調整を有効にするために、コンシューマー グループのパーティションに対する排他的読み取りアクセスをアサートします。 共同作業を行うプロセッサ以外のコンシューマー グループでは、他のリーダーをアクティブにする必要はありません。 排他的でないリーダーはアクセスを拒否されます。別のストレージの場所を使用するプロセッサを含む排他的リーダーは、プロセッサの操作とパフォーマンスに干渉します。
PluggableCheckpointStoreEventProcessor<TPartition>は、アプリケーションの有効期間中は安全にキャッシュして使用できます。これは、アプリケーションがイベントを定期的または半定期的に処理する場合にベスト プラクティスです。 プロセッサは、効率的なリソース管理の責任を負い、非アクティブな期間中はリソース使用量を低く抑え、使用率が高い期間中は正常性を管理します。 処理が完了したとき、またはアプリケーションのシャットダウン時に メソッドまたは StopProcessing(CancellationToken) メソッドをStopProcessingAsync(CancellationToken)呼び出すと、ネットワーク リソースやその他のアンマネージ オブジェクトが適切にクリーンアップされます。
コンストラクター
プロパティ
| ConsumerGroup |
このイベント プロセッサが関連付けられているコンシューマー グループの名前。 イベントは、このグループのコンテキストでのみ読み取られます。 (継承元 EventProcessor<TPartition>) |
| EventHubName |
プロセッサが接続されているイベント ハブの名前。プロセッサを含む Event Hubs 名前空間に固有です。 (継承元 EventProcessor<TPartition>) |
| FullyQualifiedNamespace |
プロセッサが関連付けられている完全修飾 Event Hubs 名前空間。 これは と似ている |
| Identifier |
このイベント プロセッサを識別するために使用される一意の名前。 (継承元 EventProcessor<TPartition>) |
| IsRunning |
このイベント プロセッサが現在実行されているかどうかを示します。 (継承元 EventProcessor<TPartition>) |
| RetryPolicy |
プロセッサの再試行を制御するアクティブなポリシー。 (継承元 EventProcessor<TPartition>) |
メソッド
| ClaimOwnershipAsync(IEnumerable<EventProcessorPartitionOwnership>, CancellationToken) |
処理のために、指定されたパーティションの所有権の要求を試みます。 この操作は、負荷分散によって使用され、アクティブなイベント プロセッサ間でイベント ハブとコンシューマー グループのペアリングのパーティションを処理する役割を分散できます。 |
| CreateConnection() |
EventHubConnection Event Hubs サービスとの通信に使用する を作成します。 (継承元 EventProcessor<TPartition>) |
| GetCheckpointAsync(String, CancellationToken) |
特定のパーティションの処理を適切に初期化できるように、イベント プロセッサ インスタンスに関連付けられているパーティションの Event Hub、コンシューマー グループ、および識別子のチェックポイントを返します。 |
| ListOwnershipAsync(CancellationToken) |
特定のイベント ハブとコンシューマー グループのペアリングに対応する各イベント プロセッサ インスタンス間のパーティションの所有権の割り当ての一覧を要求します。 この方法は、負荷分散中に使用され、プロセッサが他のアクティブなコラボレーターを検出し、それらの間で作業のバランスを最適に調整する方法を決定できるようにします。 |
| ListPartitionIdsAsync(EventHubConnection, CancellationToken) |
Event Hub パーティションの識別子を照会します。 (継承元 EventProcessor<TPartition>) |
| OnInitializingPartitionAsync(TPartition, CancellationToken) |
イベント処理のためにパーティションとそれに関連付けられているコンテキストを初期化するタスクを実行します。 (継承元 EventProcessor<TPartition>) |
| OnPartitionProcessingStoppedAsync(TPartition, ProcessingStoppedReason, CancellationToken) |
パーティションの処理が停止しているときに必要なタスクを実行します。 これは、通常、パーティションが別のイベント プロセッサ インスタンスによって要求された場合、または現在のイベント プロセッサ インスタンスがシャットダウンするときに発生します。 (継承元 EventProcessor<TPartition>) |
| OnProcessingErrorAsync(Exception, TPartition, String, CancellationToken) |
イベント プロセッサ インフラストラクチャの操作内で予期しない例外が発生したときに必要なタスクを実行します。 (継承元 EventProcessor<TPartition>) |
| OnProcessingEventBatchAsync(IEnumerable<EventData>, TPartition, CancellationToken) |
Event Hubs サービスから読み取られた特定のパーティションのイベントのバッチを処理するために必要なタスクを実行します。 (継承元 EventProcessor<TPartition>) |
| ReadLastEnqueuedEventProperties(String) |
イベントが Event Hubs サービスから受信されると、このコンテキストに関連付けられている EventHubs クライアントによって観察される、パーティションの最後のエンキューイベントに関する一連の情報。 これは、コンシューマーが set で TrackLastEnqueuedEventProperties 作成された場合にのみ使用できます。 (継承元 EventProcessor<TPartition>) |
| StartProcessing(CancellationToken) |
イベントの処理を EventProcessor<TPartition> 開始するように を通知します。 プロセッサの実行中にこのメソッドを呼び出しても、アクションは実行されません。 (継承元 EventProcessor<TPartition>) |
| StartProcessingAsync(CancellationToken) |
イベントの処理を EventProcessor<TPartition> 開始するように を通知します。 プロセッサの実行中にこのメソッドを呼び出しても、アクションは実行されません。 (継承元 EventProcessor<TPartition>) |
| StopProcessing(CancellationToken) |
イベントの処理を EventProcessor<TPartition> 停止するように を通知します。 プロセッサの実行中にこのメソッドを呼び出しても、何も実行されません。 (継承元 EventProcessor<TPartition>) |
| StopProcessingAsync(CancellationToken) |
イベントの処理を EventProcessor<TPartition> 停止するように を通知します。 プロセッサの実行中にこのメソッドを呼び出しても、何も実行されません。 (継承元 EventProcessor<TPartition>) |
| UpdateCheckpointAsync(String, Int64, Nullable<Int64>, CancellationToken) |
特定のパーティションのチェックポイントを作成または更新し、イベント プロセッサが読み取りを開始するパーティションのイベント ストリーム内の位置を識別します。 |
| ValidateProcessingPreconditions(CancellationToken) |
プロセッサが機能するために必要な依存関係の基本的な構成とアクセス許可を検証するために必要なタスクを実行します。 (継承元 EventProcessor<TPartition>) |
適用対象
Azure SDK for .NET