Espruino:Примеры/BLE и Node-RED с MQTT

Материал из Онлайн справочника
< Espruino:Примеры
Версия от 20:06, 23 мая 2023; EducationBot (обсуждение | вклад)
(разн.) ← Предыдущая версия | Текущая версия (разн.) | Следующая версия → (разн.)
Перейти к навигацииПерейти к поиску

Перевод: Максим Кузьмин
Проверка/Оформление/Редактирование: Мякишев Е.А.


BLE и Node-RED с MQTT [1]

Простейший способ начать работать с Puck.js и [1]] – это воспользоваться программой EspruinoHub на Raspberry Pi. Она будет служить мостиком между Bluetooth Low Energy и MQTT.

Инструкции по установке и настройке EspruinoHub читайте по этой ссылке.

С чего начать

Установив сервер, подключаемся к Node-RED при помощи HTTP-порта. Например, вот так: «http://raspberry:1880».

Чтобы начать получение MQTT-пакетов:

  • Перетяните в рабочую область входную ноду «mqtt» и выходную ноду «debug», а затем подключите их друг к другу
  • Дважды кликните по ноде «mqtt» и:
    • Убедитесь, что в Server стоит localhost:1883 (при первом использовании Node-RED вам нужно будет добавить новый сервер)
    • Убедитесь, что в Topic стоит /ble/#. Здесь # – это wildcard-символ MQTT
  • Теперь кликните на Deploy справа вверху
  • Убедитесь, что кнопка справа от ноды «debug» имеет ярко зелёный цвет
  • Кликните на кнопку с тремя полосками справа вверху, а затем на View > Debug messages

Теперь в окне Debug начнут генерироваться сообщения с объявлениями:

Если также вписать в код для Puck.js функцию NRF.setAdvertising(), то информация, заданная в этой функции, тоже будет показана сообщениях, генерируемых в окне Debug.

Минимизация рассылаемой информации

Часто вам не нужна вся рассылаемая информация, но её можно минимизировать, отредактировав поле Topic во входной ноде «mqtt».

В моём случае это «/ble/advertise/e7:e0:57:ad:36:a2/rssi» (см. вкладку Debug). Это означает, что я получаю информацию о мощности сигнала (RSSI) пакетов, рассылаемых от Puck.js с адресом «e7:e0:57:ad:36:a2».

Чтобы прослушивать все сообщения от «e7:e0:57:ad:36:a2», можно воспользоваться «/ble/advertise/e7:e0:57:ad:36:a2/#», но поскольку мне интересен только RSSI, я оставлю прежний вариант. Поменяйте адрес на тот, что был показан у вас в окне Debug.

Теперь, если нажать Deploy, можно увидеть, что на вкладке Debug будет появляться только RSSI.

Создание графиков данных

Если вы следовали инструкциям для EspruinoHub, то также должны были установить библиотеку для UI.

  • Переместите в рабочую область ноду «chart» из раздела «ui»
  • Подключите её к ноде «mqtt»
  • Дважды кликните по ней и дайте ей какое-нибудь название
  • Теперь кликните на Deploy
  • Теперь, если перейти в браузере по ссылке «http://raspberry:1880/ui», вы увидите график. Чем больше виджетов из «ui» вы добавите в поток Node-RED, тем больше элементов будет в этом окне с графиком

Использование данных

Теперь мы можем воспользоваться этой информацией о мощности сигнала, чтобы выполнить какое-нибудь действие, когда Puck.js приблизится к нам на определённое расстояние (что также изменит мощность сигнала).

  • Найдите подходящее RSSI-значение в сообщениях из вкладки Debug. Помните, что это отрицательное число!
  • Переместите в рабочую область ноду «function», дважды кликните по ней и вставьте в неё код ниже, но замените «-70» на собственное RSSI-значение:
msg.payload = msg.payload > -70;
return msg;
  • Подключите эту ноду между нодами «mqtt» и «debug». Чтобы удалить связь между нодами, кликните на неё и нажмите Delete.
  • Кликните на Deploy. Теперь вместо чисел будут булевы значения – когда Puck.js приблизится на определённое расстояние, значение изменится на true.
  • RSSI-данные могут сильно колебаться, но их можно сгладить при помощи функции «smooth»:

Выполнение действий с помощью получаемых данных

