2020年12月4日星期五

Using the rbe (report by exception) node & Scaling input with the range node

To test the flow, deploy this flow and then return to the HiveMQ page and send a series of messages. Firstly, you’ll need to set the analyze value to true so that the switch node sends through a message on output 1. If you use the original message value of 6, this will fail to pass the rbe node. If you then send a second message of value 10, the rbe node will evaluate the difference between 6 and 10, see it is greater than 20%, and send on a message to the final debug node

{"analyze": true , "value": 10 }

{"analyze": true , "value": 5 }

5 , 10 greater than 20%,

Let’s assume you want to scale your value (originally in the range 0-10) to a range (0-255) when you aren’t doing any analysis. This means we are dealing with the lower part of the flow fired when the switch node evaluates the Analyze property as false.

Then return to the HiveMQ test page and post {“analyze”:false, “value”:10} as a new MQTT message to the same topic.

{"analyze": false , "value": 10 }

{"analyze": false , "value": 5 }

Using the switch node to handle a JSON object

利用開關節點處理Json物件

If you now go back to the HiveMQ input page and send the MQTT message {“analyze”:true, “value”:6}, you will see that the first (top) output is activated and the incoming messages is routed, or ‘switched’, to output 1. If you send the original message {“analyze”:false, “value”:10}, the switch node will activate output 2 and the original debug node will fire.

{"analyze": false , "value":70}

http://www.hivemq.com/demos/websocket-client/

{"analyze": true , "value": 20}

http://www.hivemq.com/demos/websocket-client/

2020年12月3日星期四

Receiving a JSON object via MQTT messaging / Sending a JSON object via MQTT to Node-Red

接收http://www.hivemq.com/demos/websocket-client/ 來的Json資料, 發送Json資料給http://www.hivemq.com/demos/websocket-client

Node-Red 上收 hivemq 資料

alex9ufo/sensor1/outTopic

broker.mqtt-dashboard.com Port:1883

hivemq上收 Node-Red 資料

alex9ufo/sensor2/inTop

http://www.hivemq.com/demos/websocket-client/

broker.mqttdashboard.com port:8000

2020年12月1日星期二

以Windows安裝Node-RED 及dashboard UI 節點 SQLite 節點

以Windows安裝Node-RED

1.先到Node.js https://nodejs.org/dist./v12.18.3/ 下載LTS版

x64.msi 與 x86.msi 版本太新node-red會有問題

Index of /dist./v12.18.3/

../
docs/                                              22-Jul-2020 15:34                   -
win-x64/                                           22-Jul-2020 15:21                   -
win-x86/                                           22-Jul-2020 15:20                   -
SHASUMS256.txt                                     22-Jul-2020 16:55                3147
SHASUMS256.txt.asc                                 22-Jul-2020 16:55                4029
SHASUMS256.txt.sig                                 22-Jul-2020 16:55                 566
node-v12.18.3-aix-ppc64.tar.gz                     22-Jul-2020 14:56            32361031
node-v12.18.3-darwin-x64.tar.gz                    22-Jul-2020 15:51            20889560
node-v12.18.3-darwin-x64.tar.xz                    22-Jul-2020 15:52            13790280
node-v12.18.3-headers.tar.gz                       22-Jul-2020 15:34              555440
node-v12.18.3-headers.tar.xz                       22-Jul-2020 15:34              366264
node-v12.18.3-linux-arm64.tar.gz                   22-Jul-2020 14:57            23059455
node-v12.18.3-linux-arm64.tar.xz                   22-Jul-2020 14:59            13914756
node-v12.18.3-linux-armv7l.tar.gz                  22-Jul-2020 15:01            21253435
node-v12.18.3-linux-armv7l.tar.xz                  22-Jul-2020 15:01            12505784
node-v12.18.3-linux-ppc64le.tar.gz                 22-Jul-2020 15:01            23224873
node-v12.18.3-linux-ppc64le.tar.xz                 22-Jul-2020 15:02            13856940
node-v12.18.3-linux-s390x.tar.gz                   22-Jul-2020 15:00            23529229
node-v12.18.3-linux-s390x.tar.xz                   22-Jul-2020 15:01            13972340
node-v12.18.3-linux-x64.tar.gz                     22-Jul-2020 15:00            23185868
node-v12.18.3-linux-x64.tar.xz                     22-Jul-2020 15:01            14700900
node-v12.18.3-sunos-x64.tar.gz                     22-Jul-2020 15:38            27414512
node-v12.18.3-sunos-x64.tar.xz                     22-Jul-2020 15:39            16893888
node-v12.18.3-win-x64.7z                           22-Jul-2020 15:22            10797087
node-v12.18.3-win-x64.zip                          22-Jul-2020 15:22            18743597
node-v12.18.3-win-x86.7z                           22-Jul-2020 15:21             9732315
node-v12.18.3-win-x86.zip                          22-Jul-2020 15:21            17223625
node-v12.18.3-x64.msi                              22-Jul-2020 15:22            19763200
node-v12.18.3-x86.msi                              22-Jul-2020 15:21            18153472
node-v12.18.3.pkg                                  22-Jul-2020 16:09            21183432
node-v12.18.3.tar.gz                               22-Jul-2020 15:27            52449074
node-v12.18.3.tar.xz                               22-Jul-2020 15:32            23679596

