Trigger for Data Streams that invokes a Cloud Functions function
Written by
Updated at October 19, 2023
Trigger for Data Streams calls a Cloud Functions function when data is sent to a stream.
A trigger for Data Streams needs service accounts to manage a stream and invoke a function. You can use the same service account for both operations.
For more information about creating a trigger for Data Streams, see Creating a trigger for Data Streams that invokes a Cloud Functions function.
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.
- For the trigger to fire, service accounts need the following roles:
functions.functionInvoker
for the function 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 function. The message format depends on the source and is an array of messages
:
{
"messages":[
{
"key1":"value1"
},
{
"key2":"value2"
}
]
}