EventProcessorHost コンストラクター

リファレンス

定義

名前空間:: Microsoft.Azure.EventHubs.Processor

アセンブリ:: Microsoft.Azure.EventHubs.Processor.dll

パッケージ:: Microsoft.Azure.EventHubs.Processor v4.3.2

重要

一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。

オーバーロード

EventProcessorHost(String, String, String, String, String)	イベントハブからのイベントを処理する新しいホストを作成します。 Event Hubs はスケールアウト、トラフィックの多いシナリオで頻繁に使用されるため、一般にプロセスごとに 1 つのホストのみが存在し、プロセスは別々のマシンで実行されます。ただし、スループットが問題でない場合は、1 台のマシン上、または 1 つのプロセス内で複数のホストを実行することがサポートされています。コンストラクターのこのオーバーロードでは、既定の組み込みのリースマネージャーとチェックポイントマネージャーが使用されます。 storageConnectionString パラメーターで指定された Azure Storage アカウントは、組み込みのマネージャーによってリースとチェックポイントを記録するために使用されます。
EventProcessorHost(String, String, String, String, ICheckpointManager, ILeaseManager)	イベントハブからのイベントを処理する新しいホストを作成します。コンストラクターのこのオーバーロードにより、最大限の柔軟性が得ることができます。これにより、呼び出し元はプロセッサホストの名前も指定できます。また、オーバーロードを使用すると、呼び出し元は独自のリースマネージャーとチェックポイントマネージャーを提供して、Azure Storage に基づいて組み込みのマネージャーを置き換えることができます。
EventProcessorHost(Uri, String, String, ITokenProvider, CloudStorageAccount, String)	指定したイベントハブからのイベントを処理する新しいホストを作成する TokenProvider
EventProcessorHost(String, String, String, String, String, String, String)	イベントハブからのイベントを処理する新しいホストを作成します。コンストラクターのこのオーバーロードでは、既定の組み込みのリースマネージャーとチェックポイントマネージャーが使用されます。
EventProcessorHost(String, Uri, String, String, ITokenProvider, ICheckpointManager, ILeaseManager, Nullable<TimeSpan>, TransportType)	指定したイベントハブからのイベントを処理する新しいホストを作成する TokenProvider
EventProcessorHost(Uri, String, String, ITokenProvider, CloudStorageAccount, String, String, Nullable<TimeSpan>, TransportType)	指定したイベントハブからのイベントを処理する新しいホストを作成する TokenProvider
EventProcessorHost(String, Uri, String, String, ITokenProvider, CloudStorageAccount, String, String, Nullable<TimeSpan>, TransportType)	指定したイベントハブからのイベントを処理する新しいホストを作成する TokenProvider

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

ソース:: EventProcessorHost.cs

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

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

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

public EventProcessorHost (string eventHubPath, string consumerGroupName, string eventHubConnectionString, string storageConnectionString, string leaseContainerName);

new Microsoft.Azure.EventHubs.Processor.EventProcessorHost : string * string * string * string * string -> Microsoft.Azure.EventHubs.Processor.EventProcessorHost

Public Sub New (eventHubPath As String, consumerGroupName As String, eventHubConnectionString As String, storageConnectionString As String, leaseContainerName As String)

パラメーター

eventHubPath: String

EventHub の名前。

consumerGroupName: String

イベントハブ内のコンシューマーグループの名前。

eventHubConnectionString: String

受信元のイベントハブの接続文字列。

storageConnectionString: String

リースとチェックポイント処理に使用される Azure Storage アカウントへの接続文字列。

leaseContainerName: String

組み込みのリースおよびチェックポイントマネージャーで使用する Azure Storage コンテナー名。

適用対象

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

ソース:: EventProcessorHost.cs

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

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

public EventProcessorHost (string hostName, string eventHubPath, string consumerGroupName, string eventHubConnectionString, Microsoft.Azure.EventHubs.Processor.ICheckpointManager checkpointManager, Microsoft.Azure.EventHubs.Processor.ILeaseManager leaseManager);

new Microsoft.Azure.EventHubs.Processor.EventProcessorHost : string * string * string * string * Microsoft.Azure.EventHubs.Processor.ICheckpointManager * Microsoft.Azure.EventHubs.Processor.ILeaseManager -> Microsoft.Azure.EventHubs.Processor.EventProcessorHost

Public Sub New (hostName As String, eventHubPath As String, consumerGroupName As String, eventHubConnectionString As String, checkpointManager As ICheckpointManager, leaseManager As ILeaseManager)

パラメーター

hostName: String

プロセッサホストの名前。一意である必要があります。一意性を確保するために Guid を含めることを強くお勧めします。

eventHubPath: String

EventHub の名前。

consumerGroupName: String

イベントハブ内のコンシューマーグループの名前。

eventHubConnectionString: String

受信元のイベントハブの接続文字列。

checkpointManager: ICheckpointManager

パーティションのチェックポイント処理を処理する ICheckpointManager を実装するオブジェクト。

leaseManager: ILeaseManager

パーティションのリースを処理する ILeaseManager を実装するオブジェクト。

