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

Azure.Messaging.EventHubs.Primitives 命名空间

BlobCheckpointStore

允许与事件处理程序操作所需的检查点和所有权数据交互,使用 Azure 存储 Blob 进行持久性。

CheckpointStore

允许与事件处理程序操作所需的检查点和所有权数据进行交互。

EventProcessor<TPartition>

为创建自定义处理器提供基础,该处理器在给定事件中心的所有分区中为特定使用者组使用事件。 处理器能够与同一事件中心和使用者组配对的其他实例协作,通过使用通用存储平台进行通信来共享工作。 此外,还内置了容错功能,允许处理器在遇到错误时具有复原能力。

EventProcessorCheckpoint

包含用于反映给定事件中心分区的事件处理状态的信息。

EventProcessorOptions

创建 EventProcessor<TPartition> 时可以指定的选项集,以配置其行为。

EventProcessorPartition

一组有关正在对其执行操作的事件中心分区的 EventProcessor<TPartition> 上下文信息。

EventProcessorPartitionOwnership

用于描述实例之间 EventProcessor<TPartition> 分区所有权的状态的信息集,这些实例协作分配给定事件中心的处理。

PartitionReceiver

允许从事件中心的特定分区读取事件,并在特定使用者组的上下文中读取事件,以比起其他事件使用者提供的对事件中心服务通信的更高级别的控制进行读取。

PartitionReceiverOptions

创建 PartitionReceiver 时可以指定的选项集,用于配置其行为。

PluggableCheckpointStoreEventProcessor<TPartition>

为使用自定义处理逻辑创建事件处理程序提供基础,该逻辑使用特定使用者组的给定事件中心的所有分区中的事件。 处理器能够与同一事件中心和使用者组配对的其他实例协作,通过使用通用存储平台进行通信来共享工作。 此外,还内置了容错功能,允许处理器在遇到错误时具有复原能力。