Создать триггер, который отправляет сообщения в WebSocket-соединения из топика реестра или устройства Yandex IoT Core

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

По умолчанию используется каталог, указанный при создании профиля CLI. Чтобы изменить каталог по умолчанию, используйте команду yc config set folder-id <идентификатор_каталога>. Также для любой команды вы можете указать другой каталог с помощью параметров --folder-name или --folder-id.

Чтобы создать триггер, который отправляет сообщения в WebSocket-соединения, выполните команду:

yc serverless trigger create internet-of-things \
  --name <имя_триггера> \
  --registry-id <идентификатор_реестра> \
  --device-id <идентификатор_устройства> \
  --mqtt-topic '$devices/<идентификатор_устройства>/events' \
  --batch-size <размер_группы_сообщений> \
  --batch-cutoff <максимальное_время_ожидания> \
  --gateway-id <идентификатор_API-шлюза> \
  --gateway-websocket-broadcast-path <путь> \
  --gateway-websocket-broadcast-service-account-id <идентификатор_сервисного_аккаунта>

Где:

• --name — имя триггера.
• --registry-id — идентификатор реестра.
• --device-id — идентификатор устройства. Если вы создаете триггер для топика реестра, этот параметр можно не указывать.
• --mqtt-topic — MQTT-топик, для которого вы хотите создать триггер. Необязательный параметр. Если параметр не указан, триггер срабатывает для всех топиков реестра или устройства.

• --batch-size — размер группы сообщений. Необязательный параметр. Допустимые значения от 1 до 10, значение по умолчанию — 1.
• --batch-cutoff — максимальное время ожидания. Необязательный параметр. Допустимые значения от 0 до 20 секунд, значение по умолчанию — 10 секунд. Триггер группирует сообщения не дольше batch-cutoff и отправляет их в WebSocket-соединения. Число сообщений при этом не превышает batch-size.

• --gateway-id — идентификатор API-шлюза.
• --gateway-websocket-broadcast-path — путь в OpenAPI-спецификации. Через WebSocket-соединения, которые установлены по этому пути, будут отправляться сообщения.
• --gateway-websocket-broadcast-account-id — идентификатор сервисного аккаунта с правами на отправку сообщений в WebSocket-соединения.

Результат:

id: a1s5msktijh2********
folder_id: b1gmit33hgh2********
created_at: "2022-10-24T15:19:15.353909857Z"
name: iot-trigger
rule:
  iot_message:
    registry_id: arenou2oj4h2********
    device_id: areqjd6un3h2********
    mqtt_topic: $devices/areqjd6unh2********/events
    batch_settings:
      size: "1"
      cutoff: 0s
    gateway_websocket_broadcast:
      gateway_id: d4eofc7n0mh2********
      path: /
      service_account_id: aje3932acdh2********
status: ACTIVE

Чтобы создать триггер для Yandex IoT Core, воспользуйтесь методом REST API create для ресурса Trigger или вызовом gRPC API TriggerService/Create.