MQTT Event
Событие, которое срабатывает при получении MQTT сообщения.
Ответ
Ответ содержит запись Журнала событий.
Поле | Тип | Описание |
---|---|---|
_id |
String |
ID сущности. |
type |
Integer |
Тип сообщения. |
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 |
|
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);
});