IEventProcessor Schnittstelle

Definition

Stellt Methoden für Ereignisprozessoren bereit. Anwendungen müssen diese Schnittstelle implementieren, die die Behandlung von Ereignissen von Event Hubs ermöglicht. Diese Schnittstelle ist der Standard Erweiterbarkeitspunkt für eventProcessorHost und RegisterProcessor<T>(Lease, ICheckpointManager).

public interface IEventProcessor
type IEventProcessor = interface
Public Interface IEventProcessor

Methoden

CloseAsync(PartitionContext, CloseReason)

Wird aufgerufen, wenn der Besitz der Partition zu Lastenausgleichszwecken auf einen anderen Knoten verschoben wird oder wenn der Host heruntergefahren wird. Wird als Antwort auf aufgerufen UnregisterProcessorAsync(Lease, CloseReason).

OpenAsync(PartitionContext)

Initialisiert den Event Hub-Prozessor instance. Diese Methode wird aufgerufen, bevor Ereignisdaten an diesen Prozessor instance übergeben werden.

ProcessEventsAsync(PartitionContext, IEnumerable<EventData>)

Verarbeitet den angegebenen Kontext und die angegebenen Nachrichten asynchron. Diese Methode wird aufgerufen, wenn neue Nachrichten im Event Hubs-Stream vorhanden sind. Stellen Sie sicher, dass Der Prüfpunkt nur dann erfolgt, wenn Sie alle Ereignisse in jedem Batch verarbeitet haben.

Gilt für: