PartitionContext interface

Paket:

@azure/event-hubs

Antarmuka yang menjelaskan konteks yang diteruskan ke masing-masing fungsi yang merupakan bagian dari SubscriptionEventHandlers. Saat menerapkan salah satu fungsi ini, gunakan objek konteks untuk mendapatkan informasi tentang partisi serta kemampuan untuk titik pemeriksaan.

Properti

consumerGroup	Nama grup konsumen.
eventHubName	Nama pusat aktivitas.
fullyQualifiedNamespace	Namespace Layanan Azure Event Hubs yang sepenuhnya memenuhi syarat. Ini kemungkinan mirip dengan <ruang> nama Anda.servicebus.windows.net
lastEnqueuedEventProperties	Informasi tentang peristiwa antrean terakhir dalam partisi yang sedang diproses. Properti ini hanya diperbarui jika opsi trackLastEnqueuedEventProperties diatur ke true saat membuat instans EventProcessor.
partitionId	Pengidentifikasi partisi Pusat Aktivitas.

Metode

updateCheckpoint(ReceivedEventData)

Memperbarui titik pemeriksaan menggunakan data peristiwa. Titik pemeriksaan dimaksudkan untuk mewakili peristiwa terakhir yang berhasil diproses oleh pengguna dari partisi tertentu dari grup konsumen dalam instans Pusat Aktivitas.

Detail Properti

consumerGroup

Nama grup konsumen.

consumerGroup: string

Nilai Properti

string

eventHubName

Nama pusat aktivitas.

eventHubName: string

Nilai Properti

string

fullyQualifiedNamespace

Namespace Layanan Azure Event Hubs yang sepenuhnya memenuhi syarat. Ini kemungkinan mirip dengan <ruang> nama Anda.servicebus.windows.net

fullyQualifiedNamespace: string

Nilai Properti

string

lastEnqueuedEventProperties

Informasi tentang peristiwa antrean terakhir dalam partisi yang sedang diproses. Properti ini hanya diperbarui jika opsi trackLastEnqueuedEventProperties diatur ke true saat membuat instans EventProcessor.

lastEnqueuedEventProperties?: LastEnqueuedEventProperties

Nilai Properti

LastEnqueuedEventProperties

partitionId

Pengidentifikasi partisi Pusat Aktivitas.

partitionId: string

Nilai Properti

string

Detail Metode

updateCheckpoint(ReceivedEventData)

Memperbarui titik pemeriksaan menggunakan data peristiwa.

Titik pemeriksaan dimaksudkan untuk mewakili peristiwa terakhir yang berhasil diproses oleh pengguna dari partisi tertentu dari grup konsumen dalam instans Pusat Aktivitas.

function updateCheckpoint(eventData: ReceivedEventData): Promise<void>

Parameter

eventData

ReceivedEventData

Kejadian yang ingin Anda perbarui titik pemeriksaannya.

Mengembalikan

Promise<void>