Node-RED:Рецепты/Как обрабатывать сообщения, приходящие через заданные периоды, игнорируя промежуточные сообщения

Материал из Онлайн справочника
Перейти к навигации Перейти к поиску

Перевод: Максим Кузьмин (Cubewriter) Контакты:</br>* Skype: cubewriter</br>* E-mail: cubewriter@gmail.com</br>* Максим Кузьмин на freelance.ru
Проверка/Оформление/Редактирование: Мякишев Е.А.


Pixel Art Mini Meow Animated.gif Черновик


Как обрабатывать сообщения, приходящие через заданные периоды, игнорируя промежуточные сообщения[1]

Проблема

Вам нужно обрабатывать сообщения через регулярные промежутки времени, но игнорировать сообщения, которые приходят слишком быстро. К примеру, у вас есть данные от датчика, которые приходят каждую секунду, но вам нужно обновлять данные только каждые 5 секунд. Кроме того, обрабатываемые вами данные должны быть самыми новыми.

Решение

Воспользуйтесь режимом «Rate Limit» в ноде «Delay», чтобы ограничить скорость проходящих через нее сообщений, а также активируйте у нее настройку «drop intermediate messages» («игнорировать промежуточные сообщения»).

Пример

Nodered recipe rate-limit-message-stream.png
[{"id":"8a1bcd7d.f6b67","type":"inject","z":"ac14500e.2c57d","name":"Inject Array","topic":"","payload":"[0,1,2,3,4,5,6,7,8,9]","payloadType":"json","repeat":"","crontab":"","once":false,"onceDelay":0.1,"x":110,"y":1380,"wires":[["bd4bdd42.bd1b"]]},{"id":"bd4bdd42.bd1b","type":"delay","z":"ac14500e.2c57d","name":"","pauseType":"rate","timeout":"5","timeoutUnits":"seconds","rate":"1","nbRateUnits":"5","rateUnits":"second","randomFirst":"1","randomLast":"5","randomUnits":"seconds","drop":true,"x":320,"y":1380,"wires":[["be20c513.237c78"]]},{"id":"be20c513.237c78","type":"debug","z":"ac14500e.2c57d","name":"Debug","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"payload","targetType":"msg","x":510,"y":1380,"wires":[]}]

Разбор

Изменить скорость сообщений, проходящих через поток, можно при помощи режима «Rate Limit» в ноде «Delay». Если также поставить в ее настройках галочку рядом с пунктом «drop intermediate messages», она будет игнорировать все сообщения, приходящие во время заданного интервала.

См.также

Внешние ссылки