CheckpointStore الفصل

يتعامل CheckpointStore مع التفاعل مع خدمة التخزين المختارة.

يمكنه سرد ملكية القسم والمطالبة بها بالإضافة إلى سرد نقاط التحقق وحفظها.

توريث

ABC

CheckpointStore

الدالمنشئ

CheckpointStore()

الأساليب

claim_ownership	يحاول المطالبة بالملكية لقائمة بالأقسام المحددة.
list_checkpoints	سرد نقاط التحقق المحدثة من خدمة التخزين المختارة.
list_ownership	استرداد قائمة ملكية كاملة من خدمة التخزين المختارة.
update_checkpoint	التحديثات نقطة التحقق باستخدام المعلومات المحددة للإزاحة والقسم المرتبط ومجموعة المستهلكين في خدمة التخزين المختارة. ملاحظة: إذا كنت تخطط لتنفيذ مخزن نقاط تحقق مخصص بهدف التشغيل بين EventHubs SDKs عبر اللغات، فمن المستحسن الاحتفاظ بقيمة الإزاحة كأعداد صحيحة.

claim_ownership

يحاول المطالبة بالملكية لقائمة بالأقسام المحددة.

abstract async claim_ownership(ownership_list: Iterable[Dict[str, Any]], **kwargs: Any) -> Iterable[Dict[str, Any]]

المعلمات

الاسم	الوصف
ownership_list مطلوب	Iterable[Dict[str,Any]] قابلة للتكبير من القواميس التي تحتوي على جميع الملكية للمطالبة.

المرتجعات

النوع

الوصف

Iterable[Dict[str,Any]], Iterable <xref:of> <xref:dictionaries> <xref:containing> <xref:azure.eventhub.amqp.AmqpMessageBodyType.partition> <xref:ownership> <xref:information>:fully_qualified_namespace (str): <xref:The> <xref:fully> <xref:qualified> <xref:namespace> <xref:that> <xref:the> <xref:Event> <xref:Hub> <xref:belongs> <xref:to.> <xref:The> <xref:azure.eventhub.amqp.AmqpMessageBodyType.format> <xref:is> <xref:like> “<<xref:namespace>><xref:.servicebus.windows.net>”<xref:.> eventhub_name (str): <xref:The> <xref:name> <xref:of> <xref:the> <xref:specific> <xref:Event> <xref:Hub> <xref:the> <xref:checkpoint> <xref:is> <xref:associated> <xref:with>, <xref:relative> <xref:to> <xref:the> <xref:Event> <xref:Hubs> <xref:namespace> <xref:that> <xref:contains> <xref:it.> <xref:consumer_group> (str): <xref:The> <xref:name> <xref:of> <xref:the> <xref:consumer> <xref:group> <xref:the> <xref:ownership> <xref:are> <xref:associated> <xref:with.> <xref:partition_id> (str): <xref:The> <xref:azure.eventhub.amqp.AmqpMessageBodyType.partition> <xref:ID> <xref:which> <xref:the> <xref:checkpoint> <xref:is> <xref:created> <xref:for.> <xref:owner_id> (str): <xref:A> <xref:UUID> <xref:representing> <xref:the> <xref:owner> <xref:attempting> <xref:to> <xref:claim> <xref:this> <xref:partition.> <xref:last_modified_time> (<xref:UTC> datetime): <xref:The> <xref:last> time <xref:this> <xref:ownership> <xref:was> <xref:claimed.> <xref:etag> (str): <xref:The> <xref:Etag> <xref:value> <xref:for> <xref:the> <xref:last> time <xref:this> <xref:ownership> <xref:was> <xref:modified.> Optional <xref:depending> <xref:on> <xref:storage> <xref:implementation.>

list_checkpoints

سرد نقاط التحقق المحدثة من خدمة التخزين المختارة.

abstract async list_checkpoints(fully_qualified_namespace: str, eventhub_name: str, consumer_group: str, **kwargs: Any) -> Iterable[Dict[str, Any]]

المعلمات

الاسم	الوصف
fully_qualified_namespace مطلوب	str مساحة الاسم المؤهلة بالكامل التي ينتمي إليها Event Hub. التنسيق مثل ".servicebus.windows.net".
eventhub_name مطلوب	str اسم Event Hub المحدد الذي ترتبط به نقاط التحقق، بالنسبة إلى مساحة اسم مراكز الأحداث التي تحتوي عليه.
consumer_group مطلوب	str اسم مجموعة المستهلكين التي ترتبط بها نقاط التحقق.

المرتجعات

النوع

الوصف

