PartitionContext Kelas

Berisi informasi konteks terkait partisi.

Instans PartitionContext akan diteruskan ke panggilan balik peristiwa, kesalahan, dan inisialisasi yang ditentukan saat memanggil EventHubConsumerClient.receive(). Pengguna dapat memanggil update_checkpoint() kelas ini untuk mempertahankan data titik pemeriksaan.

Warisan

builtins.object

PartitionContext

Konstruktor

PartitionContext(fully_qualified_namespace: str, eventhub_name: str, consumer_group: str, partition_id: str, checkpoint_store: CheckpointStore | None = None)

Parameter

Nama	Deskripsi
fully_qualified_namespace Diperlukan
eventhub_name Diperlukan
consumer_group Diperlukan
partition_id Diperlukan
checkpoint_store	nilai default: None

Metode

update_checkpoint

Updates titik pemeriksaan terima ke offset peristiwa yang diberikan.

update_checkpoint

Updates titik pemeriksaan terima ke offset peristiwa yang diberikan.

update_checkpoint(event: EventData | None = None, **kwargs: Any) -> None

Parameter

Nama	Deskripsi
event	EventData Instans EventData yang berisi informasi offset dan nomor urutan yang digunakan untuk titik pemeriksaan. nilai default: None

Mengembalikan

Jenis	Deskripsi
None

Atribut

last_enqueued_event_properties

Informasi peristiwa antrean terbaru.

Properti ini akan diperbarui setiap kali peristiwa diterima jika penerima dibuat dengan track_last_enqueued_event_properties diatur ke True. Dict properti mencakup informasi berikut dari peristiwa antrean terakhir:

• sequence_number (int)

• offset (str)

• enqueued_time (datetime.datetime UTC)

• retrieval_time (datetime.datetime UTC)

Mengembalikan

Jenis	Deskripsi
Dict[str, Any], None