Yandex Cloud
Поиск
Связаться с намиПодключиться
  • Истории успеха
  • Документация
  • Блог
  • Все сервисы
  • Статус работы сервисов
    • Доступны в регионе
    • Инфраструктура и сеть
    • Платформа данных
    • Контейнеры
    • Инструменты разработчика
    • Бессерверные вычисления
    • Безопасность
    • Мониторинг и управление ресурсами
    • ИИ для бизнеса
    • Бизнес-инструменты
  • Все решения
    • По отраслям
    • По типу задач
    • Экономика платформы
    • Безопасность
    • Техническая поддержка
    • Каталог партнёров
    • Обучение и сертификация
    • Облако для стартапов
    • Облако для крупного бизнеса
    • Центр технологий для общества
    • Партнёрская программа
    • Поддержка IT-бизнеса
    • Облако для фрилансеров
    • Обучение и сертификация
    • Блог
    • Документация
    • Мероприятия и вебинары
    • Контакты, чаты и сообщества
    • Идеи
    • Тарифы Yandex Cloud
    • Промоакции и free tier
    • Правила тарификации
  • Истории успеха
  • Документация
  • Блог
Проект Яндекса
© 2025 ТОО «Облачные Сервисы Казахстан»
Yandex Data Streams
  • Управление доступом
  • Правила тарификации
    • Обзор
    • Все методы
      • CreateStream
      • DecreaseStreamRetentionPeriod
      • DeleteStream
      • DescribeStream
      • IncreaseStreamRetentionPeriod
      • GetRecords
      • GetShardIterator
      • ListStreams
      • PutRecord
      • PutRecords
      • UpdateShardCount
    • Общие ошибки
    • Примеры
  • Вопросы и ответы

В этой статье:

  • Запрос
  • Параметры запроса
  • Ответ
  • Ошибки
  1. HTTP API, совместимый с Amazon Kinesis Data Streams
  2. Методы
  3. CreateStream

CreateStream

Статья создана
Yandex Cloud
Обновлена 24 августа 2021 г.
  • Запрос
    • Параметры запроса
  • Ответ
  • Ошибки

Создает поток данных.

При успехе метод инициирует создание потока, переводит создаваемый поток в статус CREATING и возвращает HTTP-ответ с кодом 200. Операции чтения и записи возможны только для потока в статусе ACTIVE. Чтобы узнать статус потока, используйте метод DescribeStream.

При попытке создать больше потоков, чем установлено квотой для вашей учетной записи, запрос вернет ошибку LimitExceededException.

ЗапросЗапрос

Запрос содержит данные в формате JSON.

{
  "StreamName": "string",
  "ShardCount": number,
  "WriteQuotaKbPerSec": number,
  "RetentionPeriodHours": number
}

Параметры запросаПараметры запроса

Параметр Описание
StreamName Имя создаваемого потока данных.

Тип: Строка
Размер: 1-128 символов.
Возможные значения: [a-zA-Z][a-zA-Z0-9-]+*(?<!-)$
Обязательный: Да
ShardCount Количество сегментов в потоке.

Тип: Целое число
Минимальное значение: 1.
Обязательный: Да
WriteQuotaKbPerSec Ограничение на запись в поток данных, КБ/с.

Тип: Целое число
Возможные значения: 128, 512, 1024.
Обязательный: Нет
RetentionPeriodHours Время хранения сообщений, часы.

Тип: Целое число
Возможные значения 4, 12, 24.
Обязательный: Нет

ОтветОтвет

В случае успеха возвращается HTTP-ответ с кодом 200 и пустым телом.

ОшибкиОшибки

Тип ошибки Описание Код HTTP
InvalidArgumentException Недопустимый аргумент. Дополнительные сведения смотрите в сообщении об ошибке. 400
LimitExceededException Превышено максимальное число запросов. 400
ResourceInUseException Ресурс используется другой операцией. 400

Могут возникать ошибки, общие для всех методов.

Была ли статья полезна?

Предыдущая
Все методы
Следующая
DecreaseStreamRetentionPeriod
Проект Яндекса
© 2025 ТОО «Облачные Сервисы Казахстан»