Кроме того, имея какие-либо данные, мы можем с их помощью выполнить какое-нибудь действие. Если вы используете Raspberry Pi, то можете перетянуть в рабочую область ноду «rpi gpio» – с её помощью можно менять состояние GPIO-контакта на значение «true», которое мы получили, обработав RSSI-значение.

Или же мы можем отправить электронное письмо, воспользовавшись нодой «email». Но проблема в том, что вы вряд ли захотите отправлять имейл несколько раз в секунду. Как правило, необходимость сделать что-либо появляется только при изменении состояния с одного на другое.

Для этого вам понадобится нода «rbe» (от англ. «Report By Exception», что можно перевести как «сообщить об исключительной ситуации»). Она будет пропускать сообщения дальше по потоку, только если новое значение отличается от предыдущих.

Определение нажатия на кнопку

Puck.js оснащён кнопкой, поэтому очевидно, что мы можем использовать нажатия на неё для активации каких-либо действий. Мы не можем гарантировать получение абсолютно всех пакетов объявлений, отправляемых Puck.js, так что нам нужно будет найти какой-то безошибочный способ определения того, была ли нажата кнопка или нет.

Самый простой – это отправлять число, которое будет увеличиваться с каждым нажатием на кнопку. То есть, если даже какие-то пакеты будут утеряны, EspruinoHub по-прежнему сможет определять нажатия на кнопку, видя изменение в соответствующем значении.

Вот код для Puck.js, с помощью которого это можно сделать: 

var pressCount = 0;
setWatch(function() {
  pressCount++;
  NRF.setAdvertising({
    0xFFFF : [pressCount]
  });
}, BTN, { edge:"rising", repeat:true, debounce:50 });

Вместо 0xFFFF можно задать абсолютно любое (даже случайное) значение.

После этого вы можете воспользоваться нодой «rbe», чтобы определить момент изменения значения. Например:

В примере выше нода «show toast» будет просто показывать баннер на UI-странице. Этот способ можно использовать для определения любых событий, а не только нажатий на кнопку.

Определение наличия устройства

Мы также можем определять появление и исчезновение (другими словами, отсутствие от него объявлений в течение одной минуты) маяка.

Просто подпишитесь на MQTT-топик «/ble/presence/ад:рес:уст:рой:ст:ва» и будете получать «1» при появлении маяка и «0» при его исчезновении.

Управление Puck.js

Следующий шаг – это отправка сообщения на Puck.js при возникновении какого-то события.

В этот раз мы добавим пару кнопок для запуска событий:

  • Добавляем две ноды «inject»
  • Дважды кликаем по одной из них и задаем в Payload код LED1.set();
  • Дважды кликаем по второй и задаем в Payload код LED1.reset();
  • Добавляем ноду «function» и подключаем к ней обе ноды «inject»
  • Дважды кликаем по ней и пишем в ней код ниже. Он добавит в отправляемые команды символ новой строки (чтобы Puck.js понимал, где заканчивается команда).
msg.payload += "\n";
return msg;
  • Наконец, добавляем выходную ноду «mqtt» и задаем в поле Topic значение «/ble/write/e7:e0:57:ad:36:a2/nus/nus_tx», где «e7:e0:57:ad:36:a2» – это адрес вашего устройства.

Всё, готово, осталось только кликнуть на Deploy. Теперь, нажимая на кнопки, вы будете включать и выключать светодиод. Помимо прочего, этот метод можно использовать для запуска функций, которые вы до этого задали на Puck.js.

Примечание

Топик задаётся в формате /ble/write/ад:рес:уст:рой:ст:ва/сервис/характеристика, чтобы вам не пришлось передавать данные по Nordic UART на Puck.js. Вы можете задать собственные сервисы и записывать данные напрямую в них. В этом случае формат будет такой:

  • 6e400001b5a3f393e0a9e50e24dcca9e – для 128-битных UUID
  • abcd – для 16-битных UUID

Дополнительно

При помощи модуля «node-red-contrib-ifttt» можно настроить коммуникацию между Node-RED и IFTTT:

  • Залогиньтесь в Raspberry Pi при помощи имени пользователя pi
  • Напечатайте cd .node-red
  • Напечатайте npm install node-red-contrib-ifttt
  • Перезапустите Node-RED при помощи node-red-stop, а затем node-red-start

Теперь у вас есть IFTTT-блок, который можно использовать для запуска IFTTT-событий.

См.также

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

  1. ↑ www.espruino.com -
