Триггер для Yandex IoT Core, который передает сообщения в функцию Cloud Functions
Триггер для Yandex IoT Core предназначен для управления сообщениями, которыми обмениваются устройства, реестры и брокеры. Он создается для топиков: принимает из них копии сообщений и передает в функцию Cloud Functions для обработки.
Триггер должен находиться в одном облаке с устройством, реестром или брокером, из топика которого он читает сообщения.
Вы можете создать триггер:
- Для стандартного топика, реализованного сервисом, кроме топика
$monitoring/<идентификатор_устройства>/json. - Для топика с произвольными сабтопиками и подстановочными символами.
- Для алиаса топика.
Триггеру для Yandex IoT Core необходим сервисный аккаунт для вызова функции.
О том, как создать триггер для Yandex IoT Core, читайте в инструкциях Создать триггер, который передает сообщения в функцию Cloud Functions из топика реестра или устройства Yandex IoT Core и Создать триггер, который передает сообщения в функцию Cloud Functions из топика брокера Yandex IoT Core.
Батчинг
Настройки батчинга позволяют передавать в функцию сразу несколько сообщений. Эти настройки задают ограничение сверху по размеру группы сообщений и по времени ее накопления. Например, если размер группы сообщений равен 3, то в функцию могут поступать группы, в которых содержится от 1 до 3 сообщений.
Роли, необходимые для корректной работы триггера для Yandex IoT Core
- Для создания триггера вам необходимо разрешение на сервисный аккаунт, от имени которого триггер выполняет операцию. Это разрешение входит в роли iam.serviceAccounts.user, editor и выше.
- Для работы триггера сервисному аккаунту необходима роль
functions.functionInvokerна каталог с функцией, которую вызывает триггер.
Подробнее об управлении доступом.
Формат сообщения от триггера Yandex IoT Core
Перед тем как передать копию сообщения в функцию, триггер приводит ее к указанному ниже формату.
Устройство
{
"messages": [
{
"event_metadata": {
"event_id": "2153b5d2-c6af-4c69-a28d-74ce********",
"event_type": "yandex.cloud.events.iot.IoTMessage",
"created_at": "2019-09-25T15:51:17.872320525Z"
},
"details": {
"registry_id": "arenou2oj4ct********",
"device_id": "areqjd6un3af********",
"mqtt_topic": "$devices/areqjd6un3af********/events",
"payload": "VGVz****"
}
},
{
"event_metadata": {
"event_id": "2153b5d2-c6af-4c69-a28d-74ce********",
"event_type": "yandex.cloud.events.iot.IoTMessage",
"created_at": "2019-09-25T15:51:17.872320525Z"
},
"details": {
"registry_id": "arenou2oj4ct********",
"device_id": "areqjd6un3af********",
"mqtt_topic": "$devices/areqjd6un3af********/events",
"payload": "VGVz****"
}
}
]
}
Брокер
{
"messages":[
{
"event_metadata":{
"event_id":"2153b5d2-c6af-4c69-a28d-74ce********",
"event_type":"yandex.cloud.events.iot.IoTMessage",
"created_at":"2019-09-25T15:51:17.872320525Z"
},
"details":{
"broker_id":"arenou2oj4ct********",
"mqtt_topic":"broker/topic",
"payload":"VGVz****"
}
},
{
"event_metadata":{
"event_id":"2153b5d2-c6af-4c69-a28d-74ce********",
"event_type":"yandex.cloud.events.iot.IoTMessage",
"created_at":"2019-09-25T15:51:17.872320525Z"
},
"details":{
"broker_id":"arenou2oj4ct********",
"mqtt_topic":"broker/topic",
"payload":"VGVz****"
}
}
]
}