EventProcessorHost クラス

定義

Event Hubs イベント データを処理するためのホストを表します。

public sealed class EventProcessorHost
type EventProcessorHost = class
Public NotInheritable Class EventProcessorHost
継承
EventProcessorHost

コンストラクター

EventProcessorHost(String, String, String, String, ICheckpointManager, ILeaseManager)

イベント ハブからのイベントを処理する新しいホストを作成します。

コンストラクターのこのオーバーロードにより、最大限の柔軟性が得ることができます。 これにより、呼び出し元はプロセッサ ホストの名前も指定できます。 また、オーバーロードを使用すると、呼び出し元は独自のリース マネージャーとチェックポイント マネージャーを提供して、Azure Storage に基づいて組み込みのマネージャーを置き換えることができます。

EventProcessorHost(String, String, String, String, String)

イベント ハブからのイベントを処理する新しいホストを作成します。

Event Hubs はスケールアウト、トラフィックの多いシナリオで頻繁に使用されるため、一般にプロセスごとに 1 つのホストのみが存在し、プロセスは別々のマシンで実行されます。 ただし、スループットが問題でない場合は、1 台のマシン上、または 1 つのプロセス内で複数のホストを実行することがサポートされています。

コンストラクターのこのオーバーロードでは、既定の組み込みのリース マネージャーとチェックポイント マネージャーが使用されます。 storageConnectionString パラメーターで指定された Azure Storage アカウントは、組み込みのマネージャーによってリースとチェックポイントを記録するために使用されます。

EventProcessorHost(String, String, String, String, String, String, String)

イベント ハブからのイベントを処理する新しいホストを作成します。

コンストラクターのこのオーバーロードでは、既定の組み込みのリース マネージャーとチェックポイント マネージャーが使用されます。

EventProcessorHost(String, Uri, String, String, ITokenProvider, CloudStorageAccount, String, String, Nullable<TimeSpan>, TransportType)

指定したイベント ハブからのイベントを処理する新しいホストを作成する TokenProvider

EventProcessorHost(String, Uri, String, String, ITokenProvider, ICheckpointManager, ILeaseManager, Nullable<TimeSpan>, TransportType)

指定したイベント ハブからのイベントを処理する新しいホストを作成する TokenProvider

EventProcessorHost(Uri, String, String, ITokenProvider, CloudStorageAccount, String)

指定したイベント ハブからのイベントを処理する新しいホストを作成する TokenProvider

EventProcessorHost(Uri, String, String, ITokenProvider, CloudStorageAccount, String, String, Nullable<TimeSpan>, TransportType)

指定したイベント ハブからのイベントを処理する新しいホストを作成する TokenProvider

プロパティ

ConsumerGroupName

コンシューマー グループ名を取得します。

EndpointAddress

イベント エンドポイント URI を取得します。

EventHubPath

イベント ハブのパスを取得します。

HostName

プロセッサ ホスト名を返します。 プロセッサ ホスト名が自動的に生成された場合、これを取得する唯一の方法です。

OperationTimeout

操作のタイムアウトを取得します。

PartitionManagerOptions

オブジェクトによって使用されるインスタンスをPartitionManagerOptionsEventProcessorHost取得または設定します。

TransportType

トランスポートの種類を取得します。

メソッド

RegisterEventProcessorAsync<T>()

これにより、 を IEventProcessor 使用して Microsoft.Azure.EventHubs.Processor.DefaultEventProcessorFactory`1ホストに実装が登録されます。 これによりホストも開始され、パーティション分散プロセスへの参加が開始されます。

RegisterEventProcessorAsync<T>(EventProcessorOptions)

これにより、 を IEventProcessor 使用して Microsoft.Azure.EventHubs.Processor.DefaultEventProcessorFactory`1ホストに実装が登録されます。 これによりホストも開始され、パーティション分散プロセスへの参加が開始されます。

RegisterEventProcessorFactoryAsync(IEventProcessorFactory)

これにより、パーティションの IEventProcessorFactory 所有権を取得するときに の IEventProcessor インスタンスを作成するために使用されるホストに実装が登録されます。 これによりホストも開始され、パーティション分散プロセスへの参加が開始されます。

RegisterEventProcessorFactoryAsync(IEventProcessorFactory, EventProcessorOptions)

これにより、パーティションの IEventProcessorFactory 所有権を取得するときに の IEventProcessor インスタンスを作成するために使用されるホストに実装が登録されます。 これによりホストも開始され、パーティション分散プロセスへの参加が開始されます。

UnregisterEventProcessorAsync()

イベントの処理を停止します。 シャットダウンが完了するまで戻りません。

適用対象