PartitionContext interface
Interfejs opisujący kontekst przekazywany do każdej funkcji będącej częścią elementu SubscriptionEventHandlers
. Podczas implementowania dowolnej z tych funkcji użyj obiektu kontekstu, aby uzyskać informacje o partycji, a także możliwość tworzenia punktów kontrolnych.
Właściwości
consumer |
Nazwa grupy odbiorców. |
event |
Nazwa centrum zdarzeń. |
fully |
W pełni kwalifikowana przestrzeń nazw usługi Event Hubs. Prawdopodobnie będzie to podobne do .servicebus.windows.net |
last |
Informacje o ostatnim zdarzeniu w kolejce w partycji, która jest przetwarzana.
Ta właściwość jest aktualizowana tylko wtedy, gdy |
partition |
Identyfikator partycji centrum zdarzeń. |
Metody
update |
Aktualizacje punkt kontrolny przy użyciu danych zdarzenia. Punkt kontrolny jest przeznaczony do reprezentowania ostatniego pomyślnie przetworzonego zdarzenia przez użytkownika z określonej partycji grupy odbiorców w wystąpieniu centrum zdarzeń. |
Szczegóły właściwości
consumerGroup
Nazwa grupy odbiorców.
consumerGroup: string
Wartość właściwości
string
eventHubName
Nazwa centrum zdarzeń.
eventHubName: string
Wartość właściwości
string
fullyQualifiedNamespace
W pełni kwalifikowana przestrzeń nazw usługi Event Hubs. Prawdopodobnie będzie to podobne do .servicebus.windows.net
fullyQualifiedNamespace: string
Wartość właściwości
string
lastEnqueuedEventProperties
Informacje o ostatnim zdarzeniu w kolejce w partycji, która jest przetwarzana.
Ta właściwość jest aktualizowana tylko wtedy, gdy trackLastEnqueuedEventProperties
opcja jest ustawiona na wartość true podczas tworzenia wystąpienia klasy EventProcessor.
lastEnqueuedEventProperties?: LastEnqueuedEventProperties
Wartość właściwości
partitionId
Identyfikator partycji centrum zdarzeń.
partitionId: string
Wartość właściwości
string
Szczegóły metody
updateCheckpoint(ReceivedEventData)
Aktualizacje punkt kontrolny przy użyciu danych zdarzenia.
Punkt kontrolny jest przeznaczony do reprezentowania ostatniego pomyślnie przetworzonego zdarzenia przez użytkownika z określonej partycji grupy odbiorców w wystąpieniu centrum zdarzeń.
function updateCheckpoint(eventData: ReceivedEventData): Promise<void>
Parametry
- eventData
- ReceivedEventData
Zdarzenie, za pomocą którego chcesz zaktualizować punkt kontrolny.
Zwraca
Promise<void>