PartitionContext interface
SubscriptionEventHandlers일부인 각 함수에 전달되는 컨텍스트를 설명하는 인터페이스입니다. 이러한 함수를 구현할 때 컨텍스트 개체를 사용하여 파티션에 대한 정보와 검사점 기능을 가져옵니다.
속성
| consumer |
소비자 그룹 이름입니다. |
| event |
이벤트 허브 이름입니다. |
| fully |
정규화된 Event Hubs 네임스페이스입니다. 이것은 yournamespace.servicebus.windows.net> 유사할 수 있습니다<. |
| last |
처리 중인 파티션의 마지막 큐에 포함된 이벤트에 대한 정보입니다.
이 속성은 EventProcessor 인스턴스를 만들 때 |
| partition |
이벤트 허브 파티션의 식별자입니다. |
메서드
| update |
이벤트 데이터를 사용하여 검사점을 업데이트합니다. 검사점은 Event Hub 인스턴스에 있는 소비자 그룹의 특정 파티션에서 사용자가 마지막으로 성공적으로 처리한 이벤트를 나타내기 위한 것입니다. |
속성 세부 정보
consumerGroup
소비자 그룹 이름입니다.
consumerGroup: string
속성 값
string
eventHubName
이벤트 허브 이름입니다.
eventHubName: string
속성 값
string
fullyQualifiedNamespace
정규화된 Event Hubs 네임스페이스입니다. 이것은 yournamespace.servicebus.windows.net> 유사할 수 있습니다<.
fullyQualifiedNamespace: string
속성 값
string
lastEnqueuedEventProperties
처리 중인 파티션의 마지막 큐에 포함된 이벤트에 대한 정보입니다.
이 속성은 EventProcessor 인스턴스를 만들 때 trackLastEnqueuedEventProperties 옵션이 true로 설정된 경우에만 업데이트됩니다.
lastEnqueuedEventProperties?: LastEnqueuedEventProperties
속성 값
partitionId
이벤트 허브 파티션의 식별자입니다.
partitionId: string
속성 값
string
메서드 세부 정보
updateCheckpoint(ReceivedEventData)
이벤트 데이터를 사용하여 검사점을 업데이트합니다.
검사점은 Event Hub 인스턴스에 있는 소비자 그룹의 특정 파티션에서 사용자가 마지막으로 성공적으로 처리한 이벤트를 나타내기 위한 것입니다.
function updateCheckpoint(eventData: ReceivedEventData): Promise<void>
매개 변수
- eventData
- ReceivedEventData
검사점을 업데이트하려는 이벤트입니다.
반환
Promise<void>