Yandex Cloud
Поиск
Связаться с намиПодключиться
  • Документация
  • Блог
  • Все сервисы
  • Статус работы сервисов
    • Популярные
    • Инфраструктура и сеть
    • Платформа данных
    • Контейнеры
    • Инструменты разработчика
    • Бессерверные вычисления
    • Безопасность
    • Мониторинг и управление ресурсами
    • Машинное обучение
    • Бизнес-инструменты
  • Все решения
    • По отраслям
    • По типу задач
    • Экономика платформы
    • Безопасность
    • Техническая поддержка
    • Каталог партнёров
    • Обучение и сертификация
    • Облако для стартапов
    • Облако для крупного бизнеса
    • Центр технологий для общества
    • Облако для интеграторов
    • Поддержка IT-бизнеса
    • Облако для фрилансеров
    • Обучение и сертификация
    • Блог
    • Документация
    • Контент-программа
    • Мероприятия и вебинары
    • Контакты, чаты и сообщества
    • Идеи
    • Истории успеха
    • Тарифы Yandex Cloud
    • Промоакции и free tier
    • Правила тарификации
  • Документация
  • Блог
Проект Яндекса
© 2025 ООО «Яндекс.Облако»
Yandex Data Streams
    • Подготовка окружения
    • Создание потока данных
      • Fluentd
      • Logstash
      • AWS CLI
    • Обработка потока изменений из Debezium
  • Управление доступом
  • Правила тарификации
  • Вопросы и ответы
  1. Начало работы
  2. Сбор и поставка данных
  3. AWS CLI

AWS CLI

Статья создана
Yandex Cloud
Обновлена 24 апреля 2024 г.

Примечание

Вы можете создать триггер, который будет запускать функцию Cloud Functions или контейнер Serverless Containers при отправке данных в поток. Подробнее о триггере для Data Streams.

  1. В консоли управления выберите каталог, в котором находится поток данных.

  2. Выберите сервис Data Streams.

  3. Выберите поток данных.

  4. Нажмите Подключиться и перейдите на вкладку AWS CLI.

  5. Скопируйте пример команды для отправки сообщения и выполните ее. Поставка данных будет осуществляться по протоколу AWS Kinesis Data Streams.

    Пример команды:

    aws kinesis \
      --endpoint https://yds.serverless.yandexcloud.net \
      put-record \
      --stream-name /ru-central1/aoegtvhtp8ob********/cc8004q4lbo6********/test \
      --cli-binary-format raw-in-base64-out \
      --data '{"user_id":"user1", "score": 100}' \
      --partition-key 1
    

    Результат:

    {
       "ShardId": "shard-000001",
       "SequenceNumber": "3130",
       "EncryptionType": "NONE"
    }
    

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

Предыдущая
Logstash
Следующая
Обработка потока изменений из Debezium
Проект Яндекса
© 2025 ООО «Яндекс.Облако»