適用対象

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

ソース:: EventProcessorHost.cs

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

public EventProcessorHost (Uri endpointAddress, string eventHubPath, string consumerGroupName, Microsoft.Azure.EventHubs.ITokenProvider tokenProvider, Microsoft.Azure.Storage.CloudStorageAccount cloudStorageAccount, string leaseContainerName);

new Microsoft.Azure.EventHubs.Processor.EventProcessorHost : Uri * string * string * Microsoft.Azure.EventHubs.ITokenProvider * Microsoft.Azure.Storage.CloudStorageAccount * string -> Microsoft.Azure.EventHubs.Processor.EventProcessorHost

Public Sub New (endpointAddress As Uri, eventHubPath As String, consumerGroupName As String, tokenProvider As ITokenProvider, cloudStorageAccount As CloudStorageAccount, leaseContainerName As String)

パラメーター

endpointAddress: Uri

Event Hubs の完全修飾ドメイン名。ほとんどの場合、{yournamespace}.servicebus.windows.net

eventHubPath: String

EventHub の名前。

consumerGroupName: String

イベントハブ内のコンシューマーグループの名前。

tokenProvider: ITokenProvider

承認用のセキュリティトークンを生成するトークンプロバイダー。

cloudStorageAccount: CloudStorageAccount

リースとチェックポイント処理に使用される Azure Storage アカウント。

leaseContainerName: String

組み込みのリースおよびチェックポイントマネージャーで使用する Azure Storage コンテナー名。

適用対象

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

ソース:: EventProcessorHost.cs

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

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

public EventProcessorHost (string hostName, string eventHubPath, string consumerGroupName, string eventHubConnectionString, string storageConnectionString, string leaseContainerName, string storageBlobPrefix = default);

new Microsoft.Azure.EventHubs.Processor.EventProcessorHost : string * string * string * string * string * string * string -> Microsoft.Azure.EventHubs.Processor.EventProcessorHost

Public Sub New (hostName As String, eventHubPath As String, consumerGroupName As String, eventHubConnectionString As String, storageConnectionString As String, leaseContainerName As String, Optional storageBlobPrefix As String = Nothing)

パラメーター

hostName: String

プロセッサホストの名前。一意である必要があります。一意性を確保するために Guid を含めることを強くお勧めします。

eventHubPath: String

EventHub の名前。

consumerGroupName: String

イベントハブ内のコンシューマーグループの名前。

eventHubConnectionString: String

受信元のイベントハブの接続文字列。

storageConnectionString: String

リースとチェックポイント処理に使用される Azure Storage アカウントへの接続文字列。

leaseContainerName: String

組み込みのリースおよびチェックポイントマネージャーで使用する Azure Storage コンテナー名。

storageBlobPrefix: String

ストレージコンテナー内の BLOB に名前を付けるときに使用されるプレフィックス。

適用対象

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

ソース:: EventProcessorHost.cs

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

public EventProcessorHost (string hostName, Uri endpointAddress, string eventHubPath, string consumerGroupName, Microsoft.Azure.EventHubs.ITokenProvider tokenProvider, Microsoft.Azure.EventHubs.Processor.ICheckpointManager checkpointManager, Microsoft.Azure.EventHubs.Processor.ILeaseManager leaseManager, TimeSpan? operationTimeout = default, Microsoft.Azure.EventHubs.TransportType transportType = Microsoft.Azure.EventHubs.TransportType.Amqp);

new Microsoft.Azure.EventHubs.Processor.EventProcessorHost : string * Uri * string * string * Microsoft.Azure.EventHubs.ITokenProvider * Microsoft.Azure.EventHubs.Processor.ICheckpointManager * Microsoft.Azure.EventHubs.Processor.ILeaseManager * Nullable<TimeSpan> * Microsoft.Azure.EventHubs.TransportType -> Microsoft.Azure.EventHubs.Processor.EventProcessorHost

Public Sub New (hostName As String, endpointAddress As Uri, eventHubPath As String, consumerGroupName As String, tokenProvider As ITokenProvider, checkpointManager As ICheckpointManager, leaseManager As ILeaseManager, Optional operationTimeout As Nullable(Of TimeSpan) = Nothing, Optional transportType As TransportType = Microsoft.Azure.EventHubs.TransportType.Amqp)

パラメーター

hostName: String

プロセッサホストの名前。一意である必要があります。一意性を確保するために Guid を含めることを強くお勧めします。

endpointAddress: Uri

Event Hubs の完全修飾ドメイン名。ほとんどの場合、{yournamespace}.servicebus.windows.net

eventHubPath: String

EventHub の名前。

consumerGroupName: String

イベントハブ内のコンシューマーグループの名前。

tokenProvider: ITokenProvider

承認用のセキュリティトークンを生成するトークンプロバイダー。

checkpointManager: ICheckpointManager

パーティションのチェックポイント処理を処理する ICheckpointManager を実装するオブジェクト。

leaseManager: ILeaseManager

パーティションのリースを処理する ILeaseManager を実装するオブジェクト。

operationTimeout: Nullable<TimeSpan>

Event Hubs 操作の操作タイムアウト。

