PartitionContext interface
Interfaccia che descrive il contesto passato a ognuna delle funzioni che fanno parte del SubscriptionEventHandlers
. Quando si implementa una di queste funzioni, usare l'oggetto contesto per ottenere informazioni sulla partizione e sulla possibilità di eseguire il checkpoint.
Proprietà
consumer |
Nome del gruppo di consumer. |
event |
Nome dell'hub eventi. |
fully |
Spazio dei nomi completo di Hub eventi. È probabile che sia simile a .servicebus.windows.net |
last |
Informazioni sull'ultimo evento accodato nella partizione in corso di elaborazione.
Questa proprietà viene aggiornata solo se l'opzione |
partition |
Identificatore della partizione dell'hub eventi. |
Metodi
update |
Aggiorna il checkpoint usando i dati dell'evento. Un checkpoint è progettato per rappresentare l'ultimo evento elaborato correttamente dall'utente da una particolare partizione di un gruppo di consumer in un'istanza di Hub eventi. |
Dettagli proprietà
consumerGroup
Nome del gruppo di consumer.
consumerGroup: string
Valore della proprietà
string
eventHubName
Nome dell'hub eventi.
eventHubName: string
Valore della proprietà
string
fullyQualifiedNamespace
Spazio dei nomi completo di Hub eventi. È probabile che sia simile a .servicebus.windows.net
fullyQualifiedNamespace: string
Valore della proprietà
string
lastEnqueuedEventProperties
Informazioni sull'ultimo evento accodato nella partizione in corso di elaborazione.
Questa proprietà viene aggiornata solo se l'opzione trackLastEnqueuedEventProperties
è impostata su true durante la creazione di un'istanza di EventProcessor.
lastEnqueuedEventProperties?: LastEnqueuedEventProperties
Valore della proprietà
partitionId
Identificatore della partizione dell'hub eventi.
partitionId: string
Valore della proprietà
string
Dettagli metodo
updateCheckpoint(ReceivedEventData)
Aggiorna il checkpoint usando i dati dell'evento.
Un checkpoint è progettato per rappresentare l'ultimo evento elaborato correttamente dall'utente da una particolare partizione di un gruppo di consumer in un'istanza di Hub eventi.
function updateCheckpoint(eventData: ReceivedEventData): Promise<void>
Parametri
- eventData
- ReceivedEventData
Evento con cui si vuole aggiornare il checkpoint.
Restituisce
Promise<void>