Freigeben über

CheckpointStore.ClaimOwnershipAsync Methode

  • Referenz

Definition

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

Versucht, den Besitz der angegebenen Partitionen für die Verarbeitung in Anspruch zu nehmen. Dieser Vorgang wird vom Lastenausgleich verwendet, um die Verteilung der Verantwortung für die Verarbeitung von Partitionen für einen Event Hub und eine Consumergruppe zwischen den aktiven Ereignisprozessoren zu ermöglichen.

public abstract 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);
abstract member ClaimOwnershipAsync : seq<Azure.Messaging.EventHubs.Primitives.EventProcessorPartitionOwnership> * System.Threading.CancellationToken -> System.Threading.Tasks.Task<seq<Azure.Messaging.EventHubs.Primitives.EventProcessorPartitionOwnership>>
Public MustOverride Function ClaimOwnershipAsync (desiredOwnership As IEnumerable(Of EventProcessorPartitionOwnership), cancellationToken As CancellationToken) As Task(Of IEnumerable(Of EventProcessorPartitionOwnership))

Parameter

desiredOwnership
IEnumerable<EventProcessorPartitionOwnership>

Die vom Ereignisprozessor gewünschte Gruppe von Partitionsbesitz instance. Dies ist der Satz von Partitionen, die versucht, die Verantwortung für die Verarbeitung anzufordern.

cancellationToken
CancellationToken

Ein CancellationToken instance, um die Anforderung zum Abbrechen der Verarbeitung zu signalisieren. Dies tritt am wahrscheinlichsten auf, wenn der Prozessor heruntergefahren wird.

Gibt zurück

Task<IEnumerable<EventProcessorPartitionOwnership>>

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

Gilt für: