MQTT: различия между версиями
Brainroot (обсуждение | вклад) |
Admin (обсуждение | вклад) |
||
(не показано 128 промежуточных версий 11 участников) | |||
Строка 1: | Строка 1: | ||
<languages/> | |||
<translate> | |||
'''MQTT''' | <!--T:1--> | ||
'''MQTT''' - очередь сообщений, использующаяся в [[Программное обеспечение Wiren Board|программном обеспечении Wiren Board]]. [http://en.wikipedia.org/wiki/MQTT Базовая информация по MQTT на Википедии]. | |||
Драйверы, | Драйверы, отвечающие за аппаратные возможности контроллера (цифровые входы, АЦП, транзисторный выходы, ...) и функции внешних подключённых устройств (например, подключённых по RS-485 модулей реле) записывают их состояние в очередь MQTT в виде специальных сообщений. Веб-интерфейс читает эти сообщения и на их основе отображает состояние устройств. | ||
Если же происходит нажатие кнопки в веб-интерфейсе, уже веб-интерфейс отправляет сообщение в очередь MQTT, драйвер устройства его получает и отдаёт команду устройству. | |||
== Примеры работы через очередь MQTT == <!--T:3--> | |||
===Получение значения от датчика температуры и вывод его в веб-интерфейс=== | ===Получение значения от датчика температуры и вывод его в веб-интерфейс=== | ||
[[File:Web-devices-1-wire.png|400px|thumb|Показания датчика и его уникальный идентификатор на странице ''Devices'' веб-интерфейса]] | [[File:Web-devices-1-wire.png|400px|thumb|Показания датчика и его уникальный идентификатор на странице ''Devices'' веб-интерфейса]] | ||
Предположим, что к [[Wiren Board]] подключён датчик температуры по шине [[1-Wire]]. Проследим, как данные с него через очередь сообщений попадают в веб-интерфейс: | |||
#Драйвер, отвечающий за данную аппаратную функцию (например, [https://github.com/contactless/wb-homa-drivers/tree/master/wb-homa-w1 wb-homa-w1]) опрашивает подключённые к контролеру датчики 1-Wire. | |||
#Драйвер [https://github.com/ | #При получении значения драйвер размещает в очереди сообщение следующего вида: <pre>/devices/wb-w1/controls/28-0115a48fcfff 23.25</pre>Оно значит, что на устройстве 1-Wire с идентификатором ''28-0115a48fcfff'' получено значение 23.25°C. | ||
#При получении значения драйвер | #Веб-интерфейс, который получает все сообщения из очереди (он ''подписан'' на все сообщения), получает это сообщение и выводит значение датчика на страницу. | ||
#Веб-интерфейс, который подписан на все сообщения | |||
===Нажатие кнопки в веб-интерфейсе и переключение реле на внешнем модуле=== | ===Нажатие кнопки в веб-интерфейсе и переключение реле на внешнем модуле=== | ||
[[File:Web-devices-serial.png|400px|thumb|Веб-интерфейс после нажатия кнопки включения Реле 1 на подключённом по RS-485 релейном модуле [[WB-MRM2]]]] | [[File:Web-devices-serial.png|400px|thumb|Веб-интерфейс после нажатия кнопки включения Реле 1 на подключённом по RS-485 релейном модуле [[WB-MRM2]]]] | ||
Предположим, что к контроллеру по шине [[RS-485]] подключён релейный модуль [[WB-MRM2]]. Пользователь в веб-интерфейсе нажимает кнопку включения реле. Проследим, как команда из веб-интерфейса попадает на внешний модуль: | |||
#После нажатия кнопки веб-интерфейс | #После нажатия кнопки веб-интерфейс размещает в очереди сообщение следующего вида: <pre>/devices/wb-mrm2_130/controls/Relay 1/on 1</pre>Оно значит, что устройство WB-MRM2 с адресом ''130'' должно перевести Реле 1 в состояние логической единицы - "включено". | ||
#[[Драйвер wb-mqtt-serial]], отвечающий за данную аппаратную функцию, получает это сообщение (он ''подписан'' на все сообщения, относящиеся к подключённым по RS-485 устройствам) и посылает по шине RS-485 релейному модулю команду на включение первого реле. | #[[Драйвер wb-mqtt-serial]], отвечающий за данную аппаратную функцию, получает это сообщение (он ''подписан'' на все сообщения, относящиеся к подключённым по RS-485 устройствам) и посылает по шине RS-485 релейному модулю команду на включение первого реле. | ||
#Релейный модуль WB-MRM2 получает команду от контроллера, переключает реле и посылает обратно уведомление | #Релейный модуль WB-MRM2 получает команду от контроллера, переключает реле и посылает обратно уведомление ("Реле 1 включено"). | ||
#Драйвер wb-mqtt-serial получает это уведомление по RS-485 и публикует | #Драйвер wb-mqtt-serial получает это уведомление по RS-485 и публикует в очереди сообщение:<pre>/devices/wb-mrm2_130/controls/Relay 1 1</pre>Оно значит, что первое реле на устройстве WB-MRM2 с адресом ''130'' находится (уже переведено) в состоянии логической единицы ("включено"). | ||
== Принцип работы | == Принцип работы очереди сообщений == | ||
Система сообщений MQTT построена по следующему принципу: | Система сообщений MQTT построена по следующему принципу: | ||
*есть иерархическая система | *есть иерархическая система "топиков" (как на обычных форумах в интернете) | ||
*в эти топики клиенты (в случае Wiren Board это драйверы устройств и веб-интерфейс) могут писать сообщения и читать оттуда | *в эти топики клиенты (в случае Wiren Board это драйверы устройств и веб-интерфейс) могут писать сообщения и читать оттуда | ||
*чтобы следить за изменениями нужного топика (например, температуры на датчике), клиент может на него | *чтобы следить за изменениями нужного топика (например, температуры на датчике), клиент может на него "подписаться" - тогда он получит все сообщения в данном топике. | ||
=== Пример сообщения === | |||
=== | |||
=== | |||
Вот пример сообщения от драйвера температурного датчика 1-Wire из примера выше: | |||
<pre> | <pre> | ||
/devices/wb-w1/controls/28-0115a48fcfff 23.25 | /devices/wb-w1/controls/28-0115a48fcfff 23.25 | ||
</pre> | </pre> | ||
Часть до пробела | Часть до пробела - название топика, после - само сообщение. | ||
Название топика состоит из вложенных друг в друга | Название топика состоит из вложенных друг в друга "подтопиков": | ||
* | * ''/devices'' - коренной топик для всех "устройств" - как встроенных функций Wiren Board (цифровые, АЦП, ...), так и подключённых внешних (например, модулей реле) | ||
* | * ''/wb-w1'' - подтопик, который наполняется драйвером 1-Wire | ||
* | * ''/controls'' - подтопик, который есть у всех устройств - именно в него записываются все их параметры, которые меняются ("включено-выключено", значение датчика, ...) | ||
* | * ''/28-0115a48fcfff'' - непосредственно сам "канал" ("контрол)" - топик, куда записывается значение с датчика. Его название совпадает с адресом 1-Wire датчика на шине. | ||
Содержание сообщения: | Содержание сообщения: | ||
* | * ''23.25'' - значение температуры | ||
=== Пример подписки === <!--T:11--> | |||
<!--T:12--> | |||
Клиенты, которые хотят следить за значением температуры, "подписываются" на этот топик, и им приходят все новые сообщения - меняющиеся значения температуры. Один из таких клиентов - веб-интерфейс. | |||
<!--T:13--> | |||
Подписаться на сообщения можно и из консоли Linux при помощи утилиты '''mosquitto_sub''': | |||
<pre> | <pre> | ||
/devices/wb-w1/controls/28- | root@wirenboard:~# mosquitto_sub -t '/devices/wb-w1/controls/28-000004a7d3f9' -v | ||
/devices/wb-w1/controls/28-000004a7d3f9 20.312000 | |||
/devices/wb-w1/controls/28-000004a7d3f9 20.312000 | |||
/devices/wb-w1/controls/28-000004a7d3f9 20.375000 | |||
</pre> | </pre> | ||
(описание утилиты смотрите [http://mosquitto.org/man/mosquitto_sub-1.html]). | |||
<!--T:14--> | |||
Подписаться можно не только на один топик, но и на группу по wildcard: | |||
<pre> | |||
root@wirenboard:~# mosquitto_sub -t '/devices/wb-w1/#' -v | |||
/devices/wb-w1/meta/name 1-wire Thermometers | |||
/devices/wb-w1/controls/28-000004a7d3f9 23.312000 | |||
/devices/wb-w1/controls/28-000004a7d3f9/meta/type temperature | |||
/devices/wb-w1/controls/28-000004a7d3f9 23.312000 | |||
/devices/wb-w1/controls/28-000004a7d3f9 23.312000 | |||
</pre> | |||
, где ''#'' - означает любое количество топиков. Соответственно, вывелись не только значения с "контрола" устройства, но и топики с метаданными - название драйвера устройства и тип "контрола" - ''temperature''. | |||
[ | <!--T:15--> | ||
Полное описание системы топиков и подписок: [http://mosquitto.org/man/mqtt-7.html]. | |||
=== Пример | === Пример сообщения от веб-интерфейса === <!--T:16--> | ||
<!--T:17--> | |||
Подпишемся на сообщения о состоянии встроенного реле Wiren Board: | |||
<pre> | |||
< | root@wirenboard:~# mosquitto_sub -t '/devices/wb-gpio/controls/Relay_1/#' -v | ||
~# mosquitto_sub -t '/devices/wb- | /devices/wb-gpio/controls/Relay_1/meta/type switch | ||
/devices/wb- | /devices/wb-gpio/controls/Relay_1/on 0 | ||
/devices/wb- | /devices/wb-gpio/controls/Relay_1 0 | ||
/devices/wb- | </pre> | ||
</ | Тут стоит отметить, что MQTT сохраняет часть сообщений (а именно с флагом retained) вечно, поэтому после подписки вы получите даже те сообщения, которые были отправлен раньше, чем вы подписались. | ||
<!--T:18--> | |||
Реле управляется драйвером ''wb-gpio'' (этот драйвер также управляет транзисторными выходами и всем, что в электрическом смысле управляется GPIO). У него есть соответствующий топик-"контрол" ''Relay_1''. У него самого есть значение - ''0'' (реле выключено), и есть два подтопика. Один из них - служебный: в ''/meta/type'' записан тип "контрола". Здесь он ''switch'' - выключатель. Второй подтопик ''/on'' - интереснее: в него клиенты пишут то состояние, в которое они хотят установить реле. Заметим, что оно может не совпадать с тем состоянием, в котором реле находится, так как драйвер реле ведёт себя следующим образом: при получении сообщения в топик ''/devices/wb-gpio/controls/Relay_1/on'' он физически устанавливает его на реле, а лишь затем записывает новое значение реле в топик ''/devices/wb-gpio/controls/Relay_1''. | |||
<!--T:19--> | |||
< | Например, если мы сейчас нажмем на реле в веб-интерфейсе (переключим его состояние), то получим новые сообщения: | ||
Например, если мы сейчас | |||
<pre> | <pre> | ||
/devices/wb- | /devices/wb-gpio/controls/Relay_1/on 1 | ||
/devices/wb- | /devices/wb-gpio/controls/Relay_1 1 | ||
</pre> | </pre> | ||
- веб-интерфейс сначала | - веб-интерфейс сначала "даёт указание" включить реле, потом драйвер его включает и ставит актуальное состояние в "контрол". | ||
== | ==Работа с очередью сообщений== | ||
Программа (демон), отвечающая за рассылку сообщений от одних клиентов другим, называется брокером сообщений. В Wiren Board используется брокер сообщений [http://mosquitto.org/ Mosquitto]. Фактически, все драйверы и веб-интерфейс передают свои сообщения именно демону-брокеру Mosquitto. | Программа (демон), отвечающая за рассылку сообщений от одних клиентов другим, называется брокером сообщений. В Wiren Board используется брокер сообщений [http://mosquitto.org/ Mosquitto]. Фактически, все драйверы и веб-интерфейс передают свои сообщения именно демону-брокеру Mosquitto. | ||
=== | === Управление устройствами из командной строки === <!--T:20--> | ||
<!--T:21--> | |||
Как следует из написанного выше, для управления устройством (изменения значения канала), необходимо отправить сообщение в топик "/devices/<device-id>/controls/<control-id>/on" (обратите внимание на /on в конце). | |||
Это легко сделать с помощью консольной команды mosquitto_pub . Пример: | |||
<!--T:22--> | |||
<pre> | |||
< | mosquitto_pub -t "/devices/wb-gpio/controls/Relay_1/on" -m "1" | ||
</pre> | |||
</ | |||
<!--T:23--> | |||
команда включает реле 1 (канал "Relay_1" устройства "wb-gpio"). | |||
==== Очистка очереди сообщений ==== <!--T:26--> | |||
=== | |||
< | |||
<!--T:27--> | |||
Ненужные retained-сообщения могут остаться в системе MQTT после удаления неиспользуемых драйверов или отключения каких-либо устройств. | Ненужные retained-сообщения могут остаться в системе MQTT после удаления неиспользуемых драйверов или отключения каких-либо устройств. | ||
Это приводит к тому, что несуществующие больше устройства могут отображаться в разделе | Это приводит к тому, что несуществующие больше устройства могут отображаться в разделе Devices веб-интерфейса. | ||
Для удаления топиков можно воспользоваться командой | <!--T:28--> | ||
Для удаления топиков можно воспользоваться командой ''mqtt-delete-retained''. | |||
<!--T:29--> | |||
Использование: | |||
<!--T:30--> | |||
< | <pre> | ||
mqtt-delete-retained <маска mqtt> | |||
</pre> | |||
<!--T:31--> | |||
например: | |||
<!--T:32--> | |||
<pre> | |||
mqtt-delete-retained '/devices/noolite_tx_1234/#' | |||
</pre> | |||
< | |||
</ | |||
<!--T:33--> | |||
- удалит все топики, начинающиеся на '/devices/noolite_tx_1234/' | |||
=== | === Работа с очередью из внешних программ === <!--T:34--> | ||
<!--T:35--> | |||
Если вы разрабатываете собственное ПО для Wiren Board, взаимодействовать с его аппаратными ресурсами лучше всего через очередь сообщений - ваша программа передаёт сообщение в очередь, драйвер управляет устройством, и вашей программе не нужно напрямую взаимодействовать с устройством на низком уровне. | |||
Для того, чтобы отправлять сообщения MQTT, для многих языков программирования есть библиотеки. Примеры: | |||
* Python - [https://github.com/contactless/mqtt-tools] | |||
* C - [http://mosquitto.org/man/libmosquitto-3.html] | |||
=== Отображение устройств в системе сообщений === <!--T:24--> | |||
<!--T:25--> | |||
Логика топиков, соответствующих разным устройствам и их параметрам, основывается на так называемых Conventions. Список актуальных типов здесь: [https://github.com/contactless/homeui/blob/contactless/conventions.md] | |||
Wiren Board использует набор соглашений по работе с MQTT. Эти соглашения описаны ниже. Полное каноническое описание соглашений Wiren Board смотрите в документе [https://github.com/contactless/homeui/blob/contactless/conventions.md Wiren Board MQTT Conventions]. | |||
<!--T:4--> | |||
Архитектура ПО Wiren Board: | |||
<!--T:5--> | |||
< | [[File:MQTT.png | thumb | 600px]] | ||
<!--T:6--> | |||
Специальные "драйверы" (отдельный для каждой функции контроллера и внешнего устройства) транслируют данные с устройства в очередь в виде сообщений специального формата. Сообщения из этой очереди получает веб-интерфейс и движок правил. Они же могут добавлять туда новые сообщения - например, "включить реле" после получения нажатия в интерфейсе или выполнения нужных условий в каком-нибудь правиле. | |||
[[Веб-интерфейс Wiren Board| Веб-интерфейс]] работает также через систему сообщений MQTT - нажатие кнопки в интерфейсе вызывает отправку сообщения в очередь (а именно брокеру сообщений); изменение показания датчика, поступившее в систему сообщений, тут же вызывает изменения транслируется в веб-интерфейс. | |||
'''Пример:''' если на цифровой вход Wiren Board подан сигнал, драйвер ''wb-homa-gpio'' создаёт сообщение вида .......... - "на входе ... появился сигнал". Веб-интерфейс, который тоже подключён к системе сообщений, получает это сообщение и "зажигает" индикатор в веб-интерфейсе. | |||
== Система правил == <!--T:36--> | |||
< | |||
<!--T:37--> | |||
Вы можете написать свои правила на языке Javascript. Подробнее смотрите [https://github.com/contactless/wb-rules] | |||
</translate> |
Версия 20:26, 18 февраля 2016
MQTT - очередь сообщений, использующаяся в программном обеспечении Wiren Board. Базовая информация по MQTT на Википедии.
Драйверы, отвечающие за аппаратные возможности контроллера (цифровые входы, АЦП, транзисторный выходы, ...) и функции внешних подключённых устройств (например, подключённых по RS-485 модулей реле) записывают их состояние в очередь MQTT в виде специальных сообщений. Веб-интерфейс читает эти сообщения и на их основе отображает состояние устройств.
Если же происходит нажатие кнопки в веб-интерфейсе, уже веб-интерфейс отправляет сообщение в очередь MQTT, драйвер устройства его получает и отдаёт команду устройству.
Примеры работы через очередь MQTT
Получение значения от датчика температуры и вывод его в веб-интерфейс
Предположим, что к Wiren Board подключён датчик температуры по шине 1-Wire. Проследим, как данные с него через очередь сообщений попадают в веб-интерфейс:
- Драйвер, отвечающий за данную аппаратную функцию (например, wb-homa-w1) опрашивает подключённые к контролеру датчики 1-Wire.
- При получении значения драйвер размещает в очереди сообщение следующего вида:
/devices/wb-w1/controls/28-0115a48fcfff 23.25
Оно значит, что на устройстве 1-Wire с идентификатором 28-0115a48fcfff получено значение 23.25°C. - Веб-интерфейс, который получает все сообщения из очереди (он подписан на все сообщения), получает это сообщение и выводит значение датчика на страницу.
Нажатие кнопки в веб-интерфейсе и переключение реле на внешнем модуле
![](/wiki/images/thumb/d/d2/Web-devices-serial.png/400px-Web-devices-serial.png)
Предположим, что к контроллеру по шине RS-485 подключён релейный модуль WB-MRM2. Пользователь в веб-интерфейсе нажимает кнопку включения реле. Проследим, как команда из веб-интерфейса попадает на внешний модуль:
- После нажатия кнопки веб-интерфейс размещает в очереди сообщение следующего вида:
/devices/wb-mrm2_130/controls/Relay 1/on 1
Оно значит, что устройство WB-MRM2 с адресом 130 должно перевести Реле 1 в состояние логической единицы - "включено". - Драйвер wb-mqtt-serial, отвечающий за данную аппаратную функцию, получает это сообщение (он подписан на все сообщения, относящиеся к подключённым по RS-485 устройствам) и посылает по шине RS-485 релейному модулю команду на включение первого реле.
- Релейный модуль WB-MRM2 получает команду от контроллера, переключает реле и посылает обратно уведомление ("Реле 1 включено").
- Драйвер wb-mqtt-serial получает это уведомление по RS-485 и публикует в очереди сообщение:
/devices/wb-mrm2_130/controls/Relay 1 1
Оно значит, что первое реле на устройстве WB-MRM2 с адресом 130 находится (уже переведено) в состоянии логической единицы ("включено").
Принцип работы очереди сообщений
Система сообщений MQTT построена по следующему принципу:
- есть иерархическая система "топиков" (как на обычных форумах в интернете)
- в эти топики клиенты (в случае Wiren Board это драйверы устройств и веб-интерфейс) могут писать сообщения и читать оттуда
- чтобы следить за изменениями нужного топика (например, температуры на датчике), клиент может на него "подписаться" - тогда он получит все сообщения в данном топике.
Пример сообщения
Вот пример сообщения от драйвера температурного датчика 1-Wire из примера выше:
/devices/wb-w1/controls/28-0115a48fcfff 23.25
Часть до пробела - название топика, после - само сообщение.
Название топика состоит из вложенных друг в друга "подтопиков":
- /devices - коренной топик для всех "устройств" - как встроенных функций Wiren Board (цифровые, АЦП, ...), так и подключённых внешних (например, модулей реле)
- /wb-w1 - подтопик, который наполняется драйвером 1-Wire
- /controls - подтопик, который есть у всех устройств - именно в него записываются все их параметры, которые меняются ("включено-выключено", значение датчика, ...)
- /28-0115a48fcfff - непосредственно сам "канал" ("контрол)" - топик, куда записывается значение с датчика. Его название совпадает с адресом 1-Wire датчика на шине.
Содержание сообщения:
- 23.25 - значение температуры
Пример подписки
Клиенты, которые хотят следить за значением температуры, "подписываются" на этот топик, и им приходят все новые сообщения - меняющиеся значения температуры. Один из таких клиентов - веб-интерфейс.
Подписаться на сообщения можно и из консоли Linux при помощи утилиты mosquitto_sub:
root@wirenboard:~# mosquitto_sub -t '/devices/wb-w1/controls/28-000004a7d3f9' -v /devices/wb-w1/controls/28-000004a7d3f9 20.312000 /devices/wb-w1/controls/28-000004a7d3f9 20.312000 /devices/wb-w1/controls/28-000004a7d3f9 20.375000
(описание утилиты смотрите [1]).
Подписаться можно не только на один топик, но и на группу по wildcard:
root@wirenboard:~# mosquitto_sub -t '/devices/wb-w1/#' -v /devices/wb-w1/meta/name 1-wire Thermometers /devices/wb-w1/controls/28-000004a7d3f9 23.312000 /devices/wb-w1/controls/28-000004a7d3f9/meta/type temperature /devices/wb-w1/controls/28-000004a7d3f9 23.312000 /devices/wb-w1/controls/28-000004a7d3f9 23.312000
, где # - означает любое количество топиков. Соответственно, вывелись не только значения с "контрола" устройства, но и топики с метаданными - название драйвера устройства и тип "контрола" - temperature.
Полное описание системы топиков и подписок: [2].
Пример сообщения от веб-интерфейса
Подпишемся на сообщения о состоянии встроенного реле Wiren Board:
root@wirenboard:~# mosquitto_sub -t '/devices/wb-gpio/controls/Relay_1/#' -v /devices/wb-gpio/controls/Relay_1/meta/type switch /devices/wb-gpio/controls/Relay_1/on 0 /devices/wb-gpio/controls/Relay_1 0
Тут стоит отметить, что MQTT сохраняет часть сообщений (а именно с флагом retained) вечно, поэтому после подписки вы получите даже те сообщения, которые были отправлен раньше, чем вы подписались.
Реле управляется драйвером wb-gpio (этот драйвер также управляет транзисторными выходами и всем, что в электрическом смысле управляется GPIO). У него есть соответствующий топик-"контрол" Relay_1. У него самого есть значение - 0 (реле выключено), и есть два подтопика. Один из них - служебный: в /meta/type записан тип "контрола". Здесь он switch - выключатель. Второй подтопик /on - интереснее: в него клиенты пишут то состояние, в которое они хотят установить реле. Заметим, что оно может не совпадать с тем состоянием, в котором реле находится, так как драйвер реле ведёт себя следующим образом: при получении сообщения в топик /devices/wb-gpio/controls/Relay_1/on он физически устанавливает его на реле, а лишь затем записывает новое значение реле в топик /devices/wb-gpio/controls/Relay_1.
Например, если мы сейчас нажмем на реле в веб-интерфейсе (переключим его состояние), то получим новые сообщения:
/devices/wb-gpio/controls/Relay_1/on 1 /devices/wb-gpio/controls/Relay_1 1
- веб-интерфейс сначала "даёт указание" включить реле, потом драйвер его включает и ставит актуальное состояние в "контрол".
Работа с очередью сообщений
Программа (демон), отвечающая за рассылку сообщений от одних клиентов другим, называется брокером сообщений. В Wiren Board используется брокер сообщений Mosquitto. Фактически, все драйверы и веб-интерфейс передают свои сообщения именно демону-брокеру Mosquitto.
Управление устройствами из командной строки
Как следует из написанного выше, для управления устройством (изменения значения канала), необходимо отправить сообщение в топик "/devices/<device-id>/controls/<control-id>/on" (обратите внимание на /on в конце). Это легко сделать с помощью консольной команды mosquitto_pub . Пример:
mosquitto_pub -t "/devices/wb-gpio/controls/Relay_1/on" -m "1"
команда включает реле 1 (канал "Relay_1" устройства "wb-gpio").
Очистка очереди сообщений
Ненужные retained-сообщения могут остаться в системе MQTT после удаления неиспользуемых драйверов или отключения каких-либо устройств. Это приводит к тому, что несуществующие больше устройства могут отображаться в разделе Devices веб-интерфейса.
Для удаления топиков можно воспользоваться командой mqtt-delete-retained.
Использование:
mqtt-delete-retained <маска mqtt>
например:
mqtt-delete-retained '/devices/noolite_tx_1234/#'
- удалит все топики, начинающиеся на '/devices/noolite_tx_1234/'
Работа с очередью из внешних программ
Если вы разрабатываете собственное ПО для Wiren Board, взаимодействовать с его аппаратными ресурсами лучше всего через очередь сообщений - ваша программа передаёт сообщение в очередь, драйвер управляет устройством, и вашей программе не нужно напрямую взаимодействовать с устройством на низком уровне.
Для того, чтобы отправлять сообщения MQTT, для многих языков программирования есть библиотеки. Примеры:
Отображение устройств в системе сообщений
Логика топиков, соответствующих разным устройствам и их параметрам, основывается на так называемых Conventions. Список актуальных типов здесь: [5]
Wiren Board использует набор соглашений по работе с MQTT. Эти соглашения описаны ниже. Полное каноническое описание соглашений Wiren Board смотрите в документе Wiren Board MQTT Conventions.
Архитектура ПО Wiren Board:
Специальные "драйверы" (отдельный для каждой функции контроллера и внешнего устройства) транслируют данные с устройства в очередь в виде сообщений специального формата. Сообщения из этой очереди получает веб-интерфейс и движок правил. Они же могут добавлять туда новые сообщения - например, "включить реле" после получения нажатия в интерфейсе или выполнения нужных условий в каком-нибудь правиле.
Веб-интерфейс работает также через систему сообщений MQTT - нажатие кнопки в интерфейсе вызывает отправку сообщения в очередь (а именно брокеру сообщений); изменение показания датчика, поступившее в систему сообщений, тут же вызывает изменения транслируется в веб-интерфейс.
Пример: если на цифровой вход Wiren Board подан сигнал, драйвер wb-homa-gpio создаёт сообщение вида .......... - "на входе ... появился сигнал". Веб-интерфейс, который тоже подключён к системе сообщений, получает это сообщение и "зажигает" индикатор в веб-интерфейсе.
Система правил
Вы можете написать свои правила на языке Javascript. Подробнее смотрите [6]