PartitionContext الفصل

يحتوي على معلومات السياق المتعلقة بالقسم.

سيتم تمرير مثيل PartitionContext إلى الحدث والخطأ وتهيئة الاستدعاءات المحددة عند استدعاء EventHubConsumerClient.receive(). يمكن للمستخدمين استدعاء update_checkpoint() من هذه الفئة لاستمرار بيانات نقطة التحقق.

توريث

builtins.object

PartitionContext

الدالمنشئ

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

المعلمات

الاسم	الوصف
fully_qualified_namespace مطلوب
eventhub_name مطلوب
consumer_group مطلوب
partition_id مطلوب
checkpoint_store	القيمة الافتراضية: None

الأساليب

update_checkpoint

التحديثات نقطة التحقق التلقي إلى إزاحة الأحداث المحددة.

update_checkpoint

التحديثات نقطة التحقق التلقي إلى إزاحة الأحداث المحددة.

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

المعلمات

الاسم	الوصف
event	EventData مثيل EventData الذي يحتوي على معلومات رقم الإزاحة والتسلسل المستخدمة لنقطة التحقق. القيمة الافتراضية: None

المرتجعات

النوع	الوصف
None

السمات

last_enqueued_event_properties

أحدث معلومات الحدث المدرجة في قائمة الانتظار.

سيتم تحديث هذه الخاصية في كل مرة يتم فيها تلقي حدث إذا تم إنشاء المتلقي مع تعيين track_last_enqueued_event_properties إلى True. تتضمن لوحة الخصائص المعلومات التالية لآخر حدث مدرج في قائمة الانتظار:

• sequence_number (int)

• إزاحة (str)

• enqueued_time (UTC datetime.datetime)

• retrieval_time (UTC datetime.datetime)

المرتجعات

النوع	الوصف
dict, None