Связаться с намиПодключиться

Начало работы с EventRouter

Статья создана
Обновлена 3 декабря 2024 г.

Примечание

EventRouter находится на стадии Preview. Чтобы получить доступ, отправьте заявку в консоли управления.

С помощью этой инструкции вы создадите очередь Message Queue и отправите в нее сообщение, которое через шину будет передано в функцию Cloud Functions.

Перед началом работы

Чтобы начать работать в Yandex Cloud:

  1. Войдите в консоль управления. Если вы еще не зарегистрированы, перейдите в консоль управления и следуйте инструкциям.
  2. На странице Биллинг убедитесь, что у вас подключен платежный аккаунт, и он находится в статусе ACTIVE или TRIAL_ACTIVE. Если платежного аккаунта нет, создайте его.
  3. Если у вас еще нет каталога, создайте его.

Создайте сервисный аккаунт

  1. В консоли управления выберите нужный каталог.
  2. В списке сервисов выберите Identity and Access Management.
  3. Нажмите кнопку Создать сервисный аккаунт.
  4. Введите имя сервисного аккаунта: sa-for-eventrouter.
  5. Нажмите кнопку Добавить роль и выберите роли functions.functionInvoker, ymq.reader и ymq.writer.
  6. Нажмите кнопку Создать.

Создайте очередь

  1. В консоли управления выберите сервис Message Queue.
  2. Нажмите кнопку Создать очередь.
  3. Укажите имя очереди: sample-queue.
  4. Выберите тип Стандартная. Не изменяйте другие настройки.
  5. Нажмите кнопку Создать.
  6. Откройте созданную очередь.
  7. На вкладке Обзор в блоке Общая информация скопируйте URL и ARN очереди, они понадобятся позднее.

Создайте функцию

  1. В консоли управления выберите сервис Cloud Functions.
  2. Создайте функцию:
    1. В правом верхнем углу нажмите кнопку Создать функцию.
    2. Введите имя функции: eventrouter-function.
    3. Нажмите кнопку Создать.
  3. Создайте версию функции:
    1. В открывшемся окне Редактор выберите Node.js 18.
    2. Отключите опцию Добавить файлы с примерами кода.
    3. Нажмите кнопку Продолжить.
    4. Создайте файл index.js и добавьте в него следующий код: 
      module.exports.handler = async function (event, context) {
    console.log(JSON.stringify(event))
    return {
        statusCode: 200,
        body: "",
    };
};
    5. В блоке Параметры укажите в поле:
      • Точка входа — index.handler;
      • Сервисный аккаунт — sa-for-eventrouter.
    6. Нажмите кнопку Сохранить изменения.

Создайте шину

  1. В консоли управления выберите сервис Serverless Integrations.
  2. Перейдите на вкладку EventRouter.
  3. В правом верхнем углу нажмите Создать шину.
  4. Введите имя шины и нажмите Создать.

Создайте коннектор

  1. Выберите шину.
  2. Перейдите на вкладку Коннекторы.
  3. В правом верхнем углу нажмите Создать коннектор.
  4. В поле Источник выберите Yandex Message Queue.
  5. В поле Очередь сообщений укажите ARN очереди.
  6. В поле Сервисный аккаунт укажите sa-for-eventrouter.
  7. Нажмите кнопку Создать.

Создайте правило

  1. Выберите шину.
  2. Перейдите на вкладку Правила.
  3. В правом верхнем углу нажмите Создать правило.
  4. В блоке Приёмники нажмите кнопку Добавить.
  5. В поле Тип выберите Yandex Cloud Functions.
  6. В поле Функция укажите eventrouter-function.
  7. В поле Сервисный аккаунт укажите sa-for-eventrouter.
  8. Нажмите кнопку Создать.

Отправьте сообщение в очередь

  1. Установите AWS CLI.

  2. Создайте статические ключи доступа для сервисного аккаунта sa-for-eventrouter. Надежно сохраните идентификатор и секретный ключ. После того, как вы закроете окно, параметры секретного ключа станут недоступны.

  3. Настройте AWS CLI:

    1. Запустите интерактивную настройку профиля:

      aws configure

    2. Укажите полученный ранее идентификатор ключа сервисного аккаунта:

      AWS Access Key ID [****************ver_]: <идентификатор_ключа_сервисного_аккаунта>

    3. Укажите полученный ранее секретный ключ сервисного аккаунта:

      AWS Secret Access Key [****************w5lb]: <секретный_ключ_сервисного_аккаунта>

    4. Укажите имя региона по умолчанию ru-central1:

      Default region name [ru-central1]: ru-central1

    5. Укажите формат выходных данных по умолчанию json:

      Default output format [None]: json

    6. Чтобы посмотреть текущие настройки профиля, выполните команду:

      aws configure list

      Результат:

            Name                    Value             Type    Location
      ----                    -----             ----    --------
   profile                <not set>             None    None
access_key     ****************aBc1 shared-credentials-file
secret_key     ****************DeF2 shared-credentials-file
    region              ru-central1      config-file    ~/.aws/config

  4. Отправьте сообщение в очередь sample-queue, используя сохраненный ранее URL очереди:

     aws sqs send-message \
   --message-body "Hello World" \
   --endpoint https://message-queue.api.cloud.yandex.net/ \
   --queue-url <URL_очереди>

    Результат:

    {
    "MD5OfMessageBody": "67e63db14341b5a696596634********",
    "MessageId": "765ff4d2-fa4bc83-6cfcc***-*****"
}

Убедитесь, что функция вызвалась

  1. В консоли управления выберите сервис Cloud Functions.
  2. Выберите функцию eventrouter-function.
  3. Перейдите на вкладку Логи. В логах должны отобразиться сообщения, которые вы отправили в очередь.

Что дальше

Предыдущая
Workflows
Следующая
Обзор