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. PutRecord

PutRecord

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

Отправляет одно сообщение в поток данных.

В запросе указывается имя потока, ключ сегмента и объект, содержащий данные пользователя в кодировке Base64.

Возвращает идентификатор сегмента, в который было помещено сообщение, и порядковый номер сообщения.

Сообщения записываются в сегмент потока строго в том порядке, в каком отправляются.

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

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

{
  "Data": blob,
  "ExplicitHashKey": "string",
  "PartitionKey": "string",
  "SequenceNumberForOrdering": "string",
  "StreamName": "string"
}

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

Параметр Описание
Data Данные пользователя.

Тип: Бинарный, кодировка Base64
Размер: 0-1048576 байт данных в кодировке Base64
Обязательный: Да
ExplicitHashKey Хеш ключа сегмента.
При определении сегмента для записи сообщения с помощью хеша PartitionKey возможно неоптимальное распределение сообщений по сегментам. Используйте этот параметр для явного определения сегмента, в который будет записано сообщение.

Тип: Строка
Возможные значения: 0|([1-9]\d{0,38})
Обязательный: Нет
PartitionKey Ключ сегмента.
Определяет, в какой сегмент потока будет записано сообщение.

Тип: Строка
Размер: 1-256 символов.
Обязательный: Да
StreamName Имя потока данных.

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

ОтветОтвет

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

{
  "EncryptionType": "string",
  "SequenceNumber": "string",
  "ShardId": "string"
}

Параметры ответаПараметры ответа

Параметр Описание
EncryptionType Тип шифрования.

Тип: Строка
Возможные значения: NONE
Обязательный: Да
SequenceNumber Порядковый номер сообщения.

Тип: Строка
Возможные значения: 0|([1-9]\d{0,128})
Обязательный: Да
ShardId Идентификатор сегмента, в который было записано сообщение.

Тип: Строка
Размер: 1-128 символов.
Возможные значения: [a-zA-Z0-9_.-]+
Обязательный: Да

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

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

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

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

Предыдущая
ListStreams
Следующая
PutRecords
Проект Яндекса
© 2025 ООО «Яндекс.Облако»