PartitionContext interface
Interfész, amely leírja az egyes függvények számára átadott környezetet, amelyek a SubscriptionEventHandlers
részét képezik. Ezen függvények bármelyikének implementálásakor a környezeti objektummal lekérheti a partícióval kapcsolatos információkat, valamint ellenőrizheti az ellenőrzőpontokat.
Tulajdonságok
consumer |
A fogyasztói csoport neve. |
event |
Az eseményközpont neve. |
fully |
A teljes Event Hubs-névtér. Ez valószínűleg hasonló lesz a .servicebus.windows.net |
last |
Információk a feldolgozott partíció utolsó lekérdezett eseményéről.
Ez a tulajdonság csak akkor frissül, ha a |
partition |
Az Event Hub-partíció azonosítója. |
Metódusok
update |
Frissítések az ellenőrzőpontot az eseményadatok használatával. Az ellenőrzőpont azt az utolsó sikeresen feldolgozott eseményt jelöli, amelyet a felhasználó az Event Hub-példányban lévő fogyasztói csoport adott partíciójából kapott. |
Tulajdonság adatai
consumerGroup
A fogyasztói csoport neve.
consumerGroup: string
Tulajdonság értéke
string
eventHubName
Az eseményközpont neve.
eventHubName: string
Tulajdonság értéke
string
fullyQualifiedNamespace
A teljes Event Hubs-névtér. Ez valószínűleg hasonló lesz a .servicebus.windows.net
fullyQualifiedNamespace: string
Tulajdonság értéke
string
lastEnqueuedEventProperties
Információk a feldolgozott partíció utolsó lekérdezett eseményéről.
Ez a tulajdonság csak akkor frissül, ha a trackLastEnqueuedEventProperties
beállítás igaz értékre van állítva az EventProcessor-példány létrehozásakor.
lastEnqueuedEventProperties?: LastEnqueuedEventProperties
Tulajdonság értéke
partitionId
Az Event Hub-partíció azonosítója.
partitionId: string
Tulajdonság értéke
string
Metódus adatai
updateCheckpoint(ReceivedEventData)
Frissítések az ellenőrzőpontot az eseményadatok használatával.
Az ellenőrzőpont azt az utolsó sikeresen feldolgozott eseményt jelöli, amelyet a felhasználó az Event Hub-példányban lévő fogyasztói csoport adott partíciójából kapott.
function updateCheckpoint(eventData: ReceivedEventData): Promise<void>
Paraméterek
- eventData
- ReceivedEventData
Az az esemény, amellyel frissíteni szeretné az ellenőrzőpontot.
Válaszok
Promise<void>