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

EventHubBufferedProducerClient.EnqueueEventsAsync 方法

定义

重载

EnqueueEventsAsync(IEnumerable<EventData>, CancellationToken)

将一组 EventData 排队到要发布到事件中心的缓冲区中。 如果在调用此方法时缓冲区中的容量不足,它将等待空间变得可用,并确保集中的所有eventsevents内容都已排队。

当此调用返回时, events 缓冲区中已接受 ,但可能尚未发布。 在处理缓冲区时,发布将在将来的不确定点进行。

EnqueueEventsAsync(IEnumerable<EventData>, EnqueueEventOptions, CancellationToken)

将一组 EventData 排队到要发布到事件中心的缓冲区中。 如果在调用此方法时缓冲区中的容量不足,它将等待空间变得可用,并确保集中的所有eventsevents内容都已排队。

当此调用返回时, events 缓冲区中已接受 ,但可能尚未发布。 在处理缓冲区时,发布将在将来的不确定点进行。

EnqueueEventsAsync(IEnumerable<EventData>, CancellationToken)

将一组 EventData 排队到要发布到事件中心的缓冲区中。 如果在调用此方法时缓冲区中的容量不足,它将等待空间变得可用,并确保集中的所有eventsevents内容都已排队。

当此调用返回时, events 缓冲区中已接受 ,但可能尚未发布。 在处理缓冲区时,发布将在将来的不确定点进行。

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)

参数

events
IEnumerable<EventData>

要排队进入缓冲区并在以后发布的事件集。

cancellationToken
CancellationToken

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

返回

所有分区中当前缓冲并等待发布的事件总数。

例外

当前未注册处理程序 SendEventBatchFailedAsync 时发生。

注解

如果取消或发生意外异常,对此方法的调用可能会导致部分失败,其中部分(而不是全部 events )已排队。 对于必须了解每个事件是否已排队的情况,建议调用 see EnqueueEventAsync(EventData, EnqueueEventOptions, CancellationToken)EnqueueEventAsync(EventData, CancellationToken) 重载而不是此方法。

首次尝试将事件排入队列后, SendEventBatchSucceededAsync 无法再更改 和 SendEventBatchFailedAsync 处理程序。

适用于

EnqueueEventsAsync(IEnumerable<EventData>, EnqueueEventOptions, CancellationToken)

将一组 EventData 排队到要发布到事件中心的缓冲区中。 如果在调用此方法时缓冲区中的容量不足,它将等待空间变得可用,并确保集中的所有eventsevents内容都已排队。

当此调用返回时, events 缓冲区中已接受 ,但可能尚未发布。 在处理缓冲区时,发布将在将来的不确定点进行。

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)

参数

events
IEnumerable<EventData>

要排队进入缓冲区并在以后发布的事件集。

options
EnqueueEventOptions

发布这些事件时要应用的选项集。

cancellationToken
CancellationToken

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

返回

所有分区中当前缓冲并等待发布的事件总数。

例外

在 中 options指定了无效的分区标识符时发生。

注解

如果取消或发生意外异常,对此方法的调用可能会导致部分失败,其中部分(而不是全部 events )已排队。 对于必须了解每个事件是否已排队的情况,建议调用 see EnqueueEventAsync(EventData, EnqueueEventOptions, CancellationToken)EnqueueEventAsync(EventData, CancellationToken) 重载而不是此方法。

首次尝试将事件排入队列后, SendEventBatchSucceededAsync 无法再更改 和 SendEventBatchFailedAsync 处理程序。

适用于