Партнерские ресурсы
Криптовалюты
Магазины
Хостинг
Разное
Справочник по API Espruino
Глобальные методы, переменные и объекты • acceleration() • analogRead() • analogWrite() • arguments • atob() • Объект Bluetooth • btoa() • changeInterval() • clearInterval() • clearTimeout() • clearWatch() • compass() • decodeURIComponent() • digitalPulse() • digitalRead() • digitalWrite() • dump() • echo() • edit() • encodeURIComponent() • eval() • FET • getPinMode() • getSerial() • getTime() • global • HIGH • Объект I2C1 • Объект I2C2 • Объект I2C3 • Infinity • isFinite() • isNaN() • load() • Объект LoopBackA • Объект LoopBackB • LOW • NaN • parseFloat() • parseInt() • peek16() • peek32() • peek8() • pinMode() • poke16() • poke32() • poke8() • print() • require() • reset() • save() • SCL • SDA • Объект Serial1 • Объект Serial2 • Объект Serial3 • Объект Serial4 • Объект Serial5 • Объект Serial6 • setBusyIndicator() • setDeepSleep() • setInterval() • setSleepIndicator() • setTime() • setTimeout() • setWatch() • shiftOut() • show() • Объект SPI1 • Объект SPI2 • Объект SPI3 • Объект Telnet • Объект Terminal • trace() • Объект USB • VIBRATE
Класс AES • decrypt() • encrypt()
Класс Array • Array() • concat() • every() • fill() • filter() • find() • findIndex() • forEach() • includes() • indexOf() • isArray() • join() • length • map() • pop() • push() • reduce() • reverse() • shift() • slice() • some() • sort() • splice() • toString() • unshift()
Класс ArrayBuffer • ArrayBuffer() • byteLength
Класс ArrayBufferView • buffer • byteLength • byteOffset • fill() • filter() • find() • findIndex() • forEach() • includes() • indexOf() • join() • map() • reduce() • reverse() • set() • slice() • sort()
Класс Bangle • accel • accelRd() • accelWr() • aiGesture • beep() • buzz() • charging • compassWr() • dbg() • drawWidgets() • F_BEEPSET • faceUp • gesture • getAccel() • getCompass() • getLCDMode() • getLogo() • GPS • GPS-raw • HRM • ioWr() • isCharging() • isLCDOn() • lcdPower • lcdWr() • loadWidgets() • mag • off() • project() • setCompassPower() • setGPSPower() • setHRMPower() • setLCDBrightness() • setLCDMode() • setLCDOffset() • setLCDPower() • setLCDTimeout() • setOptions() • setPollInterval() • showLauncher() • step • swipe • touch • twist
Класс BluetoothDevice • connected • gatt • gattserverdisconnected • passkey • passkeyRequest • rssi • sendPasskey()
Класс BluetoothRemoteGATTCharacteristic • characteristicvaluechanged • readValue() • startNotifications() • stopNotifications() • writeValue()
Класс BluetoothRemoteGATTServer • connect() • disconnect() • getPrimaryService() • getPrimaryServices() • getSecurityStatus() • setRSSIHandler() • startBonding()
Класс BluetoothRemoteGATTService • getCharacteristic() • getCharacteristics()
Класс Boolean • Boolean()
Библиотека CC3000 • connect()
Класс Console • log()
Библиотека crypto • AES • PBKDF2() • SHA1() • SHA224() • SHA256() • SHA384() • SHA512()
Класс DataView • DavaView() • getFloat32() • getFloat64() • getInt16() • getInt32() • getInt8() • getUint16() • getUint32() • getUint8() • setFloat32() • setFloat64() • setInt16() • setInt32() • setInt8() • setUint16() • setUint32() • setUint8()
Класс Date • Date() • getDate() • getDay() • getFullYear() • getHours() • getMilliseconds() • getMinutes() • getMonth() • getSeconds() • getTime() • getTimezoneOffset() • now() • parse() • setDate() • setFullYear() • setHours() • setMilliseconds() • setMinutes() • setMonth() • setSeconds() • setTime() • toISOString() • toJSON() • toString() • toUTCString() • valueOf()
Библиотека dgram • createSocket()
Класс dgramSocket • addMembership() • bind() • Функция close() • Событие close() • message • send()
Класс E • asm() • clip() • compiledC() • connectSDCard() • convolve() • CRC32() • defrag() • dumpFragmentation() • dumpFreeList() • dumpLockedVars() • dumpStr() • dumpTimers() • dumpVariables() • enableWatchdog() • errorFlag • FFT() • flashFatFS() • getAddressOf() • getAnalogVRef() • getBattery() • getConsole() • getErrorFlags() • getFlags() • getRTCPrescaler() • getSizeOf() • getTemperature() • HSBtoRGB() • hwRand() • init • kickWatchdog() • kill • lockConsole() • lookupNoCase() • mapInPlace() • memoryArea() • memoryMap() • nativeCall() • openFile() • pipe() • reboot() • reverseByte() • sendUSBHID() • setBootCode() • setClock() • setConsole() • setFlags() • setPassword() • setRTCPrescaler() • setTimeZone() • setUSBHID() • showAlert() • showMenu() • showMessage() • showPrompt() • srand() • sum() • toArrayBuffer() • toJS() • toString() • toUint8Array() • unmountSD() • variance()
Класс Error • Error() • toString()
Библиотека ESP8266 • crc32() • deepSleep() • dumpSocketInfo() • getFreeFlash() • getResetInfo() • getState() • logDebug() • neopixelWrite() • ping() • printLog() • readLog() • reboot() • setCPUFreq() • setLog()
Класс Ethernet • getHostname() • getIP() • getStatus() • setHostname() • setIP()
Класс File • close() • pipe() • read() • seek() • skip() • write()
Библиотека Flash • erasePage() • getFree() • getPage() • read() • write()
Класс Float32Array • Float32Array()
Класс Float64Array • Float64Array()
Библиотека fs • appendFile() • appendFileSync() • mkdir() • mkdirSync() • pipe() • readdir() • readdirSync() • readFile() • readFileSync() • statSync() • unlink() • unlinkSync() • writeFile() • writeFileSync()
Класс Function • apply() • bind() • call() • Function() • replaceWith()
Класс Graphics • asBMP() • asImage() • asURL() • buffer • clear() • clearRect() • createArrayBuffer() • createCallback() • createImage() • createSDL() • drawCircle() • drawEllipse() • drawImage() • drawImages() • drawLine() • drawLineAA() • drawPoly() • drawPolyAA() • drawRect() • drawString() • dump() • fillCircle() • fillEllipse() • fillPoly() • fillRect() • flip() • getBgColor() • getColor() • getFont() • getFontHeight() • getFonts() • getHeight() • getInstance() • getModified() • getPixel() • getWidth() • lineTo() • moveTo() • quadraticBezier() • reset() • scroll() • setBgColor() • setClipRect() • setColor() • setFont() • setFontAlign() • setFontBitmap() • setFontCustom() • setFontVector() • setPixel() • setRotation() • stringWidth() • toColor() • transformVertices()
Библиотека heatshrink • compress() • decompress()
Библиотека http • createServer() • get() • request()
Класс httpCRq • drain • end() • error • write()
Класс httpCRs • available() • close • data • error • headers • httpVersion • pipe() • read() • statusCode • statusMessage
Класс httpSRq • available() • close • data • headers • method • pipe() • read() • url
Класс httpSRs • close • drain • end() • headers • setHeader() • write() • writeHead()
Класс httpSrv • close() • listen()
Класс I2C • find() • I2C() • readFrom() • setup() • writeTo()
Класс Int16Array • Int16Array()
Класс Int32Array • Int32Array()
Класс Int8Array • Int8Array()
Класс InternalError • InternalError() • toString()
Класс JSON • parse() • stringify()
Класс Math • abs() • acos() • asin() • atan() • atan2() • ceil() • clip() • cos() • E • exp() • floor() • LN10 • LN2 • log() • LOG10E • LOG2E • max() • min() • PI • pow() • random() • round() • sin() • sqrt() • SQRT1_2 • SQRT2 • tan() • wrap()
Класс Microbit • accel() • accelOff() • accelOn() • accelWr() • gesture • mag() • MIC • MIC_ENABLE • play() • record() • SPEAKER
Класс Modules • addCached() • getCached() • removeAllCached() • removeCached()
Библиотека neopixel • write()
Библиотека net • connect() • createServer()
Библиотека NetworkJS • create()
Класс NodeMCU • A0 • D0 • D1 • D2 • D3 • D4 • D5 • D6 • D7 • D8 • D9 • D10
Класс NRF • characteristicsDiscover • connect • connect() • disconnect • disconnect() • filterDevices() • findDevices() • getAddress() • getAdvertisingData() • getBattery() • getSecurityStatus() • HID • nfcAndroidApp() • NFCoff • NFCon • nfcPair() • nfcRaw() • NFCrx • nfcSend() • nfcStart() • nfcStop() • nfcURL() • requestDevice() • restart() • security • sendHIDReport() • servicesDiscover • setAddress() • setAdvertising() • setConnectionInterval() • setLowPowerConnection() • setRSSIHandler() • setScan() • setScanResponse() • setSecurity() • setServices() • setTxPower() • setWhitelist() • sleep() • updateServices() • wake()
Класс Nucleo • A0 • A1 • A2 • A3 • A4 • A5 • D0 • D1 • D2 • D3 • D4 • D5 • D6 • D7 • D8 • D9 • D10 • D11 • D12 • D13 • D14 • D15
Класс Number • MAX_VALUE • MIN_VALUE • NaN • NEGATIVE_INFINITY • Number() • POSITIVE_INFINITY • toFixed()
Класс Object • assign() • clone() • create() • defineProperties() • defineProperty() • emit() • getOwnPropertyDescriptor() • getOwnPropertyNames() • getPrototypeOf() • hasOwnProperty() • keys() • length • Object() • on() • removeAllListeners() • removeListener() • setPrototypeOf() • toString() • valueOf()
Класс OneWire • OneWire() • read() • reset() • search() • select() • skip() • write()
Класс Pin • getInfo() • getMode() • mode() • Pin() • read() • reset() • set() • toggle() • write() • writeAtTime()
Класс Pixl • getBatteryPercentage() • lcdw() • menu() • setContrast() • setLCDPower()
Класс process • env • memory() • uncaughtException • version
Класс Promise • all() • catch() • Promise() • reject() • resolve() • then()
Класс Puck • accel • accel() • accelOff() • accelOn() • accelRd() • accelWr() • capSense() • getBatteryPercentage() • getTemperature() • IR() • light() • mag() • mag • magOff() • magOn() • magRd() • magTemp() • magWr() • selfTest()
Класс ReferenceError • ReferenceError() • toString()
Класс RegExp • exec() • RegExp() • test()
Класс Serial • available() • data • find() • framing • inject() • parity • pipe() • print() • println() • read() • Serial() • setConsole() • setup() • unsetup() • write()
Класс Server • close() • listen()
Класс Socket • available() • close • data • drain • end() • error • pipe() • read() • write()
Класс SPI • find() • send() • send4bit() • send8bit() • setup() • SPI() • write()
Библиотека Storage • compact() • debug() • erase() • eraseAll() • getFree() • list() • open() • read() • readArrayBuffer() • readJSON() • write() • writeJSON()
Класс StorageFile • erase() • getLength() • read() • readLine() • write()
Класс String • charAt() • charCodeAt() • endsWith() • fromCharCode() • includes() • indexOf() • lastIndexOf() • length • match() • padEnd() • padStart() • repeat() • replace() • slice() • split() • startsWith() • String() • substr() • substring() • toLowerCase() • toUpperCase() • trim()
Класс SyntaxError • SyntaxError() • toString()
Библиотека TelnetServer • setOptions()
Библиотека tensorflow • create()
Класс TFMicroInterpreter • getInput() • getOutput() • invoke()
Библиотека tls • connect()
Библиотека tv • setup()
Класс TypeError • toString() • TypeError()
Класс Uint16Array • Uint16Array()
Класс Uint24Array • Uint24Array()
Класс Uint32Array • Uint32Array()
Класс Uint8Array • Uint8Array()
Класс Uint8ClampedArray • Uint8ClampedArray()
Класс url • parse()
Класс Waveform • startInput() • startOutput() • stop() • Waveform()
Библиотека WiFi • associated • auth_change • connect() • connected • dhcp_timeout • disconnect() • disconnected • getAPDetails() • getAPIP() • getDetails() • getHostByName() • getHostname() • getIP() • getStatus() • ping() • probe_recv • restore() • save() • scan() • setAPIP() • setConfig() • setIP() • setSNTP() • sta_joined • sta_left • startAP() • stopAP() • turbo()
Класс WioLTE • A4 • A6 • D20 • D38 • I2C • LED() • setGrovePower() • setLEDPower() • UART
Библиотека WIZnet • connect()
Класс WLAN • connect() • disconnect() • getIP() • reconnect() • setIP()

Источник — http://wikihandbk.com/ruwiki/index.php?title=Espruino:Примеры/BLE_и_Node-RED_с_MQTT&oldid=7738804