transportType: TransportType

接続時のトランスポートの種類。

適用対象

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

ソース:: EventProcessorHost.cs

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

public EventProcessorHost (Uri endpointAddress, string eventHubPath, string consumerGroupName, Microsoft.Azure.EventHubs.ITokenProvider tokenProvider, Microsoft.Azure.Storage.CloudStorageAccount cloudStorageAccount, string leaseContainerName, string storageBlobPrefix = default, TimeSpan? operationTimeout = default, Microsoft.Azure.EventHubs.TransportType transportType = Microsoft.Azure.EventHubs.TransportType.Amqp);

new Microsoft.Azure.EventHubs.Processor.EventProcessorHost : Uri * string * string * Microsoft.Azure.EventHubs.ITokenProvider * Microsoft.Azure.Storage.CloudStorageAccount * string * string * Nullable<TimeSpan> * Microsoft.Azure.EventHubs.TransportType -> Microsoft.Azure.EventHubs.Processor.EventProcessorHost

Public Sub New (endpointAddress As Uri, eventHubPath As String, consumerGroupName As String, tokenProvider As ITokenProvider, cloudStorageAccount As CloudStorageAccount, leaseContainerName As String, Optional storageBlobPrefix As String = Nothing, Optional operationTimeout As Nullable(Of TimeSpan) = Nothing, Optional transportType As TransportType = Microsoft.Azure.EventHubs.TransportType.Amqp)

パラメーター

endpointAddress: Uri

Event Hubs の完全修飾ドメイン名。ほとんどの場合、{yournamespace}.servicebus.windows.net

eventHubPath: String

EventHub の名前。

consumerGroupName: String

イベントハブ内のコンシューマーグループの名前。

tokenProvider: ITokenProvider

承認用のセキュリティトークンを生成するトークンプロバイダー。

cloudStorageAccount: CloudStorageAccount

リースとチェックポイント処理に使用される Azure Storage アカウント。

leaseContainerName: String

組み込みのリースおよびチェックポイントマネージャーで使用する Azure Storage コンテナー名。

storageBlobPrefix: String

ストレージコンテナー内の BLOB に名前を付けるときに使用されるプレフィックス。

operationTimeout: Nullable<TimeSpan>

Event Hubs 操作の操作タイムアウト。

transportType: TransportType

接続時のトランスポートの種類。

適用対象

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

ソース:: EventProcessorHost.cs

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

public EventProcessorHost (string hostName, Uri endpointAddress, string eventHubPath, string consumerGroupName, Microsoft.Azure.EventHubs.ITokenProvider tokenProvider, Microsoft.Azure.Storage.CloudStorageAccount cloudStorageAccount, string leaseContainerName, string storageBlobPrefix = default, TimeSpan? operationTimeout = default, Microsoft.Azure.EventHubs.TransportType transportType = Microsoft.Azure.EventHubs.TransportType.Amqp);

new Microsoft.Azure.EventHubs.Processor.EventProcessorHost : string * Uri * string * string * Microsoft.Azure.EventHubs.ITokenProvider * Microsoft.Azure.Storage.CloudStorageAccount * string * string * Nullable<TimeSpan> * Microsoft.Azure.EventHubs.TransportType -> Microsoft.Azure.EventHubs.Processor.EventProcessorHost

Public Sub New (hostName As String, endpointAddress As Uri, eventHubPath As String, consumerGroupName As String, tokenProvider As ITokenProvider, cloudStorageAccount As CloudStorageAccount, leaseContainerName As String, Optional storageBlobPrefix As String = Nothing, Optional operationTimeout As Nullable(Of TimeSpan) = Nothing, Optional transportType As TransportType = Microsoft.Azure.EventHubs.TransportType.Amqp)

パラメーター

hostName: String

プロセッサホストの名前。一意である必要があります。一意性を確保するために Guid を含めることを強くお勧めします。

endpointAddress: Uri

Event Hubs の完全修飾ドメイン名。ほとんどの場合、{yournamespace}.servicebus.windows.net

eventHubPath: String

EventHub の名前。

consumerGroupName: String

イベントハブ内のコンシューマーグループの名前。

tokenProvider: ITokenProvider

承認のためのセキュリティトークンを生成するトークンプロバイダー。

cloudStorageAccount: CloudStorageAccount

リースとチェックポイント処理に使用される Azure Storage アカウント。

leaseContainerName: String

組み込みのリースとチェックポイントマネージャーで使用する Azure Storage コンテナー名。

storageBlobPrefix: String

ストレージコンテナー内の BLOB に名前を付けるときに使用されるプレフィックス。

operationTimeout: Nullable<TimeSpan>

Event Hubs 操作の操作タイムアウト。

transportType: TransportType

接続時のトランスポートの種類。

適用対象

次の方法で共有

EventProcessorHost コンストラクター

定義

オーバーロード

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

パラメーター

適用対象

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

パラメーター

適用対象

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

パラメーター

適用対象

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

パラメーター

適用対象

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

パラメーター

適用対象

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

パラメーター

適用対象

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

パラメーター

適用対象

その他のリソース