EventHubBufferedProducerClient.EnqueueEventsAsync Método
Definição
Importante
Algumas informações se referem a produtos de pré-lançamento que podem ser substancialmente modificados antes do lançamento. A Microsoft não oferece garantias, expressas ou implícitas, das informações aqui fornecidas.
Sobrecargas
| EnqueueEventsAsync(IEnumerable<EventData>, CancellationToken) |
Enfileira um conjunto de EventData no buffer a ser publicado no Hub de Eventos. Se não houver capacidade suficiente no buffer quando esse método for invocado, ele aguardará o espaço ficar disponível e garantirá que todos no Quando essa chamada retorna, o |
| EnqueueEventsAsync(IEnumerable<EventData>, EnqueueEventOptions, CancellationToken) |
Enfileira um conjunto de EventData no buffer a ser publicado no Hub de Eventos. Se não houver capacidade suficiente no buffer quando esse método for invocado, ele aguardará o espaço ficar disponível e garantirá que todos no Quando essa chamada retorna, o |
EnqueueEventsAsync(IEnumerable<EventData>, CancellationToken)
Enfileira um conjunto de EventData no buffer a ser publicado no Hub de Eventos. Se não houver capacidade suficiente no buffer quando esse método for invocado, ele aguardará o espaço ficar disponível e garantirá que todos no eventsevents conjunto tenham sido enfileirados.
Quando essa chamada retorna, o events foi aceito no buffer, mas pode não ter sido publicado ainda.
A publicação ocorrerá em um ponto não determinístico no futuro à medida que o buffer for processado.
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>
O conjunto de eventos a serem enfileirados no buffer e, posteriormente, publicados.
- cancellationToken
- CancellationToken
Uma instância opcional CancellationToken para sinalizar a solicitação para cancelar a operação.
Retornos
O número total de eventos que estão atualmente armazenados em buffer e aguardando para serem publicados, em todas as partições.
Exceções
Ocorre quando nenhum SendEventBatchFailedAsync manipulador está registrado no momento.
Comentários
Se ocorrer um cancelamento ou uma exceção inesperada, é possível que as chamadas a esse método resultem em uma falha parcial em que algumas, mas não todas, do events foram enfileiradas. Para cenários em que é importante entender se cada evento individual foi enfileirado, é recomendável chamar o ver EnqueueEventAsync(EventData, EnqueueEventOptions, CancellationToken) ou EnqueueEventAsync(EventData, CancellationToken) sobrecargas em vez desse método.
Após a primeira tentativa de enfileirar eventos, os SendEventBatchSucceededAsync manipuladores e SendEventBatchFailedAsync não poderão mais ser alterados.
Aplica-se a
EnqueueEventsAsync(IEnumerable<EventData>, EnqueueEventOptions, CancellationToken)
Enfileira um conjunto de EventData no buffer a ser publicado no Hub de Eventos. Se não houver capacidade suficiente no buffer quando esse método for invocado, ele aguardará o espaço ficar disponível e garantirá que todos no eventsevents conjunto tenham sido enfileirados.
Quando essa chamada retorna, o events foi aceito no buffer, mas pode não ter sido publicado ainda.
A publicação ocorrerá em um ponto não determinístico no futuro à medida que o buffer for processado.
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>
O conjunto de eventos a serem enfileirados no buffer e, posteriormente, publicados.
- options
- EnqueueEventOptions
O conjunto de opções a serem aplicadas ao publicar esses eventos.
- cancellationToken
- CancellationToken
Uma instância opcional CancellationToken para sinalizar a solicitação para cancelar a operação.
Retornos
O número total de eventos que estão atualmente armazenados em buffer e aguardando para serem publicados, em todas as partições.
Exceções
Ocorre quando um identificador de partição inválido foi especificado no options.
Comentários
Se ocorrer um cancelamento ou uma exceção inesperada, é possível que as chamadas a esse método resultem em uma falha parcial em que algumas, mas não todas, do events foram enfileiradas. Para cenários em que é importante entender se cada evento individual foi enfileirado, é recomendável chamar o ver EnqueueEventAsync(EventData, EnqueueEventOptions, CancellationToken) ou EnqueueEventAsync(EventData, CancellationToken) sobrecargas em vez desse método.
Após a primeira tentativa de enfileirar eventos, os SendEventBatchSucceededAsync manipuladores e SendEventBatchFailedAsync não poderão mais ser alterados.
Aplica-se a
Azure SDK for .NET