EventHubBufferedProducerClient.EnqueueEventsAsync Méthode
Définition
Important
Certaines informations portent sur la préversion du produit qui est susceptible d’être en grande partie modifiée avant sa publication. Microsoft exclut toute garantie, expresse ou implicite, concernant les informations fournies ici.
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 Lorsque cet appel est retourné, le |
| 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 Lorsque cet appel est retourné, le |
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
Nombre total d’événements actuellement mis en mémoire tampon et en attente de publication, sur toutes les partitions.
Exceptions
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.
S’applique à
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
Nombre total d’événements actuellement mis en mémoire tampon et en attente de publication, sur toutes les partitions.
Exceptions
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.
S’applique à
Azure SDK for .NET