Condividi tramite


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à

consumerGroup

Nome del gruppo di consumer.

eventHubName

Nome dell'hub eventi.

fullyQualifiedNamespace

Spazio dei nomi completo di Hub eventi. È probabile che sia simile a .servicebus.windows.net

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.

partitionId

Identificatore della partizione dell'hub eventi.

Metodi

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.

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>