EventProcessorHost Klasse

Definition

Namespace:

Microsoft.Azure.EventHubs.Processor

Assembly:

Microsoft.Azure.EventHubs.Processor.dll

Paket:

Microsoft.Azure.EventHubs.Processor v4.3.2

Quelle:

EventProcessorHost.cs

Stellt einen Host zum Verarbeiten von Event Hubs-Ereignisdaten dar.

public sealed class EventProcessorHost

type EventProcessorHost = class

Public NotInheritable Class EventProcessorHost

Vererbung

Object

EventProcessorHost

Konstruktoren

EventProcessorHost(String, String, String, String, ICheckpointManager, ILeaseManager)	Erstellen Sie einen neuen Host, um Ereignisse über einen 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 Manager basierend auf Azure Storage zu ersetzen.
EventProcessorHost(String, String, String, String, String)	Erstellen Sie einen neuen Host, um Ereignisse über einen Event Hub zu verarbeiten. Da Event Hubs häufig für Hochskalierungsszenarien 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 darstellt. 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, String, String, String)	Erstellen Sie einen neuen Host, um Ereignisse über einen Event Hub zu verarbeiten. Diese Überladung des Konstruktors verwendet die standardmäßigen, integrierten Lease- und Prüfpunkt-Manager.
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 bereitgestellten TokenProvider
EventProcessorHost(String, Uri, String, String, ITokenProvider, ICheckpointManager, ILeaseManager, Nullable<TimeSpan>, TransportType)	Erstellen eines neuen Hosts zum Verarbeiten von Ereignissen aus einem Event Hub mit bereitgestellten TokenProvider
EventProcessorHost(Uri, String, String, ITokenProvider, CloudStorageAccount, String)	Erstellen eines neuen Hosts zum Verarbeiten von Ereignissen aus einem Event Hub mit bereitgestellten 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 bereitgestellten TokenProvider

Eigenschaften

ConsumerGroupName	Ruft den Namen der Consumergruppe ab.
EndpointAddress	Ruft den Ereignisendpunkt-URI ab.
EventHubPath	Ruft den Event Hub-Pfad ab.
HostName	Gibt den Prozessorhostnamen zurück. Wenn der Prozessorhostname automatisch generiert wurde, ist dies die einzige Möglichkeit, ihn abzurufen.
OperationTimeout	Ruft das Vorgangstimeout ab.
PartitionManagerOptions	Ruft die PartitionManagerOptions vom -Objekt verwendete instance ab oder legt diese EventProcessorHost fest.
TransportType	Ruft den Transporttyp ab.

Methoden

RegisterEventProcessorAsync<T>()	Dadurch wird die IEventProcessor Implementierung mit dem Host registriert Microsoft.Azure.EventHubs.Processor.DefaultEventProcessorFactory`1. Dies startet auch den Host und bewirkt, dass er am Partitionsverteilungsprozess teilnimmt.
RegisterEventProcessorAsync<T>(EventProcessorOptions)	Dadurch wird die IEventProcessor Implementierung mit dem Host registriert Microsoft.Azure.EventHubs.Processor.DefaultEventProcessorFactory`1. Dies startet auch den Host und bewirkt, dass er am Partitionsverteilungsprozess teilnimmt.
RegisterEventProcessorFactoryAsync(IEventProcessorFactory)	Dadurch wird die Implementierung beim Host registriertIEventProcessorFactory, der verwendet wird, um eine instance von IEventProcessor zu erstellen, wenn er den Besitz einer Partition übernimmt. Dies startet auch den Host und bewirkt, dass er am Partitionsverteilungsprozess teilnimmt.
RegisterEventProcessorFactoryAsync(IEventProcessorFactory, EventProcessorOptions)	Dadurch wird die Implementierung beim Host registriertIEventProcessorFactory, der verwendet wird, um eine instance von IEventProcessor zu erstellen, wenn er den Besitz einer Partition übernimmt. Dies startet auch den Host und bewirkt, dass er am Partitionsverteilungsprozess teilnimmt.
UnregisterEventProcessorAsync()	Beenden Sie die Verarbeitung von Ereignissen. Wird erst zurückgegeben, wenn das Herunterfahren abgeschlossen ist.