EventProcessorHost Konstruktoren

Definition

Namespace:

Microsoft.Azure.EventHubs.Processor

Assembly:

Microsoft.Azure.EventHubs.Processor.dll

Paket:

Microsoft.Azure.EventHubs.Processor v4.3.2

Überlädt

EventProcessorHost(String, String, String, String, String)	Erstellen Sie einen neuen Host, um Ereignisse von einem Event Hub zu verarbeiten. Da Event Hubs häufig für Szenarien mit hohem Horizontalskalieren mit hohem Datenverkehr verwendet werden, gibt es in der Regel nur einen Host pro Prozess, und die Prozesse werden auf separaten Computern ausgeführt. Es wird jedoch unterstützt, mehrere Hosts auf einem Computer oder sogar innerhalb eines Prozesses auszuführen, wenn der Durchsatz kein Problem ist. Diese Überladung des Konstruktors verwendet die standardmäßigen, integrierten Lease- und Prüfpunkt-Manager. Das durch den parameter storageConnectionString angegebene Azure Storage-Konto wird von den integrierten Managern verwendet, um Leases und Prüfpunkte aufzuzeichnen.
EventProcessorHost(String, String, String, String, ICheckpointManager, ILeaseManager)	Erstellen Sie einen neuen Host, um Ereignisse von einem Event Hub zu verarbeiten. Diese Überladung des Konstruktors ermöglicht maximale Flexibilität. Dadurch kann der Aufrufer auch den Namen des Prozessorhosts angeben. Die Überladung ermöglicht es dem Aufrufer auch, eigene Lease- und Prüfpunkt-Manager bereitzustellen, um die integrierten auf Azure Storage basierenden zu ersetzen.
EventProcessorHost(Uri, String, String, ITokenProvider, CloudStorageAccount, String)	Erstellen eines neuen Hosts zum Verarbeiten von Ereignissen aus einem Event Hub mit bereitgestellt TokenProvider
EventProcessorHost(String, String, String, String, String, String, String)	Erstellen Sie einen neuen Host, um Ereignisse von einem Event Hub zu verarbeiten. Diese Überladung des Konstruktors verwendet die standardmäßigen, integrierten Lease- und Prüfpunkt-Manager.
EventProcessorHost(String, Uri, String, String, ITokenProvider, ICheckpointManager, ILeaseManager, Nullable<TimeSpan>, TransportType)	Erstellen eines neuen Hosts zum Verarbeiten von Ereignissen aus einem Event Hub mit bereitgestellt TokenProvider
EventProcessorHost(Uri, String, String, ITokenProvider, CloudStorageAccount, String, String, Nullable<TimeSpan>, TransportType)	Erstellen eines neuen Hosts zum Verarbeiten von Ereignissen aus einem Event Hub mit bereitgestellt TokenProvider
EventProcessorHost(String, Uri, String, String, ITokenProvider, CloudStorageAccount, String, String, Nullable<TimeSpan>, TransportType)	Erstellen eines neuen Hosts zum Verarbeiten von Ereignissen aus einem Event Hub mit bereitgestellt TokenProvider

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

Quelle:

EventProcessorHost.cs

Erstellen Sie einen neuen Host, um Ereignisse von einem Event Hub zu verarbeiten.

Da Event Hubs häufig für Szenarien mit hohem Horizontalskalieren mit hohem Datenverkehr verwendet werden, gibt es in der Regel nur einen Host pro Prozess, und die Prozesse werden auf separaten Computern ausgeführt. Es wird jedoch unterstützt, mehrere Hosts auf einem Computer oder sogar innerhalb eines Prozesses auszuführen, wenn der Durchsatz kein Problem ist.

Diese Überladung des Konstruktors verwendet die standardmäßigen, integrierten Lease- und Prüfpunkt-Manager. Das durch den parameter storageConnectionString angegebene Azure Storage-Konto wird von den integrierten Managern verwendet, um Leases und Prüfpunkte aufzuzeichnen.

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)

Parameter

eventHubPath

String

Der Name des EventHub.

consumerGroupName

String

Der Name der Consumergruppe im Event Hub.

eventHubConnectionString

String

Verbindungszeichenfolge für den Event Hub, von dem empfangen werden soll.

storageConnectionString

String

Verbindungszeichenfolge mit dem Azure Storage-Konto, das für Leases und Prüfpunkte verwendet wird.

leaseContainerName

String

Azure Storage-Containername zur Verwendung durch integrierte Lease und Prüfpunkt-Manager.

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

Quelle:

EventProcessorHost.cs

Erstellen Sie einen neuen Host, um Ereignisse von einem Event Hub zu verarbeiten.

Diese Überladung des Konstruktors ermöglicht maximale Flexibilität. Dadurch kann der Aufrufer auch den Namen des Prozessorhosts angeben. Die Überladung ermöglicht es dem Aufrufer auch, eigene Lease- und Prüfpunkt-Manager bereitzustellen, um die integrierten auf Azure Storage basierenden zu ersetzen.

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)

Parameter

hostName

String

Name des Prozessorhosts. MUSS EINDEUTIG SEIN. Es wird dringend empfohlen, eine GUID einzuschlehen, um die Eindeutigkeit sicherzustellen.

eventHubPath

String

Der Name des EventHub.

consumerGroupName

String

Der Name der Consumergruppe im Event Hub.

eventHubConnectionString

String

Verbindungszeichenfolge für den Event Hub, von dem empfangen werden soll.

checkpointManager

ICheckpointManager

Objekt, das ICheckpointManager implementiert, das partitionsprüfpunkting verarbeitet.

leaseManager

ILeaseManager

Objekt, das ILeaseManager implementiert, das Leases für Partitionen verarbeitet.

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

Quelle:

