Триггер для Data Streams, который вызывает контейнер Serverless Containers
Статья создана
Обновлена 15 ноября 2024 г.
Триггер для Data Streams запускает контейнер Serverless Containers при отправке данных в поток.
Триггеру для Data Streams необходимы сервисные аккаунты для управления потоком и вызова контейнера. Вы можете использовать один и тот же сервисный аккаунт для обеих операций.
О том, как создать триггер для Data Streams, читайте в инструкции Создать триггер для Data Streams, который вызывает контейнер Serverless Containers.
Роли, необходимые для корректной работы триггера для Data Streams
- Для создания триггера вам необходимо разрешение на сервисный аккаунт, от имени которого триггер выполняет операцию. Это разрешение входит в роли iam.serviceAccounts.user, editor и выше.
- Для работы триггера сервисным аккаунтам необходимы роли:
serverless.containers.invoker
на контейнер, который вызывает триггер.yds.admin
на поток, при отправке данных в который вызывается триггер.
Формат сообщения от триггера для Data Streams
После того как триггер сработает, он отправит в контейнер сообщение. Формат сообщения зависит от источника и представляет собой массив messages
:
{
"messages":[
{
"key1":"value1"
},
{
"key2":"value2"
}
]
}