EventHubBufferedProducerClient.EnqueueEventsAsync Método
Definición
Importante
Parte de la información hace referencia a la versión preliminar del producto, que puede haberse modificado sustancialmente antes de lanzar la versión definitiva. Microsoft no otorga ninguna garantía, explícita o implícita, con respecto a la información proporcionada aquí.
Sobrecargas
| EnqueueEventsAsync(IEnumerable<EventData>, CancellationToken) |
Pone en cola un conjunto de EventData en el búfer que se va a publicar en el centro de eventos. Si no hay suficiente capacidad en el búfer cuando se invoca este método, esperará a que el espacio esté disponible y se asegurará de que todo Cuando se devuelve esta llamada, se |
| EnqueueEventsAsync(IEnumerable<EventData>, EnqueueEventOptions, CancellationToken) |
Pone en cola un conjunto de EventData en el búfer que se va a publicar en el centro de eventos. Si no hay suficiente capacidad en el búfer cuando se invoca este método, esperará a que el espacio esté disponible y se asegurará de que todo Cuando se devuelve esta llamada, se |
EnqueueEventsAsync(IEnumerable<EventData>, CancellationToken)
Pone en cola un conjunto de EventData en el búfer que se va a publicar en el centro de eventos. Si no hay suficiente capacidad en el búfer cuando se invoca este método, esperará a que el espacio esté disponible y se asegurará de que todo events el events conjunto se haya puesto en cola.
Cuando se devuelve esta llamada, se events ha aceptado en el búfer, pero es posible que aún no se haya publicado.
La publicación tendrá lugar en un punto no determinista en el futuro a medida que se procesa el búfer.
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)Parámetros
- events
- IEnumerable<EventData>
Conjunto de eventos que se van a poner en cola en el búfer y, más adelante, se van a publicar.
- cancellationToken
- CancellationToken
Una instancia opcional CancellationToken para indicar la solicitud para cancelar la operación.
Devoluciones
Número total de eventos almacenados en búfer y en espera de publicación, en todas las particiones.
Excepciones
Se produce cuando no hay ningún SendEventBatchFailedAsync controlador registrado actualmente.
Comentarios
Si se produce una cancelación o una excepción inesperada, es posible que las llamadas a este método produzcan un error parcial en el que algunos, pero no todos, hayan events puesto en cola. En escenarios en los que es importante comprender si se ha puesto en cola cada evento individual, se recomienda llamar a las sobrecargas o EnqueueEventAsync(EventData, CancellationToken) ver EnqueueEventAsync(EventData, EnqueueEventOptions, CancellationToken) en lugar de a este método.
Tras el primer intento de poner en cola los eventos, los SendEventBatchSucceededAsync controladores y SendEventBatchFailedAsync ya no se pueden cambiar.
Se aplica a
EnqueueEventsAsync(IEnumerable<EventData>, EnqueueEventOptions, CancellationToken)
Pone en cola un conjunto de EventData en el búfer que se va a publicar en el centro de eventos. Si no hay suficiente capacidad en el búfer cuando se invoca este método, esperará a que el espacio esté disponible y se asegurará de que todo events el events conjunto se haya puesto en cola.
Cuando se devuelve esta llamada, se events ha aceptado en el búfer, pero es posible que aún no se haya publicado.
La publicación tendrá lugar en un punto no determinista en el futuro a medida que se procesa el búfer.
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)Parámetros
- events
- IEnumerable<EventData>
Conjunto de eventos que se van a poner en cola en el búfer y, más adelante, se van a publicar.
- options
- EnqueueEventOptions
Conjunto de opciones que se aplicarán al publicar estos eventos.
- cancellationToken
- CancellationToken
Una instancia opcional CancellationToken para indicar la solicitud para cancelar la operación.
Devoluciones
Número total de eventos almacenados en búfer y en espera de publicación, en todas las particiones.
Excepciones
Se produce cuando se ha especificado un identificador de partición no válido en .options
Comentarios
Si se produce una cancelación o una excepción inesperada, es posible que las llamadas a este método produzcan un error parcial en el que algunos, pero no todos, hayan events puesto en cola. En escenarios en los que es importante comprender si se ha puesto en cola cada evento individual, se recomienda llamar a las sobrecargas o EnqueueEventAsync(EventData, CancellationToken) ver EnqueueEventAsync(EventData, EnqueueEventOptions, CancellationToken) en lugar de a este método.
Tras el primer intento de poner en cola los eventos, los SendEventBatchSucceededAsync controladores y SendEventBatchFailedAsync ya no se pueden cambiar.
Se aplica a
Azure SDK for .NET