Подключиться
Yandex Cloud Functions

Создание триггера для Yandex IoT Core

Триггеры находятся на стадии Preview.

Создайте триггер для топика устройства или реестра сервиса Yandex IoT Core и обрабатывайте копии сообщений с помощью функции Cloud Functions.

Важно

Триггер должен находиться в одном облаке с реестром или устройством, из топика которого он читает сообщения.

Перед началом работы

Для создания триггера вам понадобятся:

  1. Сервисный аккаунт с правами на вызов функции. Если у вас нет сервисного аккаунта, создайте его.
  2. Реестр или устройство, из топиков которых триггер будет принимать копии сообщений. Если у вас их еще нет:
  3. Функция, которой триггер будет передавать сообщения на обработку. Если у вас еще нет функции:

Создайте триггер

Создайте триггер для топика устройства.

Примечание

Триггер начинает работать в течение 5 минут после создания.

Чтобы создать триггер:

  1. В консоли управления выберите каталог, в котором вы хотите создать триггер.
  2. Выберите сервис Cloud Functions.
  3. В левой части окна выберите раздел Триггеры.
  4. Нажмите кнопку Создать триггер.
  5. В поле Имя введите имя триггера.
  6. В выпадающем списке Тип выберите Yandex IoT Core.
  7. В блоке Настройки сообщений Yandex IoT Core введите ранее заданные параметры вашего реестра и устройства:
    • Реестр: выберите реестр с нужным устройством.
    • Устройство: выберите нужное устройство.
    • MQTT-топик введите топик, для которого вы хотите создать триггер.
  8. В блоке Настройки функции введите ранее заданные параметры вашей функции:
    • Функция: выберите нужную функцию.
    • Сервисный аккаунт: выберите сервисный аккаунт для выполнения функции.
  9. Нажмите кнопку "Создать триггер"

Триггер будет создан и отобразится в таблице в разделе Триггеры.

Если у вас еще нет интерфейса командной строки Yandex.Cloud, установите и инициализируйте его.

По умолчанию используется каталог, указанный в профиле CLI. Вы можете указать другой каталог с помощью параметра --folder-name или --folder-id.

Создайте триггер:

  • --name — имя триггера.
  • --registry-id — уникальный идентификатор реестра.
  • --device-id — уникальный идентификатор устройства. Если вы создаете триггер для топика реестра, этот параметр можно пропустить.
  • --mqtt-topic — топик, для которого вы хотите создать триггер.
  • --invoke-function-id — уникальный идентификатор функции.
  • --invoke-function-service-account-id — сервисный аккаунт с правами на вызов функции.
$ yc serverless trigger create internet-of-things \
    --name <имя триггера> \
    --registry-id <идентификатор реестра> \
    --device-id <идентификатор устройства> \
    --mqtt-topic '$devices/<идентификатор устройства>/events' \
    --invoke-function-id <идентификатор функции> \
    --invoke-function-service-account-id <идентификатор сервисного аккаунта>

Результат:

id: a1sl0mkmimfj3uv52fr8
folder_id: b1g88tflru0ek1omtsu0
created_at: "2019-09-25T13:54:35.654935Z"
name: iot-trigger
rule:
  iot_message:
    registry_id: arenou2oj4ct42eq8g3n
    device_id: areqjd6un3afc3cefcvm
    mqtt_topic: $devices/areqjd6un3afc3cefcvm/events
    invoke_function:
      function_id: d4eofc7n0m03lmudse8l
      function_tag: $latest
      service_account_id: aje3932acd0c5ur7dagp
      retry_settings:
        retry_attempts: "1"
        interval: 10s
status: ACTIVE

Проверьте результат

Проверьте, что функция была запущена, посмотрев логи функции:

  1. Посмотрите логи функции, в них должна отображаться информация о вызове функции. В данном примере функция выводит информацию об обработанных сообщениях.

    $ yc serverless function logs <идентификатор функции>

    Результат:

    2019-09-25 14:00:00     MESSAGE_BATCH
2019-09-25 14:00:00     {
2019-09-25 14:00:00       "event_metadata": {
2019-09-25 14:00:00         "event_id": "9e016299-866f-4900-8830-d674cbff3577",
2019-09-25 14:00:00         "event_type": "yandex.cloud.events.iot.IoTMessage",
2019-09-25 14:00:00         "created_at": "2019-09-25T13:59:59.208724628Z"
2019-09-25 14:00:00       },
2019-09-25 14:00:00       "details": {
2019-09-25 14:00:00         "registry_id": "arenou2oj4ct42eq8g3n",
2019-09-25 14:00:00         "device_id": "areqjd6un3afc3cefcvm",
2019-09-25 14:00:00         "mqtt_topic": "$devices/areqjd6un3afc3cefcvm/events",
2019-09-25 14:00:00         "payload": "VGVzdCA0"
2019-09-25 14:00:00       }
2019-09-25 14:00:00     }
2019-09-25 14:00:00     END RequestID: 1ba57cbe-c2ce-4d1a-91a3-9592e945b45a
2019-09-25 14:00:00     REPORT RequestID: 1ba57cbe-c2ce-4d1a-91a3-9592e945b45a Duration: 368.362 ms Billed Duration: 400 ms Memory Size: 128 MB Max Memory Used: 13 MB
В этой статье: