BlobCheckpointStore.ClaimOwnershipAsync Methode

  • Referenz

Definition

Namespace:
Azure.Messaging.EventHubs.Primitives
Assembly:
Azure.Messaging.EventHubs.Processor.dll
Paket:
Azure.Messaging.EventHubs.Processor v5.11.3
Paket:
Azure.Messaging.EventHubs.Processor v5.12.0-beta.1
Quelle:
BlobCheckpointStore.cs
Quelle:
BlobCheckpointStore.cs

Versucht, den Besitz der angegebenen Partitionen für die Verarbeitung anzufordern. Dieser Vorgang wird vom Lastenausgleich verwendet, um die Verteilung der Verantwortung für die Verarbeitung von Partitionen für eine Event Hub- und Consumergruppenpaarung auf die aktiven Ereignisprozessoren zu ermöglichen.

public override System.Threading.Tasks.Task<System.Collections.Generic.IEnumerable<Azure.Messaging.EventHubs.Primitives.EventProcessorPartitionOwnership>> ClaimOwnershipAsync (System.Collections.Generic.IEnumerable<Azure.Messaging.EventHubs.Primitives.EventProcessorPartitionOwnership> desiredOwnership, System.Threading.CancellationToken cancellationToken);
override this.ClaimOwnershipAsync : seq<Azure.Messaging.EventHubs.Primitives.EventProcessorPartitionOwnership> * System.Threading.CancellationToken -> System.Threading.Tasks.Task<seq<Azure.Messaging.EventHubs.Primitives.EventProcessorPartitionOwnership>>
Public Overrides Function ClaimOwnershipAsync (desiredOwnership As IEnumerable(Of EventProcessorPartitionOwnership), cancellationToken As CancellationToken) As Task(Of IEnumerable(Of EventProcessorPartitionOwnership))

Parameter

desiredOwnership
IEnumerable<EventProcessorPartitionOwnership>

Der vom Ereignisprozessor gewünschte Satz des Partitionsbesitzes instance. Dies ist der Satz von Partitionen, die er für die Verarbeitung anzufordern versucht.

cancellationToken
CancellationToken

Ein CancellationToken instance, um der Anforderung zu signalisieren, die Verarbeitung abzubrechen. Dies tritt höchstwahrscheinlich auf, wenn der Prozessor heruntergefahren wird.

Gibt zurück

Task<IEnumerable<EventProcessorPartitionOwnership>>

Der Satz von Besitzdatensätzen für die Partitionen, die erfolgreich beansprucht wurden; Dies wird erwartet, dass es sich um oder desiredOwnership eine Teilmenge dieser Partitionen handelt.

Gilt für: