CheckpointStore Clase

CheckpointStore se ocupa de la interacción con el servicio de almacenamiento elegido.

Puede enumerar y reclamar las propiedades de las particiones, así como enumerar y guardar puntos de control.

Herencia

ABC

CheckpointStore

Constructor

CheckpointStore()

Métodos

claim_ownership	Intenta reclamar la propiedad de una lista de particiones especificadas.
list_checkpoints	Enumere los puntos de control actualizados del servicio de almacenamiento elegido.
list_ownership	Recupera una lista de propiedad completa del servicio de almacenamiento elegido.
update_checkpoint	Novedades el punto de control mediante la información especificada para el desplazamiento, la partición asociada y el grupo de consumidores en el servicio de almacenamiento elegido. Nota: Si tiene previsto implementar un almacén de puntos de control personalizado con la intención de ejecutarse entre sdk de EventHubs entre lenguajes, se recomienda conservar el valor de desplazamiento como un entero.

claim_ownership

Intenta reclamar la propiedad de una lista de particiones especificadas.

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

Parámetros

Nombre	Description
ownership_list Requerido	Iterable[Dict[str,Any]] Se puede iterar de diccionarios que contienen todas las propiedades que se van a reclamar.

Devoluciones

Tipo

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

Enumere los puntos de control actualizados del servicio de almacenamiento elegido.

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

Parámetros

Nombre	Description
fully_qualified_namespace Requerido	str Espacio de nombres completo al que pertenece el centro de eventos. El formato es como ".servicebus.windows.net".
eventhub_name Requerido	str Nombre del centro de eventos específico al que están asociados los puntos de control, en relación con el espacio de nombres de Event Hubs que lo contiene.
consumer_group Requerido	str Nombre del grupo de consumidores al que están asociados los puntos de control.

Devoluciones

Tipo

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

Recupera una lista de propiedad completa del servicio de almacenamiento elegido.

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

Parámetros

Nombre	Description
fully_qualified_namespace Requerido	str Espacio de nombres completo al que pertenece el centro de eventos. El formato es como ".servicebus.windows.net".
eventhub_name Requerido	str Nombre del centro de eventos específico al que están asociadas las propiedades de la partición, en relación con el espacio de nombres de Event Hubs que lo contiene.
consumer_group Requerido	str Nombre del grupo de consumidores al que están asociadas las propiedades.

Devoluciones

Tipo

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

Novedades el punto de control mediante la información especificada para el desplazamiento, la partición asociada y el grupo de consumidores en el servicio de almacenamiento elegido.

Nota: Si tiene previsto implementar un almacén de puntos de control personalizado con la intención de ejecutarse entre sdk de EventHubs entre lenguajes, se recomienda conservar el valor de desplazamiento como un entero.

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

Parámetros

Nombre

Description

checkpoint Requerido

Dict[str,Any] Un dict que contiene información de punto de control: fully_qualified_namespace (str): espacio de nombres completo al que pertenece el centro de eventos. El formato es como ".servicebus.windows.net". eventhub_name (str): el nombre del centro de eventos específico al que está asociado el punto de control, en relación con el espacio de nombres de Event Hubs que lo contiene. consumer_group (str): nombre del grupo de consumidores al que está asociado el punto de control. partition_id (str): identificador de partición para el que se crea el punto de control. sequence_number (int): el número de secuencia del EventData nuevo punto de control se asociará. offset (str): el desplazamiento del nuevo punto de EventData control se asociará.

Devoluciones

Tipo	Description
None