EventProcessorHost.cs

Erstellen eines neuen Hosts zum Verarbeiten von Ereignissen aus einem Event Hub mit bereitgestellt 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)

Parameter

endpointAddress

Uri

Vollqualifizierter Domänenname für Event Hubs. Höchstwahrscheinlich{yournamespace}.servicebus.windows.net

eventHubPath

String

Der Name des EventHub.

consumerGroupName

String

Der Name der Consumergruppe im Event Hub.

tokenProvider

ITokenProvider

Tokenanbieter, der Sicherheitstoken für die Autorisierung generiert.

cloudStorageAccount

CloudStorageAccount

Azure Storage-Konto, das für Leases und Prüfpunkte verwendet wird.

leaseContainerName

String

Azure Storage-Containername zur Verwendung durch integrierte Lease und Prüfpunkt-Manager.

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

Quelle:

EventProcessorHost.cs

Erstellen Sie einen neuen Host, um Ereignisse von einem Event Hub zu verarbeiten.

Diese Überladung des Konstruktors verwendet die standardmäßigen, integrierten Lease- und Prüfpunkt-Manager.

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)

Parameter

hostName

String

Name des Prozessorhosts. MUSS EINDEUTIG SEIN. Es wird dringend empfohlen, eine GUID einzuschlehen, um die Eindeutigkeit sicherzustellen.

eventHubPath

String

Der Name des EventHub.

consumerGroupName

String

Der Name der Consumergruppe im Event Hub.

eventHubConnectionString

String

Verbindungszeichenfolge für den Event Hub, von dem empfangen werden soll.

storageConnectionString

String

Verbindungszeichenfolge mit dem Azure Storage-Konto, das für Leases und Prüfpunkte verwendet wird.

leaseContainerName

String

Azure Storage-Containername zur Verwendung durch integrierte Lease und Prüfpunkt-Manager.

storageBlobPrefix

String

Präfix, das beim Benennen von Blobs innerhalb des Speichercontainers verwendet wird.

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

Quelle:

EventProcessorHost.cs

Erstellen eines neuen Hosts zum Verarbeiten von Ereignissen aus einem Event Hub mit bereitgestellt 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)

Parameter

hostName

String

Name des Prozessorhosts. MUSS EINDEUTIG SEIN. Es wird dringend empfohlen, eine GUID einzuschlehen, um die Eindeutigkeit sicherzustellen.

endpointAddress

Uri

Vollqualifizierter Domänenname für Event Hubs. Höchstwahrscheinlich{yournamespace}.servicebus.windows.net

eventHubPath

String

Der Name des EventHub.

consumerGroupName

String

Der Name der Consumergruppe im Event Hub.

tokenProvider

ITokenProvider

Tokenanbieter, der Sicherheitstoken für die Autorisierung generiert.

checkpointManager

ICheckpointManager

Objekt, das ICheckpointManager implementiert, das partitionsprüfpunkting verarbeitet.

leaseManager

ILeaseManager

Objekt, das ILeaseManager implementiert, das Leases für Partitionen verarbeitet.

operationTimeout

Nullable<TimeSpan>

Vorgangstimeout für Event Hubs-Vorgänge.

transportType

TransportType

Transporttyp bei Verbindung.

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

Quelle:

EventProcessorHost.cs

Erstellen eines neuen Hosts zum Verarbeiten von Ereignissen aus einem Event Hub mit bereitgestellt 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)

Parameter

endpointAddress

Uri

Vollqualifizierter Domänenname für Event Hubs. Höchstwahrscheinlich{yournamespace}.servicebus.windows.net

eventHubPath

String

Der Name des EventHub.

consumerGroupName

String

Der Name der Consumergruppe im Event Hub.

tokenProvider

ITokenProvider

Tokenanbieter, der Sicherheitstoken für die Autorisierung generiert.

cloudStorageAccount

CloudStorageAccount

Azure Storage-Konto, das für Leases und Prüfpunkte verwendet wird.

leaseContainerName

String

Azure Storage-Containername zur Verwendung durch integrierte Lease und Prüfpunkt-Manager.

storageBlobPrefix

String

Präfix, das beim Benennen von Blobs innerhalb des Speichercontainers verwendet wird.

operationTimeout

Nullable<TimeSpan>

Vorgangstimeout für Event Hubs-Vorgänge.

transportType

TransportType

Transporttyp bei Verbindung.

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

Quelle:

EventProcessorHost.cs

Erstellen eines neuen Hosts zum Verarbeiten von Ereignissen aus einem Event Hub mit bereitgestellt 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)

Parameter

hostName

String

Name des Prozessorhosts. MUSS EINDEUTIG SEIN. Es wird dringend empfohlen, eine GUID einzuschlehen, um die Eindeutigkeit sicherzustellen.

endpointAddress

Uri

Vollqualifizierter Domänenname für Event Hubs. Höchstwahrscheinlich{yournamespace}.servicebus.windows.net

eventHubPath

String

Der Name des EventHub.

consumerGroupName

String

Der Name der Consumergruppe im Event Hub.

tokenProvider

ITokenProvider

Tokenanbieter, der Sicherheitstoken für die Autorisierung generiert.

cloudStorageAccount

CloudStorageAccount

Azure Storage-Konto, das für Leases und Prüfpunkte verwendet wird.

leaseContainerName

String

Azure Storage-Containername zur Verwendung durch integrierte Lease und Prüfpunkt-Manager.

storageBlobPrefix

String

Präfix, das beim Benennen von Blobs innerhalb des Speichercontainers verwendet wird.

operationTimeout

Nullable<TimeSpan>

Vorgangstimeout für Event Hubs-Vorgänge.

transportType

TransportType

Transporttyp bei Verbindung.