EventHubProducerClient.SendAsync Método

Definición

Espacio de nombres:

Azure.Messaging.EventHubs.Producer

Ensamblado:

Azure.Messaging.EventHubs.dll

Paquete:

Azure.Messaging.EventHubs v5.11.3

Sobrecargas

SendAsync(EventDataBatch, CancellationToken)	Envía un conjunto de eventos al centro de eventos asociado mediante un enfoque por lotes.
SendAsync(IEnumerable<EventData>, CancellationToken)	Envía un conjunto de eventos al centro de eventos asociado como una sola operación. Para evitar la sobrecarga asociada a medir y validar el tamaño en el cliente, la validación se delegará en el servicio Event Hubs y se aplazará hasta que se invoque la operación. Se producirá un error en la llamada si el tamaño del conjunto de eventos especificado supera el tamaño máximo permitido de un único lote.
SendAsync(IEnumerable<EventData>, SendEventOptions, CancellationToken)	Envía un conjunto de eventos al centro de eventos asociado como una sola operación. Para evitar la sobrecarga asociada a medir y validar el tamaño en el cliente, la validación se delegará en el servicio Event Hubs y se aplazará hasta que se invoque la operación. Se producirá un error en la llamada si el tamaño del conjunto de eventos especificado supera el tamaño máximo permitido de un único lote.

SendAsync(EventDataBatch, CancellationToken)

Source:

EventHubProducerClient.cs

Envía un conjunto de eventos al centro de eventos asociado mediante un enfoque por lotes.

public virtual System.Threading.Tasks.Task SendAsync (Azure.Messaging.EventHubs.Producer.EventDataBatch eventBatch, System.Threading.CancellationToken cancellationToken = default);

abstract member SendAsync : Azure.Messaging.EventHubs.Producer.EventDataBatch * System.Threading.CancellationToken -> System.Threading.Tasks.Task
override this.SendAsync : Azure.Messaging.EventHubs.Producer.EventDataBatch * System.Threading.CancellationToken -> System.Threading.Tasks.Task

Public Overridable Function SendAsync (eventBatch As EventDataBatch, Optional cancellationToken As CancellationToken = Nothing) As Task

Parámetros

eventBatch

EventDataBatch

Conjunto de datos de eventos que se van a enviar. Se puede crear un lote mediante CreateBatchAsync(CancellationToken).

cancellationToken

CancellationToken

Una instancia opcional CancellationToken para indicar la solicitud para cancelar la operación.

Devoluciones

Task

Tarea en la que se resolverá cuando se haya completado la operación; si no se produce ninguna excepción cuando se espera, el servicio Event Hubs tiene confirmación de confirmación y asume la responsabilidad de la entrega del lote.

Excepciones

InvalidOperationException

Se produce cuando el lote ha especificado un identificador de partición y una clave de partición.

Comentarios

Cuando se publica, el resultado es atómico; todos los eventos que pertenecen al lote se realizaron correctamente o todos han producido un error. El éxito parcial no es posible.

Consulte también

• CreateBatchAsync(CancellationToken)

SendAsync(IEnumerable<EventData>, CancellationToken)

Source:

EventHubProducerClient.cs

Envía un conjunto de eventos al centro de eventos asociado como una sola operación. Para evitar la sobrecarga asociada a medir y validar el tamaño en el cliente, la validación se delegará en el servicio Event Hubs y se aplazará hasta que se invoque la operación. Se producirá un error en la llamada si el tamaño del conjunto de eventos especificado supera el tamaño máximo permitido de un único lote.

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

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

Public Overridable Function SendAsync (eventBatch As IEnumerable(Of EventData), Optional cancellationToken As CancellationToken = Nothing) As Task

Parámetros

eventBatch

IEnumerable<EventData>

Conjunto de datos de eventos que se van a enviar.

cancellationToken

CancellationToken

Una instancia opcional CancellationToken para indicar la solicitud para cancelar la operación.

Devoluciones

Task

Tarea en la que se resolverá cuando se haya completado la operación; si no se produce ninguna excepción cuando se espera, el servicio Event Hubs ha confirmado la recepción y ha asumido la responsabilidad de la entrega del conjunto de eventos en su partición.

Excepciones

EventHubsException

Se produce cuando el conjunto de eventos supera el tamaño máximo permitido en un solo lote, determinado por el servicio Event Hubs. Reason Se establecerá MessageSizeExceeded en en este caso.

SerializationException

Se produce cuando uno de los eventos de eventBatch tiene un miembro de la Properties colección que es un tipo no admitido para la serialización. Consulte los Properties comentarios para obtener más información.

Comentarios

Cuando se publica, el resultado es atómico; todos los eventos que pertenecen al conjunto se han realizado correctamente o todos han producido un error. El éxito parcial no es posible.

Consulte también

• CreateBatchAsync(CancellationToken)
• SendAsync(IEnumerable<EventData>, SendEventOptions, CancellationToken)
• SendAsync(EventDataBatch, CancellationToken)

SendAsync(IEnumerable<EventData>, SendEventOptions, CancellationToken)

Source:

EventHubProducerClient.cs

Envía un conjunto de eventos al centro de eventos asociado como una sola operación. Para evitar la sobrecarga asociada a medir y validar el tamaño en el cliente, la validación se delegará en el servicio Event Hubs y se aplazará hasta que se invoque la operación. Se producirá un error en la llamada si el tamaño del conjunto de eventos especificado supera el tamaño máximo permitido de un único lote.

public virtual System.Threading.Tasks.Task SendAsync (System.Collections.Generic.IEnumerable<Azure.Messaging.EventHubs.EventData> eventBatch, Azure.Messaging.EventHubs.Producer.SendEventOptions options, System.Threading.CancellationToken cancellationToken = default);

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

Public Overridable Function SendAsync (eventBatch As IEnumerable(Of EventData), options As SendEventOptions, Optional cancellationToken As CancellationToken = Nothing) As Task

Parámetros

eventBatch

IEnumerable<EventData>

Conjunto de datos de eventos que se van a enviar.

options

SendEventOptions

Conjunto de opciones que se deben tener en cuenta al enviar este lote.

cancellationToken

CancellationToken

Una instancia opcional CancellationToken para indicar la solicitud para cancelar la operación.

Devoluciones

Task

Tarea en la que se resolverá cuando se haya completado la operación; si no se produce ninguna excepción cuando se espera, el servicio Event Hubs ha confirmado la recepción y ha asumido la responsabilidad de la entrega del conjunto de eventos en su partición.

Excepciones

InvalidOperationException

Se produce cuando se ha especificado un identificador de partición y una clave de partición en .options

EventHubsException

Se produce cuando el conjunto de eventos supera el tamaño máximo permitido en un solo lote, determinado por el servicio Event Hubs. Reason Se establecerá MessageSizeExceeded en en este caso.

SerializationException

Se produce cuando uno de los eventos de eventBatch tiene un miembro de la Properties colección que es un tipo no admitido para la serialización. Consulte los Properties comentarios para obtener más información.

Comentarios

Cuando se publica, el resultado es atómico; todos los eventos que pertenecen al conjunto se han realizado correctamente o todos han producido un error. El éxito parcial no es posible.

Consulte también

• CreateBatchAsync(CreateBatchOptions, CancellationToken)
• SendAsync(IEnumerable<EventData>, CancellationToken)
• SendAsync(EventDataBatch, CancellationToken)