你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。
PluggableCheckpointStoreEventProcessor<TPartition> 类
定义
重要
一些信息与预发行产品相关，相应产品在发行之前可能会进行重大修改。 对于此处提供的信息，Microsoft 不作任何明示或暗示的担保。
为创建具有自定义处理逻辑的事件处理程序提供基础，该逻辑在给定事件中心的所有分区中为特定使用者组使用事件。 处理器能够与同一事件中心和使用者组配对的其他实例协作，通过使用通用存储平台进行通信来共享工作。 容错也是内置的，允许处理器在遇到错误时具有复原能力。
public abstract class PluggableCheckpointStoreEventProcessor<TPartition> : Azure.Messaging.EventHubs.Primitives.EventProcessor<TPartition> where TPartition : EventProcessorPartition, new()type PluggableCheckpointStoreEventProcessor<'Partition (requires 'Partition :> EventProcessorPartition and 'Partition : (new : unit -> 'Partition))> = class
inherit EventProcessor<'Partition (requires 'Partition :> EventProcessorPartition and 'Partition : (new : unit -> 'Partition))>Public MustInherit Class PluggableCheckpointStoreEventProcessor(Of TPartition)
Inherits EventProcessor(Of TPartition)类型参数
- TPartition
要对其执行操作的分区的上下文。
- 继承
注解
为了在实例之间 PluggableCheckpointStoreEventProcessor<TPartition> 实现分区共享的协调，它们将断言对使用者组的分区的独占读取访问权限。 除打算协作的处理器之外，其他读者不应在使用者组中处于活动状态。 非独占读取者将被拒绝访问;独占读取器（包括使用不同存储位置的处理器）将干扰处理器的操作和性能。
PluggableCheckpointStoreEventProcessor<TPartition>在应用程序的生存期内可以安全地缓存和使用 ，当应用程序定期或半定期处理事件时，这是最佳做法。 处理器负责高效资源管理，努力在非活动期间保持低资源使用率，并在较高使用率期间管理运行状况。 StopProcessingAsync(CancellationToken)在处理完成或应用程序关闭时调用 或 StopProcessing(CancellationToken) 方法可确保正确清理网络资源和其他非托管对象。
构造函数
属性
| ConsumerGroup |
与此事件处理程序关联的使用者组的名称。 事件在此组的上下文中是只读的。 (继承自 EventProcessor<TPartition>) |
| EventHubName |
处理器连接到的事件中心的名称，特定于包含它的事件中心命名空间。 (继承自 EventProcessor<TPartition>) |
| FullyQualifiedNamespace |
与处理器关联的完全限定的事件中心命名空间。 这可能类似于 |
| Identifier |
用于标识此事件处理程序的唯一名称。 (继承自 EventProcessor<TPartition>) |
| IsRunning |
指示此事件处理程序当前是否正在运行。 (继承自 EventProcessor<TPartition>) |
| RetryPolicy |
控制处理器重试尝试的活动策略。 (继承自 EventProcessor<TPartition>) |
