PartitionContext interface
描述传递给属于 SubscriptionEventHandlers的每个函数的上下文的接口。 实现其中任一函数时,请使用上下文对象获取有关分区的信息以及检查点功能。
属性
| consumer |
使用者组名称。 |
| event |
事件中心名称。 |
| fully |
完全限定的事件中心命名空间。 这很可能类似于 <yournamespace.servicebus.windows.net> |
| last |
有关正在处理的分区中最后一个排队事件的信息。
仅当创建 EventProcessor 实例时, |
| partition |
事件中心分区的标识符。 |
方法
| update |
使用事件数据更新检查点。 检查点表示用户从事件中心实例中的使用者组的特定分区中成功处理的最后一个事件。 |
属性详细信息
consumerGroup
使用者组名称。
consumerGroup: string
属性值
string
eventHubName
事件中心名称。
eventHubName: string
属性值
string
fullyQualifiedNamespace
完全限定的事件中心命名空间。 这很可能类似于 <yournamespace.servicebus.windows.net>
fullyQualifiedNamespace: string
属性值
string
lastEnqueuedEventProperties
有关正在处理的分区中最后一个排队事件的信息。
仅当创建 EventProcessor 实例时,trackLastEnqueuedEventProperties 选项设置为 true 时,才会更新此属性。
lastEnqueuedEventProperties?: LastEnqueuedEventProperties
属性值
partitionId
事件中心分区的标识符。
partitionId: string
属性值
string
方法详细信息
updateCheckpoint(ReceivedEventData)
使用事件数据更新检查点。
检查点表示用户从事件中心实例中的使用者组的特定分区中成功处理的最后一个事件。
function updateCheckpoint(eventData: ReceivedEventData): Promise<void>
参数
- eventData
- ReceivedEventData
要更新检查点的事件。
返回
Promise<void>