PartitionContext interface
Schnittstelle, die den Kontext beschreibt, der an jede der Funktionen übergeben wird, die Teil von SubscriptionEventHandlers
sind. Wenn Sie eine dieser Funktionen implementieren, verwenden Sie das Kontextobjekt, um Informationen über die Partition sowie die Möglichkeit zum Prüfpunkt abzurufen.
Eigenschaften
consumer |
Der Name der Consumergruppe. |
event |
Der Event Hub-Name. |
fully |
Der vollqualifizierte Event Hubs-Namespace. Dies ist wahrscheinlich ähnlich wie .servicebus.windows.net |
last |
Informationen zum letzten queued-Ereignis in der Partition, die verarbeitet wird.
Diese Eigenschaft wird nur aktualisiert, wenn die |
partition |
Der Bezeichner der Event Hub-Partition. |
Methoden
update |
Aktualisierungen den Prüfpunkt mithilfe der Ereignisdaten. Ein Prüfpunkt soll das letzte erfolgreich verarbeitete Ereignis des Benutzers aus einer bestimmten Partition einer Consumergruppe in einer Event Hub-Instanz darstellen. |
Details zur Eigenschaft
consumerGroup
Der Name der Consumergruppe.
consumerGroup: string
Eigenschaftswert
string
eventHubName
Der Event Hub-Name.
eventHubName: string
Eigenschaftswert
string
fullyQualifiedNamespace
Der vollqualifizierte Event Hubs-Namespace. Dies ist wahrscheinlich ähnlich wie .servicebus.windows.net
fullyQualifiedNamespace: string
Eigenschaftswert
string
lastEnqueuedEventProperties
Informationen zum letzten queued-Ereignis in der Partition, die verarbeitet wird.
Diese Eigenschaft wird nur aktualisiert, wenn die trackLastEnqueuedEventProperties
Option beim Erstellen einer Instanz von EventProcessor auf true festgelegt ist.
lastEnqueuedEventProperties?: LastEnqueuedEventProperties
Eigenschaftswert
partitionId
Der Bezeichner der Event Hub-Partition.
partitionId: string
Eigenschaftswert
string
Details zur Methode
updateCheckpoint(ReceivedEventData)
Aktualisierungen den Prüfpunkt mithilfe der Ereignisdaten.
Ein Prüfpunkt soll das letzte erfolgreich verarbeitete Ereignis des Benutzers aus einer bestimmten Partition einer Consumergruppe in einer Event Hub-Instanz darstellen.
function updateCheckpoint(eventData: ReceivedEventData): Promise<void>
Parameter
- eventData
- ReceivedEventData
Das Ereignis, mit dem Sie den Prüfpunkt aktualisieren möchten.
Gibt zurück
Promise<void>