Триггер для Data Streams, который вызывает контейнер Serverless Containers

Триггер для Data Streams запускает контейнер Serverless Containers при отправке данных в поток.

Триггеру для Data Streams необходимы сервисные аккаунты для управления потоком и вызова контейнера. Вы можете использовать один и тот же сервисный аккаунт для обеих операций.

О том, как создать триггер для Data Streams, читайте в инструкции Создать триггер для Data Streams, который вызывает контейнер Serverless Containers.

Группирование сообщенийГруппирование сообщений

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

Роли, необходимые для корректной работы триггера для Data StreamsРоли, необходимые для корректной работы триггера для Data Streams

• Для создания триггера вам необходимо разрешение на сервисный аккаунт, от имени которого триггер выполняет операцию. Это разрешение входит в роли iam.serviceAccounts.user, editor и выше.
• Для работы триггера сервисным аккаунтам необходимы роли:
  • serverless.containers.invoker на контейнер, который вызывает триггер.
  • yds.admin на поток, при отправке данных в который вызывается триггер.

Формат сообщения от триггера для Data StreamsФормат сообщения от триггера для Data Streams

Триггер для Data Streams принимает и отправляет сообщения только в формате JSON.

После того как триггер сработает, он отправит в контейнер сообщение с массивом messages:

{
   "messages":[
      {
         "key1":"value1"
      },
      {
         "key2":"value2"
      }
   ]
}

Полезные ссылкиПолезные ссылки

• Триггер для Data Streams, который вызывает функцию Cloud Functions
• Триггер для Data Streams, который отправляет сообщения в WebSocket-соединения