MQTT Event

Событие, которое срабатывает при получении MQTT сообщения.

Имя события

mqtt

Запрос

• Подписка
• Отписка

cn.emit('add-topics', 'mqtt')

cn.emit('remove-topics', 'mqtt')

Ответ

Ответ содержит запись Журнала событий.

Поле	Тип	Описание
_id	String	ID сущности.
type	Integer	Тип сообщения. 1 – SNMP трап, 2 – MQTT сообщения.
timestamp	Integer	Время отправки MQTT сообщения.
payload	Object	MQTT сообщение.
payload.topic	String	MQTT топик.
payload.message	String	MQTT сообщение.
entity	Array<Object>	Список сущностей, которым принадлежит MQTT сообщение.
entity.entityId	String	ID сущности.
entity.entityType	Integer	Тип сущности. 1 – Объект, 2 – Связь.
entity.entityName	String	Имя сущности.

Пример

Запрос

const comet = require('socket.io-client');

// Comet settings
const COMET_CONNECT_TIMEOUT = 5000;
const sessionId = "..."
const conf = {
    cometHost: 'https://example.com',
    cometPort: '1234',
};

const url = `${conf.cometHost}` + (conf.cometPort ? `:${conf.cometPort}` : '');
const cn = comet.connect(url, {
    query: { forceNew: true, sessionId },
    timeout: COMET_CONNECT_TIMEOUT,
});

cn.emit('add-topics', 'mqtt');

cn.on('mqtt', msg => {
      console.log(msg);
});

Ответ

{
    "_id":"636cd525eb2070485dd03e6b",
    "type":2,
    "timestamp":1668076837571,
    "payload":{
        "topic":"test",
        "message":"test"
    },
    "entity":[
        {
            "entityId":"6081971e14879f73e96e494b",
            "entityType":1,
            "entityName":"qtt"
        },
        {
            "entityId":"5c5abcbfd75610326dd80248",
            "entityType":1,
            "entityName":"Host"
        }
    ]
}