создать-поток

Описание

Создаёт поток данных Kinesis. Поток собирает и переносит записи данных, непрерывно испускаемые различными источниками данных или *производителями*. Масштабирование потока явно поддерживается с помощью фрагментов, которые представляют собой уникально идентифицированные группы записей данных в потоке.

Вы можете создать поток данных, используя режим по требованию или режим выделенных ресурсов. Потоки данных в режиме по требованию не требуют планирования ресурсов и автоматически масштабируются для обработки гигабайтов пропускной способности записи и чтения в минуту. В режиме по требованию Kinesis Data Streams автоматически управляет фрагментами для обеспечения необходимой пропускной способности. Для потоков данных в режиме выделенных ресурсов необходимо указать количество фрагментов для потока данных. Каждый фрагмент может поддерживать чтение до пяти транзакций в секунду, до максимального объёма данных чтения в 2 МБ в секунду. Каждый фрагмент может поддерживать запись до 1000 записей в секунду, до максимального объёма данных записи в 1 МБ в секунду. Если объём входных данных увеличивается или уменьшается, вы можете добавлять или удалять фрагменты.

Имя потока идентифицирует поток. Имя ограничено учётной записью Amazon Web Services, используемой приложением. Оно также ограничено регионом Amazon Web Services. То есть два потока в двух разных учётных записях могут иметь одинаковое имя, и два потока в одной учётной записи, но в двух разных регионах, могут иметь одинаковое имя.

Вы получите LimitExceededException при выполнении запроса CreateStream, если вы попытаетесь сделать следующее:

• Иметь более пяти потоков в состоянии CREATING в любой момент времени.
• Создать больше фрагментов, чем разрешено для вашей учётной записи.

Дополнительные сведения о лимите фрагментов для учётной записи Amazon Web Services см. в разделе «Пределы Amazon Kinesis Data Streams» в руководстве разработчика Amazon Kinesis Data Streams. Для увеличения этого лимита обратитесь в службу поддержки Amazon Web Services.

Вы можете использовать DescribeStreamSummary для проверки статуса потока, который возвращается в StreamStatus.

Вы можете добавить метки к потоку при выполнении запроса CreateStream, установив параметр Tags. Если вы передаёте параметр Tags, помимо разрешения kinesis:CreateStream, вам также необходимо разрешение kinesis:AddTagsToStream для создаваемого потока. Разрешение kinesis:TagResource не сработает для добавления меток к потокам при создании. Метки вступят в силу со статусом CREATING потока, но вы не сможете внести изменения в метки, пока поток не будет в состоянии ACTIVE.

См. также: Документацию API AWS

Синтаксис

  create-stream
--stream-name <value>
[--shard-count <value>]
[--stream-mode-details <value>]
[--tags <value>]
[--cli-input-json | --cli-input-yaml]
[--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 (строка)

--shard-count (целое число)

--stream-mode-details (структура)

Сокращённый синтаксис:

StreamMode=string

Синтаксис JSON:

{
  "StreamMode": "PROVISIONED"|"ON_DEMAND"
}

--tags (массив)

Сокращённый синтаксис:

KeyName1=string,KeyName2=string

Синтаксис JSON:

{"string": "string"
  ...}

--cli-input-json | --cli-input-yaml (строка) Читает аргументы из предоставленной JSON-строки. JSON-строка следует формату, предоставленному --generate-cli-skeleton. Если другие аргументы предоставлены в командной строке, эти значения переопределят значения, предоставленные в JSON. Невозможно передавать произвольные двоичные значения с помощью значения, предоставленного в JSON, поскольку строка будет воспринята буквально. Это может не быть указано вместе с --cli-input-yaml.

--generate-cli-skeleton (строка) Выводит JSON-скелет в стандартный вывод без отправки запроса к API. Если предоставлено без значения или со значением input, выводит пример JSON ввода, который можно использовать как аргумент для --cli-input-json. Аналогично, если предоставлено yaml-input, оно выведет пример входного YAML, который можно использовать с --cli-input-yaml. Если предоставлено со значением output, оно валидирует входные данные команды и возвращает пример JSON вывода для этой команды. Сгенерированный JSON-скелет не стабилен между версиями AWS CLI, и нет гарантий обратной совместимости в генерируемом JSON-скелете.

Глобальные параметры

--debug (логическое значение)

Включить отладочную запись в журнал.

--endpoint-url (строка)

Переопределить URL по умолчанию команды заданным URL.

--no-verify-ssl (логическое значение)

По умолчанию AWS CLI использует SSL при общении с AWS-сервисами. Для каждого соединения SSL AWS CLI будет проверять сертификаты SSL. Этот параметр переопределяет поведение по умолчанию по проверке сертификатов SSL.

--no-paginate (логическое значение)

Отключить автоматическую постраничную навигацию. Если автоматическая постраничная навигация отключена, AWS CLI выполнит только один вызов для первой страницы результатов.

--output (строка)

Стиль форматирования для вывода команды.

• json
• text
• таблица
• yaml
• yaml-поток

--query (строка)

Запрос JMESPath для фильтрации данных ответа.

--profile (строка)

Использовать определённый профиль из файла учетных данных.

--region (строка)

Регион для использования. Переопределяет настройки конфигурации/среды.

--version (строка)

Отобразить версию этого инструмента.

--color (строка)

Включить/отключить цветной вывод.

• включено
• выключено
• автоматически

--no-sign-request (логическое значение)

Не подписывать запросы. Учетные данные не будут загружаться, если этот аргумент указан.

--ca-bundle (строка)

Файл сертификатов CA для использования при проверке сертификатов SSL. Переопределяет настройки конфигурации/среды.

--cli-read-timeout (целое число)

Максимальное время чтения сокета в секундах. Если значение установлено в 0, чтение сокета будет блокирующим и не будет иметь ограничения по времени. Значение по умолчанию составляет 60 секунд.

--cli-connect-timeout (целое число)

Максимальное время подключения сокета в секундах. Если значение установлено в 0, подключение сокета будет блокирующим и не будет иметь ограничения по времени. Значение по умолчанию составляет 60 секунд.

--cli-binary-format (строка)

Стиль форматирования, используемый для двоичных блоков. Формат по умолчанию — base64. Формат base64 ожидает, что двоичные блоки будут предоставлены как строка, закодированная в base64. Формат raw-in-base64-out сохраняет совместимость с поведением AWS CLI V1, и двоичные значения должны передаваться буквально. При предоставлении содержимого файла, отображающего двоичный блок, fileb:// всегда будет обрабатываться как двоичный и будет использовать содержимое файла непосредственно независимо от параметра cli-binary-format. При использовании file:// содержимое файла должно быть должным образом отформатировано для настроенного параметра cli-binary-format.

• base64
• raw-in-base64-out

--no-cli-pager (логическое значение)

Отключить кли-пагинатор для вывода.

--cli-auto-prompt (логическое значение)

Автоматически запрашивать параметры ввода CLI.

--no-cli-auto-prompt (логическое значение)

Отключить автоматическую запрос параметров ввода CLI.

Примеры

Для создания потока данных

Следующий пример create-stream создаёт поток данных с именем samplestream с 3 фрагментами.

aws kinesis create-stream \
    --stream-name samplestream \
    --shard-count 3

Эта команда не выводит ничего.

Дополнительные сведения см. в разделе «Создание потока» в руководстве разработчика Amazon Kinesis Data Streams.

Вывод

Нет