PartitionContext interface
Interfejs opisujący kontekst przekazywany do każdej funkcji, które są częścią 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 jest to podobne do <yournamespace.servicebus.windows.net> |
| last |
Informacje na temat ostatniego zdarzenia w kolejce w przetwarzanej partycji.
Ta właściwość jest aktualizowana tylko wtedy, gdy opcja |
| partition |
Identyfikator partycji centrum zdarzeń. |
Metody
| update |
Aktualizuje 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 jest to podobne do <yournamespace.servicebus.windows.net>
fullyQualifiedNamespace: string
Wartość właściwości
string
lastEnqueuedEventProperties
Informacje na temat ostatniego zdarzenia w kolejce w przetwarzanej partycji.
Ta właściwość jest aktualizowana tylko wtedy, gdy opcja trackLastEnqueuedEventProperties 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)
Aktualizuje 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>