CheckpointStore Klas

CheckpointStore behandelt de interactie met de gekozen opslagservice.

Het kan partitieeigendom weergeven en claimen, evenals controlepunten weergeven en opslaan.

Overname

builtins.object

CheckpointStore

Constructor

CheckpointStore()

Methoden

claim_ownership	Probeert eigendom te claimen voor een lijst met opgegeven partities.
list_checkpoints	Vermeld de bijgewerkte controlepunten van de gekozen opslagservice.
list_ownership	Hiermee haalt u een volledige eigendomslijst op uit de gekozen opslagservice.
update_checkpoint	Updates het controlepunt met behulp van de opgegeven informatie voor de offset, de bijbehorende partitie en de consumentengroep in de gekozen opslagservice. Opmerking: als u van plan bent om een aangepast controlepuntarchief te implementeren met de bedoeling om uit te voeren tussen de EventHubs-SDK's in meerdere talen, is het raadzaam om de offsetwaarde als geheel getal te behouden.

claim_ownership

Probeert eigendom te claimen voor een lijst met opgegeven partities.

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

Parameters

Name	Description
ownership_list Vereist	Iterable[Dict[str,Any]] Itereerbaar van woordenlijsten die alle eigendom bevatten die moeten worden geclaimd.

Retouren

Type

Description

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

Vermeld de bijgewerkte controlepunten van de gekozen opslagservice.

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

Parameters

Name	Description
fully_qualified_namespace Vereist	str De volledig gekwalificeerde naamruimte waartoe de Event Hub behoort. De indeling is als '.servicebus.windows.net'.
eventhub_name Vereist	str De naam van de specifieke Event Hub waaraan de controlepunten zijn gekoppeld, ten opzichte van de Event Hubs-naamruimte die deze bevat.
consumer_group Vereist	str De naam van de consumentengroep waarmee de controlepunten zijn gekoppeld.

Retouren

Type

Description

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

Hiermee haalt u een volledige eigendomslijst op uit de gekozen opslagservice.

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

Parameters

Name	Description
fully_qualified_namespace Vereist	str De volledig gekwalificeerde naamruimte waartoe de Event Hub behoort. De indeling is als '.servicebus.windows.net'.
eventhub_name Vereist	str De naam van de specifieke Event Hub waaraan de partitie-eigendomen zijn gekoppeld, ten opzichte van de Event Hubs-naamruimte die deze bevat.
consumer_group Vereist	str De naam van de consumentengroep waarmee de eigendom is gekoppeld.

Retouren

Type

Description

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 het controlepunt met behulp van de opgegeven informatie voor de offset, de bijbehorende partitie en de consumentengroep in de gekozen opslagservice.

Opmerking: als u van plan bent om een aangepast controlepuntarchief te implementeren met de bedoeling om uit te voeren tussen de EventHubs-SDK's in meerdere talen, is het raadzaam om de offsetwaarde als geheel getal te behouden.

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

Parameters

Name

Description

checkpoint Vereist

Dict[str,Any] Een dict met controlepuntgegevens: fully_qualified_namespace (str): de volledig gekwalificeerde naamruimte waartoe de Event Hub behoort. De indeling is als '.servicebus.windows.net'. eventhub_name (str): de naam van de specifieke Event Hub waaraan het controlepunt is gekoppeld, ten opzichte van de Event Hubs-naamruimte die het bevat. consumer_group (str): de naam van de consumentengroep waarmee het controlepunt is gekoppeld. partition_id (str): de partitie-id waarvoor het controlepunt is gemaakt. sequence_number (int): het volgnummer van het EventData nieuwe controlepunt wordt gekoppeld aan. offset (str): de verschuiving van het EventData nieuwe controlepunt wordt gekoppeld aan.

Retouren

Type	Description
None