list-shards
Описание
Отображает фрагменты в потоке и предоставляет информацию о каждом фрагменте. Данная операция имеет ограничение в 1000 транзакций в секунду на поток данных.
Примечание
При вызове этого API необходимо использовать параметрStreamARN или параметр StreamName, или оба. Рекомендуется использовать входной параметр StreamARN при вызове этого API.Данное действие не отображает устаревшие фрагменты. Для получения информации об устаревших фрагментах см. Маршрутизация данных, Сохранение данных и Состояние фрагмента после перераспределения.
Предупреждение
Этот API представляет собой новую операцию, используемую Amazon Kinesis Client Library (KCL). Если у вас есть политика IAM с тонкими настройками, разрешающая только определенные операции, необходимо обновить свою политику, чтобы разрешить вызовы этого API. Дополнительную информацию см. в разделе Управление доступом к ресурсам Amazon Kinesis Data Streams с помощью IAM.См. также: Документация API AWS
list-shards — это постраничная операция. Для получения всего набора результатов могут потребоваться несколько вызовов API. Вы можете отключить постраничный вывод, указав аргумент --no-paginate. При использовании --output text и аргумента --query в ответе с постраничным выводом аргумент --query должен извлекать данные из результатов следующих выражений запроса: Shards
Синтаксис
list-shards
[--stream-name <value>]
[--exclusive-start-shard-id <value>]
[--stream-creation-timestamp <value>]
[--shard-filter <value>]
[--stream-arn <value>]
[--cli-input-json | --cli-input-yaml]
[--starting-token <value>]
[--page-size <value>]
[--max-items <value>]
[--generate-cli-skeleton <value>]
[--debug]
[--endpoint-url <value>]
[--no-verify-ssl]
[--no-paginate]
[--output <value>]
[--query <value>]
[--profile <value>]
[--region <value>]
[--version <value>]
[--color <value>]
[--no-sign-request]
[--ca-bundle <value>]
[--cli-read-timeout <value>]
[--cli-connect-timeout <value>]
[--cli-binary-format <value>]
[--no-cli-pager]
[--cli-auto-prompt]
[--no-cli-auto-prompt]
Параметры
--stream-name (строка)
Имя потока данных, фрагменты которого требуется отобразить.
Этот параметр нельзя указать, если указан параметр NextToken.
--exclusive-start-shard-id (строка)
Укажите этот параметр, чтобы отобразить фрагменты, начиная с фрагмента, идентификатор которого следует сразу за ExclusiveStartShardId.
Если этот параметр не указан, по умолчанию ListShards отображает фрагменты, начиная с первого в потоке.
Этот параметр нельзя указать, если указан параметр NextToken.
--stream-creation-timestamp (метка времени)
Укажите этот входной параметр, чтобы различать потоки данных с одинаковыми именами. Например, если вы создали поток данных, а затем удалили его, и позже создали другой поток данных с тем же именем, вы можете использовать этот входной параметр, чтобы указать, для какого из двух потоков требуется отобразить фрагменты.
Этот параметр нельзя указать, если указан параметр NextToken.
--shard-filter (структура)
Позволяет отфильтровать ответ API ListShards. Можно указать только один фильтр за раз.
Если вы используете параметр ShardFilter при вызове API ListShards, свойство Type является обязательным и должно быть указано. Если вы указываете типы AT_TRIM_HORIZON, FROM_TRIM_HORIZON или AT_LATEST, вам не нужно указывать ни одно из необязательных свойств ShardId или Timestamp.
Если вы указываете тип AFTER_SHARD_ID, вы также должны указать значение необязательного свойства ShardId. Свойство ShardId идентично по функциональности параметру ExclusiveStartShardId API ListShards. При указании свойства ShardId ответ включает фрагменты, начиная с фрагмента, идентификатор которого следует непосредственно за ShardId, которое вы предоставили.
Если вы указываете тип AT_TIMESTAMP или FROM_TIMESTAMP_ID, вы также должны указать значение необязательного свойства Timestamp. Если вы указываете тип AT_TIMESTAMP, возвращаются все фрагменты, которые были открыты в указанную метку времени. Если вы указываете тип FROM_TIMESTAMP, возвращаются все фрагменты с указанной метки времени до TIP.
Тип -> (строка)
Тип фрагмента, указанный в параметре ShardFilter. Это обязательное свойство параметра ShardFilter.
Можно указать следующие допустимые значения:
-
AFTER_SHARD_ID— ответ включает все фрагменты, начиная с фрагмента, идентификатор которого следует сразу заShardId, который вы указали. -
AT_TRIM_HORIZON— ответ включает все фрагменты, которые были открыты вTRIM_HORIZON. -
FROM_TRIM_HORIZON— (по умолчанию), ответ включает все фрагменты в периоде хранения потока данных (усечение до tip). -
AT_LATEST— ответ включает только текущие открытые фрагменты потока данных. -
AT_TIMESTAMP— ответ включает все фрагменты, начальное время которых меньше или равно указанной метке времени, а конечное время — больше или равно указанной метке времени, или фрагменты, которые все еще открыты. -
FROM_TIMESTAMP— ответ включает все закрытые фрагменты, конечное время которых больше или равно указанной метке времени, а также все открытые фрагменты. Исправлено наTRIM_HORIZONпотока данных, еслиFROM_TIMESTAMPменьше, чем значениеTRIM_HORIZON.
ShardId -> (строка)
shardID, указанный в параметре ShardFilter. Это свойство можно использовать только при указании типа фрагмента AFTER_SHARD_ID.Timestamp -> (метка времени)
ShardFilter. Метка времени — это дата эпохи Unix с точностью до миллисекунд. Например, 2016-04-04T19:58:46.480-00:00 или 1459799926.480. Это свойство можно использовать только при указании типов FROM_TIMESTAMP или AT_TIMESTAMP.Сокращенный синтаксис:
Type=string,ShardId=string,Timestamp=timestamp
Синтаксис JSON:
{
"Type": "AFTER_SHARD_ID"|"AT_TRIM_HORIZON"|"FROM_TRIM_HORIZON"|"AT_LATEST"|"AT_TIMESTAMP"|"FROM_TIMESTAMP",
"ShardId": "string",
"Timestamp": timestamp
}
--stream-arn (строка)
--cli-input-json | --cli-input-yaml (строка) Читает аргументы из предоставленной строки JSON. Строка JSON соответствует формату, предоставленному --generate-cli-skeleton. Если на командной строке указаны другие аргументы, эти значения переопределят значения, предоставленные в формате JSON. Невозможно передавать произвольные двоичные значения с помощью значения, предоставленного в формате JSON, так как строка будет взята буквально. Это не может быть указано вместе с --cli-input-yaml.
--starting-token (строка)
Токен для указания места начала постраничного вывода. Это NextToken из ранее обрезанного ответа.
Примеры использования см. в разделе Постраничный вывод в руководстве пользователя AWS Command Line Interface.
--page-size (целое число)
Размер каждой страницы для получения в вызове AWS-сервиса. Это не влияет на количество элементов, возвращаемых в выводе команды. Установка меньшего размера страницы приводит к большему количеству вызовов AWS-сервиса, получая меньше элементов в каждом вызове. Это может помочь предотвратить истечение времени ожидания вызовов AWS-сервиса.
Примеры использования см. в разделе Постраничный вывод в руководстве пользователя AWS Command Line Interface.
--max-items (целое число)
Общее количество элементов, которые нужно вернуть в выводе команды. Если общее количество доступных элементов больше указанного значения, в выводе команды предоставляется NextToken. Чтобы продолжить постраничный вывод, предоставьте значение NextToken в аргументе starting-token последующей команды. Не используйте элемент ответа NextToken непосредственно за пределами AWS CLI.
Примеры использования см. в разделе Постраничный вывод в руководстве пользователя AWS Command Line Interface.
--generate-cli-skeleton (строка) Выводит каркас JSON в стандартный вывод без отправки запроса API. Если указано без значения или со значением input, выводит пример JSON-ввода, который можно использовать в качестве аргумента для --cli-input-json. Аналогично, если указано yaml-input, выводится пример YAML-ввода, который можно использовать с --cli-input-yaml. Если указано значение output, выполняется проверка входных данных команды и возвращается пример выходного JSON для этой команды. Сгенерированный JSON-каркас не является стабильным между версиями AWS CLI, и нет гарантий обратной совместимости в сгенерированном JSON-каркасе.
Глобальные параметры
--debug (boolean)
Включить отладовую запись журнала.
--endpoint-url (string)
Переопределить стандартный URL команды указанным URL.
--no-verify-ssl (boolean)
По умолчанию AWS CLI использует SSL при общении с AWS-сервисами. Для каждого SSL-соединения AWS CLI проверяет SSL-сертификаты. Этот параметр переопределяет стандартное поведение проверки SSL-сертификатов.
--no-paginate (boolean)
Отключить автоматическую постраничную навигацию. Если автоматическая постраничная навигация отключена, AWS CLI выполнит только один вызов для первой страницы результатов.
--output (string)
Стиль форматирования вывода команд.
- json
- text
- table
- yaml
- yaml-stream
--query (string)
Запрос JMESPath для фильтрации данных ответа.
--profile (string)
Использовать определённый профиль из файла параметров.
--region (string)
Используемый регион. Переопределяет настройки из конфигурации/среды.
--version (string)
Отобразить версию этого инструмента.
--color (string)
Включить/отключить цветной вывод.
- on
- off
- auto
--no-sign-request (boolean)
Не подписывать запросы. Кредиты не будут загружены, если этот параметр предоставлен.
--ca-bundle (string)
Файл сертификатов CA для проверки SSL-сертификатов. Переопределяет настройки из конфигурации/среды.
--cli-read-timeout (int)
Максимальное время чтения сокета в секундах. Если значение установлено в 0, чтение сокета будет блокирующим и без таймаута. Значение по умолчанию 60 секунд.
--cli-connect-timeout (int)
Максимальное время подключения сокета в секундах. Если значение установлено в 0, подключение сокета будет блокирующим и без таймаута. Значение по умолчанию 60 секунд.
--cli-binary-format (string)
Стиль форматирования, используемый для двоичных блоков. По умолчанию используется формат base64. Формат base64 ожидает, что двоичные блоки будут предоставлены в виде строки, закодированной в base64. Формат raw-in-base64-out сохраняет совместимость с поведением AWS CLI версии 1, и двоичные значения должны передаваться буквально. При предоставлении содержимого файла, соответствующего двоичному блоку fileb:// всегда будет обрабатываться как двоичный, и будет использоваться содержимое файла напрямую, независимо от настройки cli-binary-format. При использовании file:// содержимое файла должно быть должным образом отформатировано для настроенного cli-binary-format.
- base64
- raw-in-base64-out
--no-cli-pager (boolean)
Отключить пейджер CLI для вывода.
--cli-auto-prompt (boolean)
Автоматически запрашивать параметры ввода CLI.
--no-cli-auto-prompt (boolean)
Отключить автоматическое запрошение параметров ввода CLI.
Примеры
Примечание
Для использования следующих примеров необходимо установить и настроить AWS CLI. Дополнительную информацию см. в руководстве по началу работы в руководстве пользователя AWS CLI.
Если не указано иное, все примеры используют правила цитирования, характерные для Unix-подобных систем. Эти примеры потребуется адаптировать к правилам цитирования вашей оболочки. Дополнительную информацию см. в разделе Использование кавычек со строками в руководстве пользователя AWS CLI.
Для вывода списка фрагментов в потоке данных
Следующий пример выводит список всех фрагментов в указанном потоке, начиная с фрагмента, идентификатор которого следует сразу за указанным exclusive-start-shard-id в shardId-000000000000.
aws kinesis list-shards \
--stream-name samplestream \
--exclusive-start-shard-id shardId-000000000000
Вывод:
{
"Shards": [
{
"ShardId": "shardId-000000000001",
"HashKeyRange": {
"StartingHashKey": "113427455640312821154458202477256070485",
"EndingHashKey": "226854911280625642308916404954512140969"
},
"SequenceNumberRange": {
"StartingSequenceNumber": "49600871682979337187563555549332609155523708941634633746"
}
},
{
"ShardId": "shardId-000000000002",
"HashKeyRange": {
"StartingHashKey": "226854911280625642308916404954512140970",
"EndingHashKey": "340282366920938463463374607431768211455"
},
"SequenceNumberRange": {
"StartingSequenceNumber": "49600871683001637932762086172474144873796357303140614178"
}
}
]
}
Дополнительную информацию см. в разделе Вывод списка фрагментов в руководстве разработчика Amazon Kinesis Data Streams.
Вывод
Фрагменты -> (список)
Массив JSON-объектов. Каждый объект представляет один фрагмент и определяет идентификаторы фрагмента, родительского фрагмента и фрагмента, смежного с родительским. Каждый объект также содержит начальные и конечные хэш-ключи и начальные и конечные последовательные номера для фрагмента.
(структура)
Уникально идентифицированная группа записей данных в потоке данных Kinesis.
ShardId -> (строка)
ParentShardId -> (строка)
AdjacentParentShardId -> (строка)
HashKeyRange -> (структура)
Диапазон возможных значений хэш-ключа для фрагмента, представляющий собой набор упорядоченных смежных положительных целых чисел.
StartingHashKey -> (строка)
EndingHashKey -> (строка)
SequenceNumberRange -> (структура)
Диапазон возможных последовательных номеров для фрагмента.
StartingSequenceNumber -> (строка)
EndingSequenceNumber -> (строка)
null.NextToken -> (строка)
Когда количество фрагментов в потоке данных превышает значение по умолчанию для параметра MaxResults, или если вы явно укажете значение для MaxResults, меньшее количества фрагментов в потоке данных, ответ включает маркер постраничной навигации под названием NextToken. Вы можете указать это значение NextToken в последующем вызове ListShards для получения следующего набора фрагментов. Дополнительную информацию об использовании этого маркера постраничной навигации при вызове операции ListShards см. в ListShardsInput$NextToken.
Предупреждение
Маркеры истекают через 300 секунд. Когда вы получаете значение дляNextToken в ответ на вызов ListShards, у вас есть 300 секунд для использования этого значения. Если вы укажете истекший маркер в вызове ListShards, вы получите ExpiredNextTokenException.
© Copyright 2025, Amazon Web Services. Created using Sphinx.