Knowledge WiKibase

…collecting bit by bit!

Инструменты пользователя

Инструменты сайта

Вы находитесь здесь: Оглавление » iot » software » node-red » flows » Мониторинг локальной сети в Node-RED
Вы посетили:
iot:software:node-red:flows:network_monitoring

Различия

Показаны различия между двумя версиями страницы.

Ссылка на это сравнение

Предыдущая версия справа и слева Предыдущая версия
Следующая версия 		Предыдущая версия
iot:software:node-red:flows:network_monitoring [2021/12/15 12:08]
Николай Солошин Добавлены узлы "Фильтрация пустой нагрузки" и "Сообщение о пустой нагрузке". 		iot:software:node-red:flows:network_monitoring [2022/02/16 21:20] (текущий)
Николай Солошин ↷ Операцией перемещения обновлены ссылки
Строка 1: Строка 1:
-{{htmlmetatags>metatag-keywords=(network monitoring,node-red,flow)  +{{htmlmetatags>metatag-keywords=(network monitoring,node-red,flow,мониторинг сети,сетевой мониторинг,поток,поток node-red,flows)  
-metatag-description=(Проверяет добавленные в базу узлы и при необходимости отправляет уведомления.)}}+metatag-description=(Проверяет добавленные в базу хосты и, при необходимости, отправляет уведомления.)}}
  
 ====== Мониторинг локальной сети в Node-RED ====== ====== Мониторинг локальной сети в Node-RED ======
  
-Не большой поток для мониторинга произвольных устройств в локальной сети или Интернете.+Небольшой поток для мониторинга произвольных устройств в локальной сети или Интернете **версия 2.x**, полностью переосмысленная и переписанная -- меньше ложных срабатываний((Для беспроводных устройств оптимальным оказалось 3 дополнительных цикла с задержкой 10 секунд.)), меньше обращений к базе данных, более компактная, линейная и логичная! В общем, конфетка, а не... то, что было((Можно простить, т.к. это практические первое, что я когда-то собрал на Node-RED.)). LOL 
 + 
 +:!: Архивные версии [[iot:software:node-red:flows:network_monitoring?rev=1638922322|1.0]], [[iot:software:node-red:flows:network_monitoring?rev=1640356134|1.1]], [[iot:software:node-red:flows:network_monitoring?rev=1640519728|2.0]].
  
 ===== Нестандартные узлы ===== ===== Нестандартные узлы =====
Строка 16: Строка 18:
 ===== Дополнительные подпотоки ===== ===== Дополнительные подпотоки =====
  
-  * [[iot:node-red:subflows:sendmail|Отправка почты]]+  * [[iot:software:node-red:subflows:sendmail|Отправка почты]]
  
-Эти подпотоки входят в состав кода ниже и загружать отдельно их не надо!+Этот подпоток входит в состав кода ниже и загружать отдельно его не надо!
  
 ===== Описание работы цепочки ===== ===== Описание работы цепочки =====
  
-Поток запускается раз в минуту, получает из базы все устройства и пингует их. Потом записывает ответы в базу и через 30 секунд повторно пингует только те, которые не ответили до этого, и опять записывает ответы в базу. Далее идет задержка в 10 секунд, чтобы все устройства успели провериться и все данные записаться. Потом из базы извлекаются отдельно не отвечающие устройства, работающие устройства и устройства, которые не работали до этого. В зависимости от состава данных на почту отправляются обобщенные письма с разным содержимым.+Цепочка запускается автоматически каждую минуту((Настраивается в узле "Автозапуск".)), при необходимости или каком-то сбое, можно запустить вручную. Далее из базы данных читаются все устройства, проверяются командой ping и записываются результаты в БД. Если есть устройства, которые не ответили, они попадают в цикл с заданным числом витков и временем между попытками((Настраивается в узле "Ввод настроек".)). Прочие устройства ожидают завершения всех циклов, после чего все сообщения собираются в одно, которое и передается дальше. 
 + 
 +{{iot:software:node-red:flows:nm3.1.png?nolink|}} 
 + 
 +Далее подсчитывается количество тех или иных статусов(("Умерло", "ожило", "мертвое" и "живое" устройство.)) и сообщение вновь разбивается на части для объединения по статусам и сортировки. В конце, если необходимо((Есть устройства со статусами "умерло" или "ожило".)), формируется и отправляется письмо. 
 + 
 +{{iot:software:node-red:flows:mails_examples.jpg?direct&1000|Примеры писем от мониторинга сети.}} 
 + 
 +=== История изменений ===
  
-{{:iot:node-red:flows:nm1.png?nolink|}}+  * В **версии 2.1** добавлена отправка периодической сводки((По умолчанию раз в 6 часов.)) по недоступным хостам.
  
 ==== Создание таблицы ==== ==== Создание таблицы ====
Строка 30: Строка 40:
 :!: Для работы этого потока, необходимо вручную создать таблицу, выполнив SQL-запрос: :!: Для работы этого потока, необходимо вручную создать таблицу, выполнив SQL-запрос:
  
-<code sql>CREATE TABLE nw_status (_id INTEGER PRIMARY KEY, name TEXT, host TEXT, timeout INTEGER, response INTEGER, sent INTEGER)</code>+<code sql>CREATE TABLE nw_status (_id INTEGER PRIMARY KEY, name TEXT, host TEXT, timeout INTEGER, response INTEGER, sent INTEGER DEFAULT 0, cycles INTEGER)</code>
  
 Пример цепочки: Пример цепочки:
Строка 53: Строка 63:
         "once": false,         "once": false,
         "onceDelay": 0.1,         "onceDelay": 0.1,
-        "topic": "CREATE TABLE nw_status (_id INTEGER PRIMARY KEY, name TEXT, host TEXT, timeout INTEGER, response INTEGER, sent INTEGER)",+        "topic": "CREATE TABLE nw_status (_id INTEGER PRIMARY KEY, name TEXT, host TEXT, timeout INTEGER, response INTEGER, sent INTEGER DEFAULT 0, cycles INTEGER)",
         "payload": "",         "payload": "",
         "payloadType": "date",         "payloadType": "date",
Строка 111: Строка 121:
 === Добавление устройства === === Добавление устройства ===
  
-<code sql>INSERT INTO nw_status (name, host, sent) VALUES ("Устройство 1", "192.168.0.5", false)</code>+<code sql>INSERT INTO nw_status (name, host, timeout) VALUES ("Устройство 1", "192.168.0.5", 10000)</code>
  
-Последний параметр должен быть всегда ''false''!+Если таймаут необходимо установить по умолчанию, вместо цифр указать ''NULL''((По умолчанию 5000/(5 сек.), диапазон 1000-30000.)) или не использовать его в запросе:
  
-=== Массовое добавление ===+<code sql>INSERT INTO nw_status (name, host) VALUES ("Устройство 1", "192.168.0.5")</code>
  
-<code sql>INSERT INTO nw_status (name, host, sent) VALUES ("Устройство 1", "192.168.0.5", false), ("Устройство 2", "192.168.0.6", false), ("Устройство 3", "192.168.0.7", false)</code>+=== Массовое добавление ===
  
-Последний параметр должен быть всегда ''false''!+<code sql>INSERT INTO nw_status (name, host, timeout) VALUES ("Устройство 1", "192.168.0.5", NULL), ("Устройство 2", "192.168.0.6", 7000), ("Устройство 3", "192.168.0.7", 2000)</code>
  
 === Просмотр всех устройств === === Просмотр всех устройств ===
Строка 125: Строка 135:
 <code sql>SELECT * FROM nw_status</code> <code sql>SELECT * FROM nw_status</code>
  
-=== Удаление устройства с id ===+=== Удаление устройства ===
  
-<code sql>DELETE FROM nw_status WHERE _id = 1</code>+Запрос для удаления устройства с номером 2. 
 + 
 +<code sql>DELETE FROM nw_status WHERE _id = 2</code> 
 + 
 +:!: Во **второй версии** потока есть ограничение -- ряд ''_id'' должен быть цельным, без пропусков((Т.е. "1, 2, 3, 4", а не "1, 2, 4, 5"!)), т.е. нельзя просто так удалить устройство -- его необходимо заменить другим или присвоить его номер последнему устройству в списке! 
 + 
 +=== Обновление последней записи === 
 + 
 +Для замены ''_id'' в последней строке базы данных можно использовать такой запрос: 
 + 
 +<code sql>UPDATE nw_status SET _id = 2 WHERE _rowid_ = ( SELECT MAX( _rowid_ ) FROM nw_status )</code>
  
 ===== Код для загрузки ===== ===== Код для загрузки =====
Строка 176: Строка 196:
     },     },
     {     {
-        "id": "2d6b7ec9.d03902", +        "id": "817060ef.2b843",
-        "type": "sqlite", +
-        "z": "bf63e9a3.a5b928", +
-        "mydb": "2bc4c6d.cf1f03a", +
-        "sqlquery": "msg.topic", +
-        "sql": "", +
-        "name": "Выполнение запросов к базе данных", +
-        "x": 210, +
-        "y": 1000, +
-        "wires": [ +
-            [] +
-        ] +
-    }, +
-    { +
-        "id": "2df5d68e.94e28a",+
         "type": "inject",         "type": "inject",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "name": "Запрос всех данных из таблицы", +        "name": "Автозапуск", 
-        "props": [ +        "props": [], 
-            { +        "repeat": "60",
-                "p": "payload" +
-            }, +
-            { +
-                "p": "topic", +
-                "vt": "str" +
-            } +
-        ], +
-        "repeat": "",+
         "crontab": "",         "crontab": "",
-        "once": false, +        "once": true, 
-        "onceDelay": 0.1, +        "onceDelay": "1", 
-        "topic": "select * from nw_status", +        "topic": "", 
-        "payload": "", +        "payloadType": "str", 
-        "payloadType": "date", +        "x": 130, 
-        "x": 190, +        "y": 100,
-        "y": 940,+
         "wires": [         "wires": [
             [             [
-                "2d6b7ec9.d03902"+                "ad444795.a7b668"
             ]             ]
         ]         ]
     },     },
     {     {
-        "id": "e98df0ca.07391", +        "id": "f27932db.06f1e", 
-        "type": "inject",+        "type": "sqlite",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "name": "Разные примеры запросов", +        "mydb": "2bc4c6d.cf1f03a", 
-        "props": [ +        "sqlquery": "msg.topic", 
-            { +        "sql": "", 
-                "p": "payload" +        "name": "Выборка всех устройств", 
-            }, +        "x": 690, 
-            { +        "y": 40,
-                "p": "topic22", +
-                "v": "SELECT name FROM nw_status WHERE response = false", +
-                "vt": "str" +
-            }, +
-            { +
-                "p": "topic333", +
-                "v": "ALTER TABLE nw_status ADD COLUMN sent INTEGER", +
-                "vt": "str" +
-            }, +
-            { +
-                "p": "topic7777", +
-                "v": "SELECT name FROM nw_status WHERE response = false AND sent IS NULL OR sent = false", +
-                "vt": "str" +
-            }, +
-            { +
-                "p": "topic666", +
-                "v": "UPDATE nw_status SET sent = false WHERE _id = 15", +
-                "vt": "str" +
-            }, +
-            { +
-                "p": "topic67867", +
-                "v": "UPDATE nw_status SET sent = false", +
-                "vt": "str" +
-            }, +
-            { +
-                "p": "topic2324", +
-                "v": "SELECT name FROM nw_status WHERE response = false AND sent IS NULL OR FALSE", +
-                "vt": "str" +
-            }, +
-            { +
-                "p": "topic9999", +
-                "v": "DELETE FROM nw_status WHERE _id >= 14", +
-                "vt": "str" +
-            }, +
-            { +
-                "p": "topic", +
-                "vt": "str" +
-            } +
-        ], +
-        "repeat": "", +
-        "crontab": "", +
-        "once": false, +
-        "onceDelay": 0.1, +
-        "topic": "INSERT INTO nw_status (name, host, sent) VALUES (\"Увлажнитель в спальне 2\", \"192.168.30.99\", false)", +
-        "payload": "", +
-        "payloadType": "date", +
-        "x": 180, +
-        "y": 1060,+
         "wires": [         "wires": [
             [             [
-                "2d6b7ec9.d03902"+                "5ace9ea9.1497d"
             ]             ]
         ]         ]
     },     },
     {     {
-        "id": "b19cc44a.c99678", +        "id": "f41fa10e.39756",
-        "type": "comment", +
-        "z": "bf63e9a3.a5b928", +
-        "name": "SQL запросы", +
-        "info": "Добавоение нового устройства:\nINSERT INTO nw_status (name, host, sent) VALUES (\"Увлажнитель в спальне\", \"192.168.30.29\", false)\n\nУдаление устройства с ID=1:\nDELETE FROM nw_status WHERE _id = 1\n\n---------------\n\nСоздание таблицы:\nCREATE TABLE nw_status (_id INTEGER PRIMARY KEY, name TEXT, host TEXT, timeout INTEGER, response INTEGER, sent INTEGER)\n\nМассовое добавление строк:\nINSERT INTO nw_status (name, host) VALUES (\"Увлажнитель в спальне\", \"192.168.30.29\"), (\"Вентиляция в ванной\", \"192.168.30.21\"), (\"Фумигатор в спальне\", \"192.168.30.25\"), (\"Лампа в спальне\", \"192.168.30.20\"), (\"Торшер в спальне\", \"192.168.30.36\"), (\"Ночник в спальне\", \"192.168.30.19\"), (\"Освещение в спальне - холодный\", \"192.168.30.23\"), (\"Освещение в спальне - теплый\", \"192.168.30.14\"), (\"Освещение в детской\", \"192.168.30.16\"), (\"Освещение коридора\", \"192.168.30.40\"), (\"Камера на лестничной клетке\", \"192.168.30.13\"), (\"MikroTik Dalnos\", \"192.168.30.5\"), (\"MikroTik Altos\", \"192.168.30.4\"), (\"Тест 1\", \"192.168.30.98\"), (\"Тест 2\", \"192.168.30.99\")\n\nВыбор определенных столбцов:\nSELECT _id, name, host FROM nw_status\n\nВыбор с условием:\nSELECT name FROM nw_status WHERE response = false AND sent = false\n\nДобавление столбца:\nALTER TABLE nw_status ADD COLUMN sent INTEGER\n\nУдаление таблицы:\nDROP TABLE nw_status\n\n-----------\n\nINSERT INTO nw_status (_id, response) VALUES (4, false)\n\nUPDATE nw_status SET response = true WHERE _id = 1\n\nSELECT * FROM nw_status WHERE _id = 1\n\nSELECT * FROM nw_status WHERE response = false\n\nSELECT value FROM nw_status WHERE _id = 1\n", +
-        "x": 430, +
-        "y": 1060, +
-        "wires": [] +
-    }, +
-    { +
-        "id": "cfe7df0c.f1ba8",+
         "type": "ping",         "type": "ping",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
Строка 302: Строка 241:
         "timer": "60",         "timer": "60",
         "inputs": 1,         "inputs": 1,
-        "x": 720, +        "x": 460, 
-        "y": 40,+        "y": 160,
         "wires": [         "wires": [
             [             [
-                "6432f525.3fcdec", +                "425962de.576a5c"
-                "f294d89c.2ea288"+
             ]             ]
         ]         ]
     },     },
     {     {
-        "id": "fc20d804.5ada18", +        "id": "cbb6faf8.027568", 
-        "type": "inject",+        "type": "change",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "name": "Запуск раз в мин.", +        "name": "Установка счетчика цикла", 
-        "props": [], +        "rules": [ 
-        "repeat": "60", +            { 
-        "crontab": "", +                "t": "set", 
-        "once": true, +                "p": "ping.count", 
-        "onceDelay": "1", +                "pt": "msg", 
-        "topic": "", +                "to": "$exists( ping.count ) = true ? ( ping.count + 1 ) : 0", 
-        "payloadType": "str", +                "tot": "jsonata" 
-        "x": 150, +            }, 
-        "y": 40,+            { 
 +                "t": "set", 
 +                "p": "delay", 
 +                "pt": "msg", 
 +                "to": "settings.delay", 
 +                "tot": "flow" 
 +            } 
 +        ], 
 +        "action": "", 
 +        "property": "", 
 +        "from": "", 
 +        "to": "", 
 +        "reg": false, 
 +        "x": 180, 
 +        "y": 220,
         "wires": [         "wires": [
             [             [
-                "8c18105b.84c43"+                "25c3af02.51d2c"
             ]             ]
         ]         ]
     },     },
     {     {
-        "id": "8c18105b.84c43", +        "id": "25c3af02.51d2c", 
-        "type": "sqlite",+        "type": "switch",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "mydb": "2bc4c6d.cf1f03a", +        "name": "Проверка счетчика", 
-        "sqlquery": "fixed", +        "property": "ping.count", 
-        "sql": "SELECT _id, host, response, sent FROM nw_status", +        "propertyType": "msg", 
-        "name": "Выборка всех устройств из базы", +        "rules": [ 
-        "x": 440, +            { 
-        "y": 40,+                "t": "neq", 
 +                "v": "settings.cycles", 
 +                "vt": "flow" 
 +            }, 
 +            { 
 +                "t": "eq", 
 +                "v": "settings.cycles", 
 +                "vt": "flow" 
 +            } 
 +        ], 
 +        "checkall": "false", 
 +        "repair": false, 
 +        "outputs": 2, 
 +        "x": 460, 
 +        "y": 220,
         "wires": [         "wires": [
             [             [
-                "cfe7df0c.f1ba8"+                "202cf843.0c54a8" 
 +            ], 
 +            [ 
 +                "73733ff5.013f9"
             ]             ]
 +        ],
 +        "outputLabels": [
 +            "Повторить цикл",
 +            "Завершить цикл"
         ]         ]
     },     },
     {     {
-        "id": "ac764a5f.30d158", +        "id": "425962de.576a5c", 
-        "type": "sqlite",+        "type": "switch",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "mydb": "2bc4c6d.cf1f03a", +        "name": "Доступность устройства", 
-        "sqlquery": "msg.topic", +        "property": "payload", 
-        "sql": "UPDATE nw_status SET response = $response WHERE _id = $id", +        "propertyType": "msg", 
-        "name": "Запись ответов в базу",+        "rules": [ 
 +            { 
 +                "t": "false" 
 +            }, 
 +            { 
 +                "t": "else" 
 +            } 
 +        ], 
 +        "checkall": "false", 
 +        "repair": false, 
 +        "outputs": 2,
         "x": 690,         "x": 690,
-        "y": 220,+        "y": 160,
         "wires": [         "wires": [
-            []+            [ 
 +                "cbb6faf8.027568" 
 +            ], 
 +            [ 
 +                "47244dcf.c20b34" 
 +            ] 
 +        ], 
 +        "outputLabels": [ 
 +            "Не отвечает", 
 +            "Отвечает"
         ]         ]
     },     },
     {     {
-        "id": "6432f525.3fcdec",+        "id": "202cf843.0c54a8", 
 +        "type": "template", 
 +        "z": "bf63e9a3.a5b928", 
 +        "name": "Восстановление структуры", 
 +        "field": "payload", 
 +        "fieldType": "msg", 
 +        "format": "handlebars", 
 +        "syntax": "mustache", 
 +        "template": "[{\n\"_id\": {{{ping._id}}},\n\"name\": \"{{{ping.name}}}\",\n\"host\": \"{{{ping.host}}}\",\n\"timeout\": {{{ping.timeout}}},\n\"sent\": {{{ping.sent}}},\n\"count\": {{{ping.count}}}\n}]", 
 +        "output": "json", 
 +        "x": 680, 
 +        "y": 280, 
 +        "wires": [ 
 +            [ 
 +                "d2b39ab6.0c64f8" 
 +            ] 
 +        ] 
 +    }, 
 +    { 
 +        "id": "73733ff5.013f9",
         "type": "change",         "type": "change",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "name": "Подготовка параметров запроса",+        "name": "Установка св-в",
         "rules": [         "rules": [
             {             {
Строка 371: Строка 382:
                 "p": "topic",                 "p": "topic",
                 "pt": "msg",                 "pt": "msg",
-                "to": "\"UPDATE nw_status SET response = \" & payload & \" WHERE _id = \" & ping._id",+                "to": "\"UPDATE \\\"\" & $flowContext( \"settings.table\" ) & \"\\\" SET response = \" & payload & \", cycles = \" & ( $exists( ping.count ) = false ? 0 : ping.count ) & \" WHERE _id = \" & ping._id",
                 "tot": "jsonata"                 "tot": "jsonata"
 +            },
 +            {
 +                "t": "set",
 +                "p": "parts.index",
 +                "pt": "msg",
 +                "to": "ping._id - 1",
 +                "tot": "jsonata"
 +            },
 +            {
 +                "t": "set",
 +                "p": "parts.count",
 +                "pt": "msg",
 +                "to": "parts.count",
 +                "tot": "flow"
 +            },
 +            {
 +                "t": "set",
 +                "p": "parts.id",
 +                "pt": "msg",
 +                "to": "parts.id",
 +                "tot": "flow"
 +            },
 +            {
 +                "t": "move",
 +                "p": "payload",
 +                "pt": "msg",
 +                "to": "ping.response",
 +                "tot": "msg"
             }             }
         ],         ],
Строка 380: Строка 419:
         "to": "",         "to": "",
         "reg": false,         "reg": false,
-        "x": 660, +        "x": 220, 
-        "y": 160,+        "y": 280,
         "wires": [         "wires": [
             [             [
-                "ac764a5f.30d158"+                "5d114f5c.32a04"
             ]             ]
         ]         ]
     },     },
     {     {
-        "id": "54551fc7.c449", +        "id": "5d114f5c.32a04", 
-        "type": "ping",+        "type": "sqlite",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "protocol": "Automatic", +        "mydb": "2bc4c6d.cf1f03a", 
-        "mode": "triggered", +        "sqlquery": "msg.topic", 
-        "name": "Повторная проверка связи", +        "sql": "", 
-        "host": "", +        "name": "Запись ответов", 
-        "timer": "20", +        "x": 420,
-        "inputs": 1, +
-        "x": 180,+
         "y": 280,         "y": 280,
         "wires": [         "wires": [
             [             [
-                "6432f525.3fcdec", +                "8961f0c.35b121"
-                "20b57937.b480b6"+
             ]             ]
         ]         ]
     },     },
     {     {
-        "id": "20b57937.b480b6", +        "id": "5ace9ea9.1497d", 
-        "type": "switch",+        "type": "change",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "name": "Отсечка работающих устройств", +        "name": "Сохранение переменных",
-        "property": "payload", +
-        "propertyType": "msg",+
         "rules": [         "rules": [
             {             {
-                "t": "false"+                "t": "set", 
 +                "p": "parts.count", 
 +                "pt": "flow", 
 +                "to": "$count( payload )\t", 
 +                "tot": "jsonata"
             },             },
             {             {
-                "t": "else"+                "t": "set", 
 +                "p": "parts.id", 
 +                "pt": "flow", 
 +                "to": "", 
 +                "tot": "date"
             }             }
         ],         ],
-        "checkall": "false", +        "action": "", 
-        "repair": false, +        "property": "", 
-        "outputs": 2, +        "from": "", 
-        "x": 200, +        "to": "", 
-        "y": 340,+        "reg": false, 
 +        "x": 680, 
 +        "y": 100,
         "wires": [         "wires": [
             [             [
-                "251fd244.6bc71e" +                "f41fa10e.39756"
-            ], +
-            [ +
-                "cdb27b4e.0e8408"+
             ]             ]
         ]         ]
     },     },
     {     {
-        "id": "f294d89c.2ea288", +        "id": "93dadf2f.1e905", 
-        "type": "switch",+        "type": "join",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "name": "Отсечка работающих устройств",+        "name": "Объединение", 
 +        "mode": "auto", 
 +        "build": "string",
         "property": "payload",         "property": "payload",
         "propertyType": "msg",         "propertyType": "msg",
 +        "key": "topic",
 +        "joiner": "\\n",
 +        "joinerType": "str",
 +        "accumulate": false,
 +        "timeout": "",
 +        "count": "",
 +        "reduceRight": false,
 +        "reduceExp": "",
 +        "reduceInit": "",
 +        "reduceInitType": "num",
 +        "reduceFixup": "",
 +        "x": 480,
 +        "y": 340,
 +        "wires": [
 +            [
 +                "d763f5eb.4a1378"
 +            ]
 +        ],
 +        "info": "Восстанавливается и объединяется последовательность для того, чтобы достоверно узнать завершение операции тестирования связи."
 +    },
 +    {
 +        "id": "8961f0c.35b121",
 +        "type": "change",
 +        "z": "bf63e9a3.a5b928",
 +        "name": "Установка статусов",
         "rules": [         "rules": [
             {             {
-                "t": "false"+                "t": "set", 
 +                "p": "payload", 
 +                "pt": "msg", 
 +                "to": "$type( payload ) = \"array\" ? ping : payload", 
 +                "tot": "jsonata"
             },             },
             {             {
-                "t": "else"+                "t": "set", 
 +                "p": "payload.status", 
 +                "pt": "msg", 
 +                "to": "( payload.sent = 0 and payload.response = false ) ? \"died\" : ( payload.sent = 1 and payload.response = false ) ? \"dead\" : ( payload.sent = 1 and payload.response > 0 ) ? \"revived\" : ( payload.sent = 0 and payload.response > 0 ) ? \"alive\"", 
 +                "tot": "jsonata"
             }             }
         ],         ],
-        "checkall": "false", +        "action": "", 
-        "repair": false, +        "property": "", 
-        "outputs": 2, +        "from": "", 
-        "x": 200, +        "to": "", 
-        "y": 100,+        "reg": false, 
 +        "x": 240, 
 +        "y": 340,
         "wires": [         "wires": [
             [             [
-                "92c6d976.4c9eb8" +                "93dadf2f.1e905"
-            ], +
-            [ +
-                "cdb27b4e.0e8408"+
             ]             ]
         ]         ]
     },     },
     {     {
-        "id": "92c6d976.4c9eb8",+        "id": "51891d56.192d94",
         "type": "delay",         "type": "delay",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "name": "Задержка 30 сек", +        "name": "Задержка проверки", 
-        "pauseType": "delay", +        "pauseType": "delayv", 
-        "timeout": "30",+        "timeout": "1",
         "timeoutUnits": "seconds",         "timeoutUnits": "seconds",
         "rate": "1",         "rate": "1",
Строка 479: Строка 554:
         "randomLast": "5",         "randomLast": "5",
         "randomUnits": "seconds",         "randomUnits": "seconds",
-        "drop": true, +        "drop": false, 
-        "x": 150,+        "x": 220,
         "y": 160,         "y": 160,
         "wires": [         "wires": [
             [             [
-                "fe66d152.90cc4"+                "f41fa10e.39756"
             ]             ]
         ]         ]
     },     },
     {     {
-        "id": "fe66d152.90cc4", +        "id": "6ccc324d.f380bc",
-        "type": "template", +
-        "z": "bf63e9a3.a5b928", +
-        "name": "Восстановление структуры", +
-        "field": "payload", +
-        "fieldType": "msg", +
-        "format": "handlebars", +
-        "syntax": "mustache", +
-        "template": "[{\n\"_id\": {{{ping._id}}},\n\"host\": \"{{{ping.host}}}\",\n\"timeout\": {{{ping.timeout}}}\n}]", +
-        "output": "json", +
-        "x": 180, +
-        "y": 220, +
-        "wires": [ +
-            [ +
-                "54551fc7.c449" +
-            ] +
-        ] +
-    }, +
-    { +
-        "id": "f22d9840.db3838", +
-        "type": "sqlite", +
-        "z": "bf63e9a3.a5b928", +
-        "mydb": "2bc4c6d.cf1f03a", +
-        "sqlquery": "fixed", +
-        "sql": "SELECT _id, name FROM nw_status WHERE response = false AND sent = false", +
-        "name": "Выборка новых уведомлений", +
-        "x": 190, +
-        "y": 460, +
-        "wires": [ +
-            [ +
-                "8eab3c0.f34e6c8" +
-            ] +
-        ] +
-    }, +
-    { +
-        "id": "59302cbf.45d0b4",+
         "type": "change",         "type": "change",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "name": "Установка темы и времени",+        "name": "Ввод настроек",
         "rules": [         "rules": [
 +            {
 +                "t": "set",
 +                "p": "settings.cycles",
 +                "pt": "flow",
 +                "to": "3",
 +                "tot": "num"
 +            },
 +            {
 +                "t": "set",
 +                "p": "settings.delay",
 +                "pt": "flow",
 +                "to": "10000",
 +                "tot": "num"
 +            },
 +            {
 +                "t": "set",
 +                "p": "settings.table",
 +                "pt": "flow",
 +                "to": "nw_status_test",
 +                "tot": "str"
 +            },
             {             {
                 "t": "set",                 "t": "set",
                 "p": "topic",                 "p": "topic",
                 "pt": "msg",                 "pt": "msg",
-                "to": "\"Уведомление системы мониторинга от \" & $now('[H01]:[m01]:[s01] [D01].[M01].[Y0001]', '+1000') & \"!\"",+                "to": "\"SELECT _id, name, host, timeout, sent FROM \\\"\" & $flowContext( \"settings.table\" ) & \"\\\"\"",
                 "tot": "jsonata"                 "tot": "jsonata"
             },             },
             {             {
-                "t": "delete", +                "t": "set", 
-                "p": "ping", +                "p": "status.run", 
-                "pt": "msg"+                "pt": "flow", 
 +                "to": "true", 
 +                "tot": "bool" 
 +            }, 
 +            { 
 +                "t": "set", 
 +                "p": "status.sent", 
 +                "pt": "flow", 
 +                "to": "false", 
 +                "tot": "bool"
             }             }
         ],         ],
Строка 548: Строка 618:
         "reg": false,         "reg": false,
         "x": 440,         "x": 440,
-        "y": 820,+        "y": 40,
         "wires": [         "wires": [
             [             [
-                "cdca79a3.67f758"+                "f27932db.06f1e"
             ]             ]
-        ]+        ], 
 +        "info": "**flow.settings.cycles** -- количество дополнительных попыток проверки связи (при установке \"0\" будет проведена 1 попытка; при установке \"1\", соответственно, 2, т.е. одна основная, и одна дополнительная);\n\n**flow.settings.delay** -- задержка между дополнительными попытками проверки;\n\n**flow.settings.table** -- название таблицы в базе данных."
     },     },
     {     {
-        "id": "a91d85a7.c844f8", +        "id": "dbabb4a5.093288", 
-        "type": "template",+        "type": "link in",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "name": "Шаблон тела письма", +        "name": "", 
-        "field": "payload", +        "links": [ 
-        "fieldType": "msg", +            "d2b39ab6.0c64f8" 
-        "format": "handlebars", +        ], 
-        "syntax": "mustache", +        "x": 75, 
-        "template": "{{{setsendstatus}}}:\n\n{{{fails}}}\nДиагностические данные:\n\n{{{payload}}}", +        "y": 160,
-        "output": "str", +
-        "x": 160, +
-        "y": 820,+
         "wires": [         "wires": [
             [             [
-                "59302cbf.45d0b4"+                "51891d56.192d94"
             ]             ]
         ]         ]
     },     },
     {     {
-        "id": "2224cda9.8a42a2", +        "id": "d2b39ab6.0c64f8", 
-        "type": "csv",+        "type": "link out",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "name": "Преобразование 1-й секции письма", +        "name": "", 
-        "sep": ",", +        "links": [ 
-        "hdrin": "", +            "dbabb4a5.093288" 
-        "hdrout": "none", +        ], 
-        "multi": "one", +        "x": 675, 
-        "ret": "\\r\\n", +        "y": 220, 
-        "temp": "name", +        "wires": [] 
-        "skip": "0", +    }, 
-        "strings": true, +    { 
-        "include_empty_strings": "", +        "id": "721310f6.a461a", 
-        "include_null_values": "", +        "type": "link in", 
-        "x": 570, +        "z": "bf63e9a3.a5b928", 
-        "y": 580,+        "name": "", 
 +        "links": [ 
 +            "47244dcf.c20b34" 
 +        ], 
 +        "x": 75, 
 +        "y": 280,
         "wires": [         "wires": [
             [             [
-                "5a58b9c4.d46f88"+                "73733ff5.013f9"
             ]             ]
         ]         ]
     },     },
     {     {
-        "id": "cdca79a3.67f758", +        "id": "47244dcf.c20b34", 
-        "type": "subflow:38c9a069.18cd6",+        "type": "link out",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "name": "Отправка писем", +        "name": "", 
-        "env": [], +        "links": [ 
-        "x": 150, +            "721310f6.a461a" 
-        "y": 880,+        ], 
 +        "x": 775, 
 +        "y": 220,
         "wires": []         "wires": []
     },     },
     {     {
-        "id": "d5126915.e6c4f8", +        "id": "ad444795.a7b668", 
-        "type": "sqlite",+        "type": "switch",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "mydb": "2bc4c6d.cf1f03a", +        "name": "Проверка метки", 
-        "sqlquery": "msg.topic", +        "property": "status.run", 
-        "sql": "UPDATE nw_status SET sent = true WHERE response = false", +        "propertyType": "flow", 
-        "name": "Установка флага отправки", +        "rules": [ 
-        "x": 680, +            { 
-        "y": 1060,+                "t": "jsonata_exp", 
 +                "v": "$exists( $flowContext( \"status.run\" ) ) = false or $flowContext( \"status.run\" ) = false", 
 +                "vt": "jsonata" 
 +            }, 
 +            { 
 +                "t": "jsonata_exp", 
 +                "v": "( $exists( $flowContext( \"status.sent\" ) ) = false or $flowContext( \"status.sent\" ) = false) and $flowContext( \"status.run\" ) = true", 
 +                "vt": "jsonata" 
 +            } 
 +        ], 
 +        "checkall": "false", 
 +        "repair": false, 
 +        "outputs": 2, 
 +        "x": 330, 
 +        "y": 100,
         "wires": [         "wires": [
-            []+            [ 
 +                "6ccc324d.f380bc" 
 +            ], 
 +            [ 
 +                "65cbf7fe.7357d8" 
 +            ] 
 +        ], 
 +        "info": "Фильтр запуска цепочки до завершения предыдущей задачи." 
 +    }, 
 +    { 
 +        "id": "d763f5eb.4a1378", 
 +        "type": "change", 
 +        "z": "bf63e9a3.a5b928", 
 +        "name": "Подсчет статусов", 
 +        "rules": [ 
 +            { 
 +                "t": "set", 
 +                "p": "result.alive", 
 +                "pt": "msg", 
 +                "to": "payload.$sift( function( $v, $k ) { $k = \"status\" and $v = \"alive\" } ) ~> $count()", 
 +                "tot": "jsonata" 
 +            }, 
 +            { 
 +                "t": "set", 
 +                "p": "result.dead", 
 +                "pt": "msg", 
 +                "to": "payload.$sift( function( $v, $k ) { $k = \"status\" and $v = \"dead\" } ) ~> $count()", 
 +                "tot": "jsonata" 
 +            }, 
 +            { 
 +                "t": "set", 
 +                "p": "result.revived", 
 +                "pt": "msg", 
 +                "to": "payload.$sift( function( $v, $k ) { $k = \"status\" and $v = \"revived\" } ) ~> $count()", 
 +                "tot": "jsonata" 
 +            }, 
 +            { 
 +                "t": "set", 
 +                "p": "result.died", 
 +                "pt": "msg", 
 +                "to": "payload.$sift( function( $v, $k ) { $k = \"status\" and $v = \"died\" } ) ~> $count()", 
 +                "tot": "jsonata" 
 +            }, 
 +            { 
 +                "t": "set", 
 +                "p": "status.run", 
 +                "pt": "flow", 
 +                "to": "false", 
 +                "tot": "bool" 
 +            } 
 +        ], 
 +        "action": "", 
 +        "property": "", 
 +        "from": "", 
 +        "to": "", 
 +        "reg": false, 
 +        "x": 710, 
 +        "y": 340, 
 +        "wires": [ 
 +            [ 
 +                "71abee18.7fdf4" 
 +            ]
         ]         ]
     },     },
     {     {
-        "id": "5a58b9c4.d46f88",+        "id": "2aa2153.fed7bea", 
 +        "type": "subflow:38c9a069.18cd6", 
 +        "z": "bf63e9a3.a5b928", 
 +        "name": "Отправка писем", 
 +        "env": [], 
 +        "x": 710, 
 +        "y": 640, 
 +        "wires": [] 
 +    }, 
 +    { 
 +        "id": "38565f85.6837e",
         "type": "change",         "type": "change",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "name": "Перемещение данных",+        "name": "Наложение проверок",
         "rules": [         "rules": [
             {             {
-                "t": "move",+                "t": "set", 
 +                "p": "topic", 
 +                "pt": "msg", 
 +                "to": "\"Уведомление системы мониторинга от \" & $now( '[H01]:[m01]:[s01] [D01].[M01].[Y0001]', '+1000' ) & \"!\"", 
 +                "tot": "jsonata" 
 +            }, 
 +            { 
 +                "t": "set",
                 "p": "payload",                 "p": "payload",
                 "pt": "msg",                 "pt": "msg",
-                "to": "fails", +                "to": "Запущен новый цикл проверки, тогда как предыдущий еще не завершен! Текущая проверка отменена. Возможно, необходимо увеличить интервал запуска.", 
-                "tot": "msg"+                "tot": "str" 
 +            }, 
 +            { 
 +                "t": "set", 
 +                "p": "status.sent", 
 +                "pt": "flow", 
 +                "to": "true", 
 +                "tot": "bool"
             }             }
         ],         ],
Строка 640: Строка 814:
         "to": "",         "to": "",
         "reg": false,         "reg": false,
-        "x": 170, +        "x": 700, 
-        "y": 640,+        "y": 700,
         "wires": [         "wires": [
             [             [
-                "c5361c7e.7aa9b"+                "2aa2153.fed7bea"
             ]             ]
         ]         ]
     },     },
     {     {
-        "id": "c5361c7e.7aa9b", +        "id": "49762568.343b6c", 
-        "type": "sqlite",+        "type": "link in",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "mydb": "2bc4c6d.cf1f03a", +        "name": "", 
-        "sqlquery": "fixed", +        "links": [ 
-        "sql": "SELECT name, response FROM nw_status WHERE response > 0 ORDER BY response DESC", +            "65cbf7fe.7357d8" 
-        "name": "Выборка: устройство отвечает", +        ], 
-        "x": 550, +        "x": 555, 
-        "y": 640,+        "y": 700,
         "wires": [         "wires": [
             [             [
-                "e8ff64c5.1ca438"+                "38565f85.6837e"
             ]             ]
         ]         ]
     },     },
     {     {
-        "id": "e85a41df.97796",+        "id": "65cbf7fe.7357d8", 
 +        "type": "link out", 
 +        "z": "bf63e9a3.a5b928", 
 +        "name": "", 
 +        "links": [ 
 +            "49762568.343b6c" 
 +        ], 
 +        "x": 495, 
 +        "y": 100, 
 +        "wires": [] 
 +    }, 
 +    { 
 +        "id": "924e62cc.f20bf",
         "type": "csv",         "type": "csv",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "name": "Преобразование 2-й секции", +        "name": "Преобразование в текст", 
-        "sep": "\\t",+        "sep": ",",
         "hdrin": "",         "hdrin": "",
         "hdrout": "none",         "hdrout": "none",
         "multi": "one",         "multi": "one",
         "ret": "\\r\\n",         "ret": "\\r\\n",
-        "temp": "name,response",+        "temp": "string",
         "skip": "0",         "skip": "0",
         "strings": true,         "strings": true,
         "include_empty_strings": "",         "include_empty_strings": "",
         "include_null_values": "",         "include_null_values": "",
-        "x": 180, +        "x": 430, 
-        "y": 760,+        "y": 520, 
 +        "wires": [ 
 +            [ 
 +                "6d923a0c.dfcda4" 
 +            ] 
 +        ] 
 +    }, 
 +    { 
 +        "id": "dd59e694.b8b688", 
 +        "type": "split", 
 +        "z": "bf63e9a3.a5b928", 
 +        "name": "Разделение пос-и", 
 +        "splt": "\\n", 
 +        "spltType": "str", 
 +        "arraySplt": 1, 
 +        "arraySpltType": "len", 
 +        "stream": false, 
 +        "addname": "", 
 +        "x": 430, 
 +        "y": 400,
         "wires": [         "wires": [
             [             [
-                "f78e87bf.8fa918"+                "15fa5ef7.8a6351", 
 +                "5a977cdd.89d1a4"
             ]             ]
         ]         ]
     },     },
     {     {
-        "id": "bd70494f.de36c8",+        "id": "5a977cdd.89d1a4",
         "type": "change",         "type": "change",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "name": "Подготовка параметров запроса",+        "name": "Подготовка свойств",
         "rules": [         "rules": [
             {             {
                 "t": "set",                 "t": "set",
-                "p": "topic",+                "p": "parts.id",
                 "pt": "msg",                 "pt": "msg",
-                "to": "\"UPDATE nw_status SET sent = \" & setsendstatus & \" WHERE _id = \" & payload._id",+                "to": "payload.status", 
 +                "tot": "msg" 
 +            }, 
 +            { 
 +                "t": "set", 
 +                "p": "parts.count", 
 +                "pt": "msg", 
 +                "to": "parts.id = \"alive\" ? result.alive : parts.id = \"dead\" ? result.dead : parts.id = \"revived\" ? result.revived : parts.id = \"died\" ? result.died", 
 +                "tot": "jsonata" 
 +            }, 
 +            { 
 +                "t": "delete", 
 +                "p": "parts.index", 
 +                "pt": "msg" 
 +            }, 
 +            { 
 +                "t": "set", 
 +                "p": "payload.string", 
 +                "pt": "msg", 
 +                "to": "( payload.response = false ? \"∞\" : payload.response ) & \" мс (\" & ( $exists( payload.count ) = false ? 0 : payload.count ) & \") - \" & payload.name & \" (\" & payload.host & \")\"",
                 "tot": "jsonata"                 "tot": "jsonata"
             }             }
Строка 706: Строка 931:
         "to": "",         "to": "",
         "reg": false,         "reg": false,
-        "x": 660, +        "x": 160, 
-        "y": 1000,+        "y": 460,
         "wires": [         "wires": [
             [             [
-                "d5126915.e6c4f8"+                "3e710520.472cea"
             ]             ]
         ]         ]
     },     },
     {     {
-        "id": "a37420b1.59473", +        "id": "3e710520.472cea", 
-        "type": "sqlite",+        "type": "join",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "mydb": "2bc4c6d.cf1f03a", +        "name": "Группировка по статусу", 
-        "sqlquery": "fixed", +        "mode": "auto", 
-        "sql": "SELECT _id, name FROM nw_status WHERE sent = true AND response > 0", +        "build": "string", 
-        "name": "Выборка: у-ва с предупреждениями", +        "property": "payload", 
-        "x": 650, +        "propertyType": "msg", 
-        "y": 340,+        "key": "topic", 
 +        "joiner": "\\n", 
 +        "joinerType": "str", 
 +        "accumulate": false, 
 +        "timeout": "", 
 +        "count": "", 
 +        "reduceRight": false, 
 +        "reduceExp": "", 
 +        "reduceInit": "", 
 +        "reduceInitType": "", 
 +        "reduceFixup": "", 
 +        "x": 410, 
 +        "y": 460,
         "wires": [         "wires": [
             [             [
-                "9dc64396.a2ca2"+                "5f8d8b50.4b7204"
             ]             ]
-        ]+        ], 
 +        "info": "Создает до двух отдельных сообщений в зависимости от статуса -- отвечает устройство или нет."
     },     },
     {     {
-        "id": "666b7178.3bf08", +        "id": "5f8d8b50.4b7204", 
-        "type": "split",+        "type": "change",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "name": "Разделение массива", +        "name": "Подготовка нагрузки", 
-        "splt": "\\n", +        "rules": [ 
-        "spltType": "str", +            { 
-        "arraySplt": 1, +                "t": "set", 
-        "arraySpltType": "len", +                "p": "payload", 
-        "stream": false, +                "pt": "msg", 
-        "addname": "", +                "to": "$type( payload[0].response ) = \"number\" ? $sort( payload, function( $l, $r ) { $l.response < $r.response } ) : payload", 
-        "x": 700, +                "tot": "jsonata" 
-        "y": 940,+            }, 
 +            { 
 +                "t": "set", 
 +                "p": "result.status", 
 +                "pt": "msg", 
 +                "to": "payload[0].status", 
 +                "tot": "msg" 
 +            } 
 +        ], 
 +        "action": "", 
 +        "property": "", 
 +        "from": "", 
 +        "to": "", 
 +        "reg": false, 
 +        "x": 160, 
 +        "y": 520,
         "wires": [         "wires": [
             [             [
-                "bd70494f.de36c8"+                "924e62cc.f20bf"
             ]             ]
         ]         ]
     },     },
     {     {
-        "id": "14e6ce78.52a912", +        "id": "15fa5ef7.8a6351",
-        "type": "sqlite", +
-        "z": "bf63e9a3.a5b928", +
-        "mydb": "2bc4c6d.cf1f03a", +
-        "sqlquery": "fixed", +
-        "sql": "SELECT _id, name FROM nw_status WHERE response = false", +
-        "name": "Выборка: у-во не отвечает", +
-        "x": 180, +
-        "y": 580, +
-        "wires": [ +
-            [ +
-                "2224cda9.8a42a2" +
-            ] +
-        ] +
-    }, +
-    { +
-        "id": "d70537c9.e5d708",+
         "type": "switch",         "type": "switch",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "name": "Отсечка пустых сообщений",+        "name": "Фильтрация статусов",
         "property": "payload",         "property": "payload",
         "propertyType": "msg",         "propertyType": "msg",
         "rules": [         "rules": [
             {             {
-                "t": "nempty"+                "t": "jsonata_exp", 
 +                "v": "payload.status = \"died\" or payload.status = \"revived\"", 
 +                "vt": "jsonata"
             }             }
         ],         ],
Строка 780: Строка 1019:
         "repair": false,         "repair": false,
         "outputs": 1,         "outputs": 1,
-        "x": 680, +        "x": 700, 
-        "y": 460,+        "y": 400,
         "wires": [         "wires": [
             [             [
-                "666b7178.3bf08", +                "663cca43.d8dff4"
-                "a5ae845b.949b08"+
             ]             ]
         ]         ]
     },     },
     {     {
-        "id": "8eab3c0.f34e6c8",+        "id": "a07661e9.dc5b5", 
 +        "type": "sqlite", 
 +        "z": "bf63e9a3.a5b928", 
 +        "mydb": "2bc4c6d.cf1f03a", 
 +        "sqlquery": "msg.topic", 
 +        "sql": "", 
 +        "name": "Запись статусов", 
 +        "x": 710, 
 +        "y": 520, 
 +        "wires": [ 
 +            [] 
 +        ] 
 +    }, 
 +    { 
 +        "id": "663cca43.d8dff4",
         "type": "change",         "type": "change",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "name": "Метка: установить статус отправки",+        "name": "Подготовка изменений",
         "rules": [         "rules": [
             {             {
                 "t": "set",                 "t": "set",
-                "p": "setsendstatus",+                "p": "topic",
                 "pt": "msg",                 "pt": "msg",
-                "to": "true", +                "to": "\"UPDATE \"& $flowContext( \"settings.table\" ) & \" SET sent = \" & ( ( payload.status = \"died\" and payload.sent = 0 ) ? 1 : ( payload.status = \"revived\" and payload.sent = 1 ) ? 0 ) & \" WHERE _id = \" & payload._id", 
-                "tot": "bool"+                "tot": "jsonata"
             }             }
         ],         ],
Строка 808: Строка 1060:
         "to": "",         "to": "",
         "reg": false,         "reg": false,
-        "x": 210, +        "x": 690, 
-        "y": 520,+        "y": 460,
         "wires": [         "wires": [
             [             [
-                "d70537c9.e5d708"+                "a07661e9.dc5b5"
             ]             ]
         ]         ]
     },     },
     {     {
-        "id": "9dc64396.a2ca2", +        "id": "71abee18.7fdf4", 
-        "type": "change",+        "type": "switch",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "name": "Метка: снять статус отправки",+        "name": "Фильтрация изменений", 
 +        "property": "payload", 
 +        "propertyType": "msg",
         "rules": [         "rules": [
             {             {
-                "t": "set", +                "t": "jsonata_exp", 
-                "p": "setsendstatus", +                "v": "( result.revived > 0 or result.died > 0 ) or ( result.dead > 0 and periodical = true)", 
-                "pt": "msg", +                "vt": "jsonata"
-                "to": "false", +
-                "tot": "bool"+
             }             }
         ],         ],
-        "action": "", +        "checkall": "false", 
-        "property": "", +        "repair": false, 
-        "from": "", +        "outputs": 1, 
-        "to": "", +        "x": 170,
-        "reg": false, +
-        "x": 670,+
         "y": 400,         "y": 400,
         "wires": [         "wires": [
             [             [
-                "d70537c9.e5d708"+                "dd59e694.b8b688"
             ]             ]
         ]         ]
     },     },
     {     {
-        "id": "cdb27b4e.0e8408", +        "id": "6d923a0c.dfcda4", 
-        "type": "trigger",+        "type": "change",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "name": "Отбрасывание лишних сообщений", +        "name": "Сохранение текста", 
-        "op1": "", +        "rules": [ 
-        "op2": "", +            { 
-        "op1type": "nul", +                "t": "set", 
-        "op2type": "date", +                "p": "status.texts", 
-        "duration": "10", +                "pt": "flow", 
-        "extend": false, +                "to": "$merge( [ $flowContext( \"status.texts\" ), { $.result.status : payload } ] )", 
-        "overrideDelay": false, +                "tot": "jsonata" 
-        "units": "s", +            } 
-        "reset": "", +        ], 
-        "bytopic": "all", +        "action": "", 
-        "topic": "topic", +        "property": "", 
-        "outputs": 1, +        "from": "", 
-        "x": 650, +        "to": "", 
-        "y": 280,+        "reg": false, 
 +        "x": 160, 
 +        "y": 580,
         "wires": [         "wires": [
             [             [
-                "a37420b1.59473"+                "2fb8a144.23e9ee"
             ]             ]
         ]         ]
     },     },
     {     {
-        "id": "251fd244.6bc71e",+        "id": "2fb8a144.23e9ee",
         "type": "trigger",         "type": "trigger",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "name": "Отбрасывание лишних сообщений",+        "name": "Ожидание всех частей",
         "op1": "",         "op1": "",
-        "op2": "",+        "op2": "true",
         "op1type": "nul",         "op1type": "nul",
-        "op2type": "date", +        "op2type": "bool", 
-        "duration": "10", +        "duration": "2", 
-        "extend": false,+        "extend": true,
         "overrideDelay": false,         "overrideDelay": false,
         "units": "s",         "units": "s",
Строка 885: Строка 1137:
         "topic": "topic",         "topic": "topic",
         "outputs": 1,         "outputs": 1,
-        "x": 210, +        "x": 430, 
-        "y": 400,+        "y": 580,
         "wires": [         "wires": [
             [             [
-                "f22d9840.db3838"+                "13bfd89.8a76c27"
             ]             ]
         ]         ]
     },     },
     {     {
-        "id": "a5ae845b.949b08", +        "id": "13bfd89.8a76c27",
-        "type": "switch", +
-        "z": "bf63e9a3.a5b928", +
-        "name": "Выбор пути", +
-        "property": "setsendstatus", +
-        "propertyType": "msg", +
-        "rules": [ +
-            { +
-                "t": "true" +
-            }, +
-            { +
-                "t": "false" +
-            } +
-        ], +
-        "checkall": "false", +
-        "repair": false, +
-        "outputs": 2, +
-        "x": 690, +
-        "y": 520, +
-        "wires": [ +
-            [ +
-                "14e6ce78.52a912" +
-            ], +
-            [ +
-                "2224cda9.8a42a2" +
-            ] +
-        ] +
-    }, +
-    { +
-        "id": "f78e87bf.8fa918",+
         "type": "change",         "type": "change",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "name": "Установка первой строки тела",+        "name": "Подготовка письма",
         "rules": [         "rules": [
             {             {
-                "t": "change", +                "t": "set", 
-                "p": "setsendstatus",+                "p": "topic",
                 "pt": "msg",                 "pt": "msg",
-                "from": "true", +                "to": "( periodical = true ? \"Сводка системы мониторинга от \" : \"Уведомление системы мониторинга от \" ) & $now( '[H01]:[m01]:[s01] [D01].[M01].[Y0001]', '+1000' ) & \"!\"", 
-                "fromt": "bool", +                "tot": "jsonata"
-                "to": "Устройства перестали отвечать", +
-                "tot": "str"+
             },             },
             {             {
-                "t": "change", +                "t": "set", 
-                "p": "setsendstatus",+                "p": "payload",
                 "pt": "msg",                 "pt": "msg",
-                "from": "false", +                "to": "( $exists( $flowContext( \"status.texts.revived\" ) ) = true ? \"Устройства начали отвечать:\\n\" ) & ( $exists( $flowContext( \"status.texts.revived\" ) ) = true ? ( $flowContext( \"status.texts.revived\" ) & \"\\n\" ) ) & ( $exists( $flowContext( \"status.texts.died\" ) ) = true ? \"Устройства перестали отвечать: \\n\" ) & ( $exists( $flowContext( \"status.texts.died\" ) ) = true ? ( $flowContext( \"status.texts.died\" ) & \"\\n\" ) ) & ( $exists( $flowContext( \"status.texts.dead\" ) ) = true ? \"Устройства не отвечают:\\n\" ) & ( $exists( $flowContext( \"status.texts.dead\" ) ) = true ? ( $flowContext( \"status.texts.dead\" ) & \"\\n\" ) ) & ( $exists( $flowContext( \"status.texts.alive\" ) ) = true ? \"Диагностические данные:\\n\" ) & ( $exists( $flowContext( \"status.texts.alive\" ) ) = true ? $flowContext( \"status.texts.alive\" ) )", 
-                "fromt": "bool", +                "tot": "jsonata" 
-                "to": "Устройства начали отвечать", +            }, 
-                "tot": "str"+            { 
 +                "t": "delete", 
 +                "p": "status.texts", 
 +                "pt": "flow"
             }             }
         ],         ],
Строка 952: Строка 1176:
         "to": "",         "to": "",
         "reg": false,         "reg": false,
-        "x": 470, +        "x": 700, 
-        "y": 760,+        "y": 580,
         "wires": [         "wires": [
             [             [
-                "a91d85a7.c844f8"+                "2aa2153.fed7bea"
             ]             ]
         ]         ]
     },     },
     {     {
-        "id": "e8ff64c5.1ca438", +        "id": "172accf.e425333", 
-        "type": "switch",+        "type": "inject",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "name": "Фильтрация пустой нагрузки", +        "name": "Запустить и сбросить метку", 
-        "property": "payload", +        "props": [], 
-        "propertyType": "msg", +        "repeat": "", 
-        "rules": [+        "crontab": "", 
 +        "once": false, 
 +        "onceDelay": "1", 
 +        "topic": "", 
 +        "payloadType": "str", 
 +        "x": 180, 
 +        "y": 40, 
 +        "wires": [ 
 +            [ 
 +                "6ccc324d.f380bc" 
 +            ] 
 +        ], 
 +        "info": "Сбросить метку `flow.status.run` и запустить поток. Полезно при сбоях, когда цепочка повисла в режиме ожидания." 
 +    }, 
 +    { 
 +        "id": "d45c7cea.9b2c4", 
 +        "type": "inject", 
 +        "z": "bf63e9a3.a5b928", 
 +        "name": "Периодическая сводка", 
 +        "props": [
             {             {
-                "t": "empty"+                "p": "topic", 
 +                "v": "\"SELECT _id, name, host, response, sent, cycles FROM \\\"\" & $flowContext( \"settings.table\" ) & \"\\\"\"", 
 +                "vt": "jsonata"
             },             },
             {             {
-                "t": "else"+                "p": "periodical", 
 +                "v": "true", 
 +                "vt": "bool"
             }             }
         ],         ],
-        "checkall": "false", +        "repeat": "21600", 
-        "repair": false, +        "crontab": "", 
-        "outputs": 2, +        "once": true, 
-        "x": 190,+        "onceDelay": "60", 
 +        "topic": "", 
 +        "payloadType": "str", 
 +        "x": 170, 
 +        "y": 640, 
 +        "wires": [ 
 +            [ 
 +                "994ffc21.74839" 
 +            ] 
 +        ], 
 +        "info": "Отправляется только, если есть \"мертвые\" устройства." 
 +    }, 
 +    { 
 +        "id": "994ffc21.74839", 
 +        "type": "sqlite", 
 +        "z": "bf63e9a3.a5b928", 
 +        "mydb": "2bc4c6d.cf1f03a", 
 +        "sqlquery": "msg.topic", 
 +        "sql": "", 
 +        "name": "Выборка устройств", 
 +        "x": 440, 
 +        "y": 640, 
 +        "wires": [ 
 +            [ 
 +                "f97471ca.36e7d" 
 +            ] 
 +        ] 
 +    }, 
 +    { 
 +        "id": "f97471ca.36e7d", 
 +        "type": "split", 
 +        "z": "bf63e9a3.a5b928", 
 +        "name": "Разделение пос-и", 
 +        "splt": "\\n", 
 +        "spltType": "str", 
 +        "arraySplt": 1, 
 +        "arraySpltType": "len", 
 +        "stream": false, 
 +        "addname": "", 
 +        "x": 150,
         "y": 700,         "y": 700,
         "wires": [         "wires": [
             [             [
-                "ba2d5855.7ea038" +                "a11064c5.7b4778" 
-            ],+            ] 
 +        ] 
 +    }, 
 +    { 
 +        "id": "f9033d4c.c67e1", 
 +        "type": "link in", 
 +        "z": "bf63e9a3.a5b928", 
 +        "name": "", 
 +        "links": [ 
 +            "d76d9726.edb0b8" 
 +        ], 
 +        "x": 75, 
 +        "y": 340, 
 +        "wires": [
             [             [
-                "e85a41df.97796"+                "8961f0c.35b121"
             ]             ]
         ]         ]
     },     },
     {     {
-        "id": "ba2d5855.7ea038",+        "id": "d76d9726.edb0b8", 
 +        "type": "link out", 
 +        "z": "bf63e9a3.a5b928", 
 +        "name": "", 
 +        "links": [ 
 +            "f9033d4c.c67e1" 
 +        ], 
 +        "x": 495, 
 +        "y": 700, 
 +        "wires": [] 
 +    }, 
 +    { 
 +        "id": "a11064c5.7b4778",
         "type": "change",         "type": "change",
         "z": "bf63e9a3.a5b928",         "z": "bf63e9a3.a5b928",
-        "name": "Сообщение о пустой нагрузке",+        "name": "Подготовка св-в",
         "rules": [         "rules": [
             {             {
                 "t": "set",                 "t": "set",
-                "p": "payload",+                "p": "payload.response",
                 "pt": "msg",                 "pt": "msg",
-                "to": "Ни одно устройство не отвечает!", +                "to": "payload.response = 0 ? false : payload.response", 
-                "tot": "str"+                "tot": "jsonata" 
 +            }, 
 +            { 
 +                "t": "move", 
 +                "p": "payload.cycles", 
 +                "pt": "msg", 
 +                "to": "payload.count", 
 +                "tot": "msg"
             }             }
         ],         ],
Строка 1008: Строка 1326:
         "to": "",         "to": "",
         "reg": false,         "reg": false,
-        "x": 510,+        "x": 350,
         "y": 700,         "y": 700,
         "wires": [         "wires": [
             [             [
-                "f78e87bf.8fa918"+                "d76d9726.edb0b8"
             ]             ]
         ]         ]
Последнее изменение: 2022/02/12 11:40 (внешнее изменение)

Инструменты страницы

Если не указано иное, содержимое этой вики предоставляется на условиях следующей лицензии: CC Attribution-Share Alike 4.0 International