CheckpointStore Класс
CheckpointStore занимается взаимодействием с выбранной службой хранилища.
Он может перечислять и запрашивать права владения секциями, а также перечислять и сохранять контрольные точки.
- Наследование
-
CheckpointStore
Конструктор
CheckpointStore()
Методы
claim_ownership |
Пытается запросить владение списком указанных секций. |
list_checkpoints |
Список обновленных контрольных точек из выбранной службы хранилища. |
list_ownership |
Извлекает полный список владельцев из выбранной службы хранилища. |
update_checkpoint |
Обновления контрольную точку, используя указанные сведения для смещения, связанной секции и группы потребителей в выбранной службе хранилища. Примечание. Если вы планируете реализовать пользовательское хранилище контрольных точек с целью выполнения между пакетами SDK для центров событий на разных языках, рекомендуется сохранить значение смещения в виде целого числа. |
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 <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
Обязательно
|
Полное пространство имен, к которому принадлежит концентратор событий. Формат имеет вид ".servicebus.windows.net". |
eventhub_name
Обязательно
|
Имя конкретного концентратора событий, с которым связаны контрольные точки, относительно пространства имен Центров событий, в котором он содержится. |
consumer_group
Обязательно
|
Имя группы потребителей, с которыми связаны контрольные точки. |
Возвращаемое значение
Тип | Описание |
---|---|
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
Обязательно
|
Полное пространство имен, к которому принадлежит концентратор событий. Формат имеет вид ".servicebus.windows.net". |
eventhub_name
Обязательно
|
Имя конкретного концентратора событий, с которым связаны секции, относительно пространства имен Центров событий, в котором он содержится. |
consumer_group
Обязательно
|
Имя группы потребителей, с которыми связаны владения. |
Возвращаемое значение
Тип | Описание |
---|---|
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
Обновления контрольную точку, используя указанные сведения для смещения, связанной секции и группы потребителей в выбранной службе хранилища.
Примечание. Если вы планируете реализовать пользовательское хранилище контрольных точек с целью выполнения между пакетами SDK для центров событий на разных языках, рекомендуется сохранить значение смещения в виде целого числа.
abstract async update_checkpoint(checkpoint: Dict[str, str | int | None], **kwargs: Any) -> None
Параметры
Имя | Описание |
---|---|
checkpoint
Обязательно
|
Словарь, содержащий сведения о контрольной точке:
|
Возвращаемое значение
Тип | Описание |
---|---|
Azure SDK for Python