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

EventProcessor<TPartition>.OnPartitionProcessingStoppedAsync 方法

  • 参考

定义

命名空间:
Azure.Messaging.EventHubs.Primitives
程序集:
Azure.Messaging.EventHubs.dll
包:
Azure.Messaging.EventHubs v5.11.2
Source:
EventProcessor.cs

执行分区处理停止时所需的任务。 当分区由另一个事件处理程序实例声明或当前事件处理程序实例关闭时，通常会发生这种情况。

protected virtual System.Threading.Tasks.Task OnPartitionProcessingStoppedAsync (TPartition partition, Azure.Messaging.EventHubs.Processor.ProcessingStoppedReason reason, System.Threading.CancellationToken cancellationToken);
abstract member OnPartitionProcessingStoppedAsync : 'Partition * Azure.Messaging.EventHubs.Processor.ProcessingStoppedReason * System.Threading.CancellationToken -> System.Threading.Tasks.Task
override this.OnPartitionProcessingStoppedAsync : 'Partition * Azure.Messaging.EventHubs.Processor.ProcessingStoppedReason * System.Threading.CancellationToken -> System.Threading.Tasks.Task
Protected Overridable Function OnPartitionProcessingStoppedAsync (partition As TPartition, reason As ProcessingStoppedReason, cancellationToken As CancellationToken) As Task

参数

partition
TPartition

正在停止其处理的分区的上下文。

reason
ProcessingStoppedReason

停止分区处理的原因。

cancellationToken
CancellationToken

一个 CancellationToken 实例，用于向请求发出取消处理信号。 这在正常情况下不会发出信号，仅当处理器遇到不可恢复的错误时才会发生。

返回

Task

注解

不建议直接从此方法中管理处理器的状态;请求启动或停止处理器可能会导致死锁情况，尤其是在使用调用的同步形式时。

此方法将同时调用，因为每个关闭都是独立的。 对调用没有时间限制;实现可以安全地根据需要执行长时间运行的操作和重试。 此处理程序对关联分区的处理没有影响，并且不能保证在重启分区处理或迁移到新主机之前执行完成。

适用于