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

Microsoft.Azure.EventHubs.Processor 命名空间

Checkpoint

用于在流中保留状态的上下文对象。

EventProcessorConfigurationException

一个异常, EventProcessorHost 指定配置不正确。

EventProcessorHost

表示用于处理事件中心事件数据的主机。

EventProcessorOptions

定义向 EventHubConsumerGroup 注册 IEventProcessor 接口时的运行时选项。 这也是从对象使用的 EventProcessorHost IEventProcessor 实例捕获异常的机制。

EventProcessorRuntimeException

在事件处理期间引发的异常。

ExceptionReceivedEventArgs

Microsoft.Azure.EventHubs.Processor.EventProcessorOptions.NotifyOfException(System.String,System.String,System.Exception,System.String) 事件提供数据。

Lease

包含分区所有权信息。

LeaseLostException

表示服务租约丢失时发生的异常。

PartitionContext

封装与 所使用的 IEventProcessor事件中心分区相关的信息。

PartitionManagerOptions

用于控制实例中 EventProcessorHost 发生的分区分布的各个方面的选项。

接口

ICheckpointManager

如果希望 EventProcessorHost 将检查点存储在 Azure 存储以外的某个位置,则可以使用此接口编写自己的检查点管理器。

Azure 存储管理器对租用和检查点使用相同的存储,因此这两个接口都由同一类实现。 如果两种类型的数据都有统一存储,则可以随意执行相同操作。

此接口未指定初始化方法,因为我们无法知道实现需要哪些信息。

IEventProcessor

必须由事件处理程序类实现的接口。

事件处理程序类的任何给定实例将仅处理来自一个事件中心的一个分区的事件。 每次调用事件处理程序时都会提供 PartitionContext,因为某些参数可能会更改,但它始终是同一分区。

尽管 EventProcessorHost 是多线程的,但对事件处理程序类的给定实例的调用是序列化的,OnError () 除外。 首先调用 OnOpen () ,然后调用 OnEvents () 零次或多次。 当需要关闭事件处理程序时,无论是因为某个位置发生故障、分区的租约已丢失,还是因为整个处理器主机正在关闭,在返回最后一次 OnEvents () 调用后,都会调用 OnClose () 。

可以在 OnEvents () 或 OnClose () 执行时调用 OnError () 。 不会尝试同步以避免可能的死锁。

IEventProcessorFactory

必须由事件处理程序工厂类实现的接口。

如果创建事件处理程序对象需要的工作量比仅使用无参数构造函数的新需要更多工作,则需要用户提供的工厂。

ILeaseManager

如果想要在 Azure 存储以外的某个位置使用 EventProcessorHost 存储租约,可以使用此接口编写自己的租约管理器。

Azure 存储管理器对租用和检查点使用相同的存储,因此这两个接口都由同一类实现。 如果两种类型的数据都有统一存储,则可以随意执行相同操作。

此接口未指定初始化方法,因为我们无法知道实现需要哪些信息。

枚举

CloseReason

关闭 的原因 EventProcessorHost