CheckpointStore Kelas

CheckpointStore berkaitan dengan interaksi dengan layanan penyimpanan yang dipilih.

Ini dapat mencantumkan dan mengklaim kepemilikan partisi serta mencantumkan dan menyimpan titik pemeriksaan.

Warisan

ABC

CheckpointStore

Konstruktor

CheckpointStore()

Metode

claim_ownership	Mencoba mengklaim kepemilikan untuk daftar partisi tertentu.
list_checkpoints	Cantumkan titik pemeriksaan yang diperbarui dari layanan penyimpanan yang dipilih.
list_ownership	Mengambil daftar kepemilikan lengkap dari layanan penyimpanan yang dipilih.
update_checkpoint	Updates titik pemeriksaan menggunakan informasi yang diberikan untuk offset, partisi terkait, dan grup konsumen dalam layanan penyimpanan yang dipilih. Catatan: Jika Anda berencana untuk menerapkan penyimpanan titik pemeriksaan kustom dengan niat menjalankan antara SDK EventHubs lintas bahasa, disarankan untuk mempertahankan nilai offset sebagai bilangan bulat.

claim_ownership

Mencoba mengklaim kepemilikan untuk daftar partisi tertentu.

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

Parameter

Nama	Deskripsi
ownership_list Diperlukan	Iterable[Dict[str,Any]] Iterable kamus yang berisi semua kepemilikan untuk diklaim.

Mengembalikan

Jenis

Deskripsi

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

Cantumkan titik pemeriksaan yang diperbarui dari layanan penyimpanan yang dipilih.

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

Parameter

Nama	Deskripsi
fully_qualified_namespace Diperlukan	str Namespace layanan yang sepenuhnya memenuhi syarat tempat Pusat Aktivitas berada. Formatnya seperti ".servicebus.windows.net".
eventhub_name Diperlukan	str Nama Pusat Aktivitas tertentu yang dikaitkan dengan titik pemeriksaan, relatif terhadap namespace layanan Azure Event Hubs yang berisinya.
consumer_group Diperlukan	str Nama grup konsumen yang dikaitkan dengan titik pemeriksaan.

Mengembalikan

Jenis

Deskripsi

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

Mengambil daftar kepemilikan lengkap dari layanan penyimpanan yang dipilih.

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

Parameter

Nama	Deskripsi
fully_qualified_namespace Diperlukan	str Namespace layanan yang sepenuhnya memenuhi syarat tempat Pusat Aktivitas berada. Formatnya seperti ".servicebus.windows.net".
eventhub_name Diperlukan	str Nama Event Hub tertentu yang dikaitkan dengan kepemilikan partisi, relatif terhadap namespace layanan Azure Event Hubs yang berisinya.
consumer_group Diperlukan	str Nama grup konsumen yang terkait dengan kepemilikan.

Mengembalikan

Jenis

Deskripsi

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

Updates titik pemeriksaan menggunakan informasi yang diberikan untuk offset, partisi terkait, dan grup konsumen dalam layanan penyimpanan yang dipilih.

Catatan: Jika Anda berencana untuk menerapkan penyimpanan titik pemeriksaan kustom dengan niat menjalankan antara SDK EventHubs lintas bahasa, disarankan untuk mempertahankan nilai offset sebagai bilangan bulat.

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

Parameter

Nama

Deskripsi

checkpoint Diperlukan

Dict[str,Any] Dict yang berisi informasi titik pemeriksaan: fully_qualified_namespace (str): Namespace yang sepenuhnya memenuhi syarat tempat Pusat Aktivitas berada. Formatnya seperti ".servicebus.windows.net". eventhub_name (str): Nama Pusat Aktivitas tertentu yang dikaitkan dengan titik pemeriksaan, relatif terhadap namespace layanan Azure Event Hubs yang berisinya. consumer_group (str): Nama grup konsumen yang dikaitkan dengan titik pemeriksaan. partition_id (str): ID partisi tempat titik pemeriksaan dibuat. sequence_number (int): Nomor EventData urut titik pemeriksaan baru akan dikaitkan. offset (str): Offset EventData titik pemeriksaan baru akan dikaitkan.

Mengembalikan

Jenis	Deskripsi
None