2.執行後一路下一步

https://ithelp.ithome.com.tw/upload/images/20181016/20112219NdAuwQwW0N.png

3.確認Node.Js與NPM版本

4.輸入 npm install -g --unsafe-perm node-red 安裝Node-RED

https://ithelp.ithome.com.tw/upload/images/20181016/20112219R2UY4wxHiB.png

5.輸入node-red啟動Node-RED

https://ithelp.ithome.com.tw/upload/images/20181016/20112219qYt2zzQqBS.png

或是在C碟中搜尋node-red 並將捷徑放到桌面直接用滑鼠啟動

6.啟動瀏覽器輸入127.0.0.1:1880

https://ithelp.ithome.com.tw/upload/images/20181016/20112219PvSQ9Mus5k.png

即可使用Node-RED

7.安裝節點 dashboard

進入安裝輸入 dashboard 選擇node-red-dashboard

8.安裝節點 SQLite

輸入 sqlite 選擇node-red-node-sqlite

9.匯入 node-red RFID 2-2程式

http://alex9ufoexploer.blogspot.com/2020/10/rfid-2-2-node-red-mqtt-esp32-mfrc522.html

找到 5. Node-Red 程式下載

載點

http://www.mediafire.com/file/evkbrlxet6f3hyz/flows_RFID%25E8%25AE%2580%25E5%258F%2596.json/file

可以用wordpad 打開檔案 (Json檔案)

匯入所選檔案

重新部署

配合硬體進入127.0.0.1:1880/ui 使用者介面控制 ESP32

2020年11月30日星期一

Reading data from a SQL Database Using Node-Red (讀取SQLite資料庫內容)

源自於 http://www.steves-internet-guide.com/storing-iot-data-sql-database/

1.Convert time

//var payload=msg.payload;

for (var i=0;i<msg.payload.length;i++)

{

dateObj = new Date(msg.payload[i].TIMESTAMP);

var date=dateObj.getDate();

var month=dateObj.getMonth()+1;

var year=dateObj.getFullYear();

var hours=dateObj.getHours();

var minutes=dateObj.getMinutes();

var seconds=dateObj.getSeconds();

var newtime=date+"/"+month+"/"+year;

newtime=newtime+"-"+hours+":"+minutes+":"+seconds;

msg.payload[i].TIMESTAMP=newtime

}

return msg;

2. 函數

var data=context.get('data')|| {value:"",condition:">="};

var topic=msg.topic;

var payload=msg.payload;

if (topic=="site")

data.site=msg.payload;

if (topic=="value")

data.value=msg.payload;

if (topic=="condition")

data.condition=msg.payload;

if (topic=="sdate")

data.sdate=msg.payload;

if (topic=="edate")

data.edate=msg.payload;

var d=new Date();

now=d.getTime();

if (data.edate==undefined || data.edate=="")

edate=now;

else

edate=data.edate;

if (data.sdate==undefined || data.sdate=="")

sdate=0;

else

sdate=data.sdate;

context.set('data',data)

if (sdate==0)

{

var part_msg="";

}

else

