EventHubBufferedProducerClient.EnqueueEventsAsync Méthode

Définition

Espace de noms:

Azure.Messaging.EventHubs.Producer

Assembly:

Azure.Messaging.EventHubs.dll

Paquet:

Azure.Messaging.EventHubs v5.10.0

Surcharges

EnqueueEventsAsync(IEnumerable<EventData>, CancellationToken)

Met en file d’attente un ensemble de EventData dans la mémoire tampon à publier dans Event Hub. Si la capacité de la mémoire tampon est insuffisante lors de l’appel de cette méthode, elle attend que l’espace soit disponible et s’assure que tous les events ensembles ont été mis en events file d’attente. Lorsque cet appel est retourné, le events a été accepté dans la mémoire tampon, mais il n’a peut-être pas encore été publié. La publication aura lieu à un point non déterministe à l’avenir à mesure que la mémoire tampon sera traitée.

EnqueueEventsAsync(IEnumerable<EventData>, EnqueueEventOptions, CancellationToken)

Met en file d’attente un ensemble de EventData dans la mémoire tampon à publier dans Event Hub. Si la capacité de la mémoire tampon est insuffisante lors de l’appel de cette méthode, elle attend que l’espace soit disponible et s’assure que tous les events ensembles ont été mis en events file d’attente. Lorsque cet appel est retourné, le events a été accepté dans la mémoire tampon, mais il n’a peut-être pas encore été publié. La publication aura lieu à un point non déterministe à l’avenir à mesure que la mémoire tampon sera traitée.

EnqueueEventsAsync(IEnumerable<EventData>, CancellationToken)

Met en file d’attente un ensemble de EventData dans la mémoire tampon à publier dans Event Hub. Si la capacité de la mémoire tampon est insuffisante lors de l’appel de cette méthode, elle attend que l’espace soit disponible et s’assure que tous les events ensembles ont été mis en events file d’attente.

Lorsque cet appel est retourné, le events a été accepté dans la mémoire tampon, mais il n’a peut-être pas encore été publié. La publication aura lieu à un point non déterministe à l’avenir à mesure que la mémoire tampon sera traitée.

public virtual System.Threading.Tasks.Task<int> EnqueueEventsAsync (System.Collections.Generic.IEnumerable<Azure.Messaging.EventHubs.EventData> events, System.Threading.CancellationToken cancellationToken = default);

abstract member EnqueueEventsAsync : seq<Azure.Messaging.EventHubs.EventData> * System.Threading.CancellationToken -> System.Threading.Tasks.Task<int>
override this.EnqueueEventsAsync : seq<Azure.Messaging.EventHubs.EventData> * System.Threading.CancellationToken -> System.Threading.Tasks.Task<int>

Public Overridable Function EnqueueEventsAsync (events As IEnumerable(Of EventData), Optional cancellationToken As CancellationToken = Nothing) As Task(Of Integer)

Paramètres

events

IEnumerable<EventData>

Ensemble d’événements à mettre en file d’attente dans la mémoire tampon et, plus tard, à publier.

cancellationToken

CancellationToken

Une instance facultative CancellationToken pour signaler la demande d’annulation de l’opération.

Retours

Task<Int32>

Nombre total d’événements actuellement mis en mémoire tampon et en attente de publication, sur toutes les partitions.

Exceptions

InvalidOperationException

Se produit lorsqu’aucun gestionnaire n’est SendEventBatchFailedAsync actuellement inscrit.

Remarques

Si une annulation ou une exception inattendue se produit, il est possible que les appels à cette méthode entraînent un échec partiel où certains, mais pas tous, ont mis la events file d’attente. Pour les scénarios où il est important de comprendre si chaque événement individuel a été mis en file d’attente, il est recommandé d’appeler la EnqueueEventAsync(EventData, EnqueueEventOptions, CancellationToken) vue ou EnqueueEventAsync(EventData, CancellationToken) des surcharges au lieu de cette méthode.

Lors de la première tentative de mise en file d’attente des événements, les SendEventBatchSucceededAsync gestionnaires et SendEventBatchFailedAsync ne peuvent plus être modifiés.

EnqueueEventsAsync(IEnumerable<EventData>, EnqueueEventOptions, CancellationToken)

Met en file d’attente un ensemble de EventData dans la mémoire tampon à publier dans Event Hub. Si la capacité de la mémoire tampon est insuffisante lors de l’appel de cette méthode, elle attend que l’espace soit disponible et s’assure que tous les events ensembles ont été mis en events file d’attente.

Lorsque cet appel est retourné, le events a été accepté dans la mémoire tampon, mais il n’a peut-être pas encore été publié. La publication aura lieu à un point non déterministe à l’avenir à mesure que la mémoire tampon sera traitée.

public virtual System.Threading.Tasks.Task<int> EnqueueEventsAsync (System.Collections.Generic.IEnumerable<Azure.Messaging.EventHubs.EventData> events, Azure.Messaging.EventHubs.Producer.EnqueueEventOptions options, System.Threading.CancellationToken cancellationToken = default);

abstract member EnqueueEventsAsync : seq<Azure.Messaging.EventHubs.EventData> * Azure.Messaging.EventHubs.Producer.EnqueueEventOptions * System.Threading.CancellationToken -> System.Threading.Tasks.Task<int>
override this.EnqueueEventsAsync : seq<Azure.Messaging.EventHubs.EventData> * Azure.Messaging.EventHubs.Producer.EnqueueEventOptions * System.Threading.CancellationToken -> System.Threading.Tasks.Task<int>

Public Overridable Function EnqueueEventsAsync (events As IEnumerable(Of EventData), options As EnqueueEventOptions, Optional cancellationToken As CancellationToken = Nothing) As Task(Of Integer)

Paramètres

events

IEnumerable<EventData>

Ensemble d’événements à mettre en file d’attente dans la mémoire tampon et, plus tard, à publier.

options

EnqueueEventOptions

Ensemble d’options à appliquer lors de la publication de ces événements.

cancellationToken

CancellationToken

Une instance facultative CancellationToken pour signaler la demande d’annulation de l’opération.

Retours

Task<Int32>

Nombre total d’événements actuellement mis en mémoire tampon et en attente de publication, sur toutes les partitions.

Exceptions

InvalidOperationException

Se produit lorsqu’un identificateur de partition non valide a été spécifié dans le options.

Remarques

Si une annulation ou une exception inattendue se produit, il est possible que les appels à cette méthode entraînent un échec partiel où certains, mais pas tous, ont mis la events file d’attente. Pour les scénarios où il est important de comprendre si chaque événement individuel a été mis en file d’attente, il est recommandé d’appeler la EnqueueEventAsync(EventData, EnqueueEventOptions, CancellationToken) vue ou EnqueueEventAsync(EventData, CancellationToken) des surcharges au lieu de cette méthode.

Lors de la première tentative de mise en file d’attente des événements, les SendEventBatchSucceededAsync gestionnaires et SendEventBatchFailedAsync ne peuvent plus être modifiés.