Отправить события в шину напрямую

Если у вас еще нет интерфейса командной строки Yandex Cloud (CLI), установите и инициализируйте его.

По умолчанию используется каталог, указанный при создании профиля CLI. Чтобы изменить каталог по умолчанию, используйте команду yc config set folder-id <идентификатор_каталога>. Также для любой команды вы можете указать другой каталог с помощью параметров --folder-name или --folder-id.

1. Посмотрите описание команды CLI для непосредственной отправки событий в шину:

   yc serverless eventrouter put-event --help
   

2. Получите список шин:

   yc serverless eventrouter bus list
   

   Результат:

   +----------------------+------------------+----------------------+--------+---------------------+
   |          ID          |       NAME       |      FOLDER ID       | STATUS | DELETION PROTECTION |
   +----------------------+------------------+----------------------+--------+---------------------+
   | f6676a9ti657******** | my-new-bus-17    | b1g681qpemb4******** | ACTIVE | false               |
   | f66aevm4ithv******** | my-favourite-bus | b1g681qpemb4******** | ACTIVE | true                |
   | f66m2q222n92******** | my-bus-42        | b1g681qpemb4******** | ACTIVE | false               |
   +----------------------+------------------+----------------------+--------+---------------------+
   

3. Отправьте событие в выбранную шину:

   yc serverless eventrouter put-event \
     --name <имя_шины> \
     --event '<событие>' \
     --file <путь_к_файлу>
   

   Где:

   • --name — имя шины, в которую вы передаете событие.

     Вместо имени шины вы можете передать в команде ее идентификатор в параметре --id.

   • --event — отправляемое событие в формате JSON. Например: {"name": "value"}.

   • --file — путь к файлу, в котором содержится отправляемое в шину событие в формате JSON.

   Параметры --event и --file — взаимоисключающие, можно использовать только один из них.

Чтобы отправить событие в шину напрямую, воспользуйтесь вызовом gRPC API EventService/Put:

1. Если у вас не установлена утилита gRPCurl, установите ее.

2. Если у вас еще нет интерфейса командной строки Yandex Cloud (CLI), установите и инициализируйте его.

3. Получите IAM-токен для аутентификации в API.

   IAM_TOKEN=$(yc iam create-token)
   

   Команда сохранит полученный IAM-токен в переменную IAM_TOKEN.

4. Получите список шин:

   yc serverless eventrouter bus list
   

   Результат:

   +----------------------+------------------+----------------------+--------+---------------------+
   |          ID          |       NAME       |      FOLDER ID       | STATUS | DELETION PROTECTION |
   +----------------------+------------------+----------------------+--------+---------------------+
   | f6676a9ti657******** | my-new-bus-17    | b1g681qpemb4******** | ACTIVE | false               |
   | f66aevm4ithv******** | my-favourite-bus | b1g681qpemb4******** | ACTIVE | true                |
   | f66m2q222n92******** | my-bus-42        | b1g681qpemb4******** | ACTIVE | false               |
   +----------------------+------------------+----------------------+--------+---------------------+
   

5. Создайте файл с телом запроса (например, body.json):

   {
     "bus_id": "<идентификатор_шины>",
     "body": "<событие>"
   }
   

   Где:

   • bus_id — идентификатор шины, в которую вы отправляете событие.
   • body — отправляемое событие в формате JSON. Например: {'name': 'value'}.

6. Выполните gRPC-вызов, указав путь к созданному ранее файлу body.json:

   grpcurl \
     -rpc-header "Authorization: Bearer $IAM_TOKEN" \
     -d @ < body.json \
     events.eventrouter.serverless.yandexcloud.net:443 yandex.cloud.serverless.eventrouter.v1.EventService/Put