{

var part_msg=" AND TIMESTAMP >"+sdate+ " AND TIMESTAMP<"+edate+ " ";

}

if(topic=="submit")

{

var query="";

if(data.value==undefined ||data.value=="" )

{

if(data.site!=undefined)

query ="SELECT * FROM SITES WHERE SITE="+"\""+data.site+"\""+part_msg+" ORDER BY TIMESTAMP DESC LIMIT 100";

}

else if(data.value!=undefined && data.value!="" )

{

if(data.site!=undefined && data.condition !=undefined)

{

query ="SELECT * FROM SITES WHERE SITE="+"\""+data.site+"\""+" AND PAGE_SPEED ";

query=query+data.condition + data.value +part_msg;

query=query+" ORDER BY TIMESTAMP DESC LIMIT 100";

}

node.log("query "+query);

msg.topic=query;

context.set('data',data)

if (query!="")

return msg;

}

return;

3. Node-Red程式

Node-Red Storing IOT data In a SQL Database Part2

Node-Red Storing IOT data In a SQL Database Part2

(存入 Json 格式)

參考來源 http://www.steves-internet-guide.com/storing-iot-data-sql-database/

1. 建立資料表 TABLE data

CREATE TABLE data(TIMESTAMP INT PRIMARY KEY NOT NULL, SENSOR TEXT NOT NULL,RAW_DATA TEXT NOT NULL)

2. 刪除資料表 TABLE data

drop table data

3.刪除紀錄

DELETE FROM data WHERE TIMESTAMP>=0

4.檢視資料庫內容

SELECT * FROM data ORDER BY TIMESTAMP DESC LIMIT 100

5. function test data

var count=context.get('count');

var timestamp=context.get('timestamp');

if (count==undefined)

{

count=1;

timestamp=1;

}

var data1={"sensor":"sensor1","temperature":21,"humidity":61};

var data2={"sensor":"sensor2","temperature":22,"humidity":62};

var data3={"sensor":"sensor3","temperature":23,"humidity":63};

if (count%20==0)

count=-count;

data1.temperature+=(count*.25);

data2.temperature+=(count*.5);

data3.temperature+=(count*.75);

data1.humidity+=(count*.25);

data2.humidity+=(count*.5);

data3.humidity+=(count*.75);

msg.payload=[data1];

var msg1={};

var msg2={};

var msg3={};

data1.timestamp=timestamp;

timestamp+=1;

data2.timestamp=timestamp;

timestamp+=1;

data3.timestamp=timestamp;

msg1.payload=JSON.stringify(data1);

msg2.payload=JSON.stringify(data2);

msg3.payload=JSON.stringify(data3);

timestamp+=1;

count+=1;

context.set('count',count);

context.set('timestamp',timestamp);

return [[msg1,msg2,msg3]];

6.Write Query

var raw_data=msg.payload;

var temp=JSON.parse(msg.payload);

var timestamp=temp.timestamp;

var sensor=temp.sensor;

msg="(timestamp,sensor,raw_data) values("+timestamp +",\'"+sensor +"\'"+ ",\'"+raw_data+"\'" +")";

var topic="INSERT INTO DATA " +msg;

var msg1={};

msg1.topic=topic;

msg1.payload=timestamp;

return msg1;

7. UI 樣板

<style>

.table

{

height:400px;

width:700px;

background:blue;

}

</style>

<div class="table">

<table style="width:100%">

<tr>

<th>TIMESTAMP</th>

<th>SENSOR</th>

<th>RAW DATA (JSON)</th>

</tr>

<tr ng-repeat="x in msg.payload | limitTo:20">

<td>{{msg.payload[$index].TIMESTAMP}}</td>

<td>{{msg.payload[$index].SENSOR}}</td>

<td>{{msg.payload[$index].RAW_DATA}}</td>

</tr>

</table>

</div>

8. Node-Red程式

訂閱：文章 (Atom)

2020年12月4日 星期五

Using the rbe (report by exception) node & Scaling input with the range node

2020年12月3日 星期四

2020年12月1日 星期二

Index of /dist./v12.18.3/

2020年11月30日 星期一

2020年12月4日星期五

2020年12月3日星期四

2020年12月1日星期二

2020年11月30日星期一