你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。

EventHubProducerClient.SendAsync 方法

定义

命名空间:

Azure.Messaging.EventHubs.Producer

程序集:

Azure.Messaging.EventHubs.dll

包:

Azure.Messaging.EventHubs v5.11.3

重载

SendAsync(EventDataBatch, CancellationToken)	使用批处理方法将一组事件发送到关联的事件中心。
SendAsync(IEnumerable<EventData>, CancellationToken)	将一组事件作为单个操作发送到关联的事件中心。 为了避免与在客户端中测量和验证大小相关的开销，验证将委托给事件中心服务，并推迟到调用操作。 如果指定事件集的大小超过单个批允许的最大大小，则调用将失败。
SendAsync(IEnumerable<EventData>, SendEventOptions, CancellationToken)	将一组事件作为单个操作发送到关联的事件中心。 为了避免与在客户端中测量和验证大小相关的开销，验证将委托给事件中心服务，并推迟到调用操作。 如果指定事件集的大小超过单个批允许的最大大小，则调用将失败。

SendAsync(EventDataBatch, CancellationToken)

Source:

EventHubProducerClient.cs

使用批处理方法将一组事件发送到关联的事件中心。

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

参数

eventBatch

EventDataBatch

要发送的事件数据集。 可以使用 创建 CreateBatchAsync(CancellationToken)批处理。

cancellationToken

CancellationToken

一个可选 CancellationToken 实例，用于向请求发出取消操作的信号。

返回

Task

操作完成时要解决的任务;如果在等待时未引发异常，则事件中心服务会确认接收并承担批处理的传递责任。

例外

InvalidOperationException

当批处理同时指定了分区标识符和分区键时发生。

注解

发布后，结果为原子;属于批处理的所有事件都成功或全部失败。 部分成功是不可能的。

另请参阅

• CreateBatchAsync(CancellationToken)

SendAsync(IEnumerable<EventData>, CancellationToken)

Source:

EventHubProducerClient.cs

将一组事件作为单个操作发送到关联的事件中心。 为了避免与在客户端中测量和验证大小相关的开销，验证将委托给事件中心服务，并推迟到调用操作。 如果指定事件集的大小超过单个批允许的最大大小，则调用将失败。

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

参数

eventBatch

IEnumerable<EventData>

要发送的事件数据集。

cancellationToken

CancellationToken

一个可选 CancellationToken 实例，用于向请求发出取消操作的信号。

返回

Task

操作完成时要解决的任务;如果在等待时未引发异常，则事件中心服务已确认接收并承担将事件集传送到其分区的责任。

例外

EventHubsException

当事件集超过单个批处理中允许的最大大小（由事件中心服务确定）时发生。 在这种情况下， Reason 将设置为 MessageSizeExceeded 。

SerializationException

当 中的某个事件在 eventBatch 集合中 Properties 具有不受支持的序列化类型的成员时发生。 有关详细信息， Properties 请参阅备注。

注解

发布后，结果为原子;属于该集的所有事件都成功或全部失败。 部分成功是不可能的。

另请参阅

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

SendAsync(IEnumerable<EventData>, SendEventOptions, CancellationToken)

Source:

EventHubProducerClient.cs

将一组事件作为单个操作发送到关联的事件中心。 为了避免与在客户端中测量和验证大小相关的开销，验证将委托给事件中心服务，并推迟到调用操作。 如果指定事件集的大小超过单个批允许的最大大小，则调用将失败。

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

参数

eventBatch

IEnumerable<EventData>

要发送的事件数据集。

options

SendEventOptions

发送此批时要考虑的选项集。

cancellationToken

CancellationToken

一个可选 CancellationToken 实例，用于向请求发出取消操作的信号。

返回

Task

操作完成时要解决的任务;如果在等待时未引发异常，则事件中心服务已确认接收并承担将事件集传送到其分区的责任。

例外

InvalidOperationException

在 中同时指定了分区标识符和分区键时发生 options。

EventHubsException

当事件集超过单个批处理中允许的最大大小（由事件中心服务确定）时发生。 在这种情况下， Reason 将设置为 MessageSizeExceeded 。

SerializationException

当 中的某个事件在 eventBatch 集合中 Properties 具有不受支持的序列化类型的成员时发生。 有关详细信息， Properties 请参阅备注。

注解

发布后，结果为原子;属于该集的所有事件都成功或全部失败。 部分成功是不可能的。

另请参阅

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