你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn。
EventHubBufferedProducerClient.EnqueueEventsAsync 方法
定义
重要
一些信息与预发行产品相关,相应产品在发行之前可能会进行重大修改。 对于此处提供的信息,Microsoft 不作任何明示或暗示的担保。
重载
EnqueueEventsAsync(IEnumerable<EventData>, CancellationToken) |
将一组 EventData 排队到要发布到事件中心的缓冲区中。 如果在调用此方法时缓冲区中的容量不足,它将等待空间变得可用,并确保集中的所有 当此调用返回时, |
EnqueueEventsAsync(IEnumerable<EventData>, EnqueueEventOptions, CancellationToken) |
将一组 EventData 排队到要发布到事件中心的缓冲区中。 如果在调用此方法时缓冲区中的容量不足,它将等待空间变得可用,并确保集中的所有 当此调用返回时, |
EnqueueEventsAsync(IEnumerable<EventData>, CancellationToken)
将一组 EventData 排队到要发布到事件中心的缓冲区中。 如果在调用此方法时缓冲区中的容量不足,它将等待空间变得可用,并确保集中的所有events
events
内容都已排队。
当此调用返回时, 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 排队到要发布到事件中心的缓冲区中。 如果在调用此方法时缓冲区中的容量不足,它将等待空间变得可用,并确保集中的所有events
events
内容都已排队。
当此调用返回时, 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 处理程序。