Iterable[Dict[str,Any]], Iterable <xref:of> <xref:dictionaries> <xref:containing> <xref:azure.eventhub.amqp.AmqpMessageBodyType.partition> <xref:checkpoint> <xref:information>:fully_qualified_namespace (str): <xref:The> <xref:fully> <xref:qualified> <xref:namespace> <xref:that> <xref:the> <xref:Event> <xref:Hub> <xref:belongs> <xref:to.> <xref:The> <xref:azure.eventhub.amqp.AmqpMessageBodyType.format> <xref:is> <xref:like> “<<xref:namespace>><xref:.servicebus.windows.net>”<xref:.> eventhub_name (str): <xref:The> <xref:name> <xref:of> <xref:the> <xref:specific> <xref:Event> <xref:Hub> <xref:the> <xref:checkpoints> <xref:are> <xref:associated> <xref:with>, <xref:relative> <xref:to> <xref:the> <xref:Event> <xref:Hubs> <xref:namespace> <xref:that> <xref:contains> <xref:it.> <xref:consumer_group> (str): <xref:The> <xref:name> <xref:of> <xref:the> <xref:consumer> <xref:group> <xref:the> <xref:checkpoints> <xref:are> <xref:associated> <xref:with.> <xref:partition_id> (str): <xref:The> <xref:azure.eventhub.amqp.AmqpMessageBodyType.partition> <xref:ID> <xref:which> <xref:the> <xref:checkpoint> <xref:is> <xref:created> <xref:for.> sequence_number (int): <xref:The> <xref:sequence> <xref:number> <xref:of> <xref:the> <xref:EventData.> offset (str): <xref:The> offset <xref:of> <xref:the> <xref:EventData.>

list_ownership

استرداد قائمة ملكية كاملة من خدمة التخزين المختارة.

abstract async list_ownership(fully_qualified_namespace: str, eventhub_name: str, consumer_group: str, **kwargs: Any) -> Iterable[Dict[str, Any]]

المعلمات

الاسم	الوصف
fully_qualified_namespace مطلوب	str مساحة الاسم المؤهلة بالكامل التي ينتمي إليها Event Hub. التنسيق مثل ".servicebus.windows.net".
eventhub_name مطلوب	str اسم Event Hub المحدد الذي ترتبط به ملكية القسم، بالنسبة إلى مساحة اسم مراكز الأحداث التي تحتوي عليه.
consumer_group مطلوب	str اسم مجموعة المستهلكين المقترنة بالملكية.

المرتجعات

النوع

الوصف

Iterable[Dict[str, Any]], Iterable <xref:of> <xref:dictionaries> <xref:containing> <xref:azure.eventhub.amqp.AmqpMessageBodyType.partition> <xref:ownership> <xref:information>:fully_qualified_namespace (str): <xref:The> <xref:fully> <xref:qualified> <xref:namespace> <xref:that> <xref:the> <xref:Event> <xref:Hub> <xref:belongs> <xref:to.> <xref:The> <xref:azure.eventhub.amqp.AmqpMessageBodyType.format> <xref:is> <xref:like> “<<xref:namespace>><xref:.servicebus.windows.net>”<xref:.> eventhub_name (str): <xref:The> <xref:name> <xref:of> <xref:the> <xref:specific> <xref:Event> <xref:Hub> <xref:the> <xref:checkpoint> <xref:is> <xref:associated> <xref:with>, <xref:relative> <xref:to> <xref:the> <xref:Event> <xref:Hubs> <xref:namespace> <xref:that> <xref:contains> <xref:it.> <xref:consumer_group> (str): <xref:The> <xref:name> <xref:of> <xref:the> <xref:consumer> <xref:group> <xref:the> <xref:ownership> <xref:are> <xref:associated> <xref:with.> <xref:partition_id> (str): <xref:The> <xref:azure.eventhub.amqp.AmqpMessageBodyType.partition> <xref:ID> <xref:which> <xref:the> <xref:checkpoint> <xref:is> <xref:created> <xref:for.> <xref:owner_id> (str): <xref:A> <xref:UUID> <xref:representing> <xref:the> <xref:current> <xref:owner> <xref:of> <xref:this> <xref:partition.> <xref:last_modified_time> (<xref:UTC> datetime): <xref:The> <xref:last> time <xref:this> <xref:ownership> <xref:was> <xref:claimed.> <xref:etag> (str): <xref:The> <xref:Etag> <xref:value> <xref:for> <xref:the> <xref:last> time <xref:this> <xref:ownership> <xref:was> <xref:modified.> Optional <xref:depending> <xref:on> <xref:storage> <xref:implementation.>

update_checkpoint

التحديثات نقطة التحقق باستخدام المعلومات المحددة للإزاحة والقسم المرتبط ومجموعة المستهلكين في خدمة التخزين المختارة.

ملاحظة: إذا كنت تخطط لتنفيذ مخزن نقاط تحقق مخصص بهدف التشغيل بين EventHubs SDKs عبر اللغات، فمن المستحسن الاحتفاظ بقيمة الإزاحة كأعداد صحيحة.

abstract async update_checkpoint(checkpoint: Dict[str, str | int | None], **kwargs: Any) -> None

المعلمات

الاسم

الوصف

checkpoint مطلوب

Dict[str,Any] إملاء يحتوي على معلومات نقطة التحقق: fully_qualified_namespace (str): مساحة الاسم المؤهلة بالكامل التي ينتمي إليها Event Hub. التنسيق مثل ".servicebus.windows.net". eventhub_name (str): اسم Event Hub المحدد الذي ترتبط به نقطة التحقق، بالنسبة إلى مساحة اسم مراكز الأحداث التي تحتوي عليه. consumer_group (str): اسم مجموعة المستهلكين التي ترتبط بها نقطة التحقق. partition_id (str): معرف القسم الذي تم إنشاء نقطة التحقق له. sequence_number (int): سيتم ربط رقم EventData تسلسل نقطة التحقق الجديدة. الإزاحة (str): سيتم إقران إزاحة EventData نقطة التحقق الجديدة.

المرتجعات

النوع	الوصف
None