Trigger for Data Streams that invokes a Serverless Containers container

Trigger for Data Streams calls a Serverless Containers container when data is sent to a stream.

A trigger for Data Streams needs service accounts to manage a stream and invoke a container. You can use the same service account for both operations.

Roles required for the proper operation of a trigger for Data Streams

• To create a trigger, you need a permission for a service account that runs the trigger executing the operation. This permission is included in the iam.serviceAccounts.user and editor roles and higher.
• To run a trigger, service accounts need the following roles:
  • serverless.containers.invoker for the container that the trigger invokes.
  • yds.admin for the stream that invokes the trigger when data is sent there.

Format of the message from the trigger for Data Streams

After the trigger is activated, it sends a message to the container. The message format depends on the source and is an array of messages:

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

See also

• Trigger for Data Streams that invokes a Cloud Functions function.