（以下來(lái)源成都縱橫智控公眾號(hào)授權(quán)更多可見(jiàn)-https://www.iotrouter.com-智控）

-需求概述

注：使用Influxdb數(shù)據(jù)庫(kù)節(jié)點(diǎn)，需要插上micro sd卡才可以

本章節(jié)主要實(shí)現(xiàn)一個(gè)流程：EG8200每10秒采集一次Modbus TCP數(shù)據(jù)存入Influxdb數(shù)據(jù)庫(kù),并且每分鐘從Influxdb數(shù)據(jù)庫(kù)中取6條數(shù)據(jù)打包上報(bào)。

Modbus TCP數(shù)據(jù)采集此處不做過(guò)多贅述，可參考其他案例介紹。下文默認(rèn)已經(jīng)采集到Modbus TCP數(shù)據(jù)。

-數(shù)據(jù)上報(bào)格式

[{
  "time": "2023-12-20 14:50:13",
  "value1": 12573,
  "value2": 12568,
  "value3": 12561,
  "value4": 12557,
  "value5": 12552,
  "value6": 12545,
  "value7": 12540,
  "value8": 12535
}, {
  "time": "2023-12-20 14:50:13",
  "value1": 12573,
  "value2": 12568,
  "value3": 12561,
  "value4": 12557,
  "value5": 12552,
  "value6": 12545,
  "value7": 12540,
  "value8": 12535
}, {
  "time": "2023-12-20 14:50:13",
  "value1": 12574,
  "value2": 12569,
  "value3": 12562,
  "value4": 12558,
  "value5": 12553,
  "value6": 12546,
  "value7": 12541,
  "value8": 12536
}, {
  "time": "2023-12-20 14:50:14",
  "value1": 12574,
  "value2": 12569,
  "value3": 12562,
  "value4": 12558,
  "value5": 12553,
  "value6": 12546,
  "value7": 12541,
  "value8": 12536
}, {
  "time": "2023-12-20 14:50:14",
  "value1": 12575,
  "value2": 12570,
  "value3": 12563,
  "value4": 12559,
  "value5": 12554,
  "value6": 12547,
  "value7": 12542,
  "value8": 12537
}, {
  "time": "2023-12-20 14:50:14",
  "value1": 12575,
  "value2": 12570,
  "value3": 12563,
  "value4": 12559,
  "value5": 12554,
  "value6": 12547,
  "value7": 12542,
  "value8": 12537
}]

-需求分析

第一步：配置并連接數(shù)據(jù)庫(kù)

第二步：創(chuàng)建一個(gè)數(shù)據(jù)庫(kù)

第三步：指定使用新創(chuàng)建的數(shù)據(jù)庫(kù)

第四步：讀取Modbus TCP數(shù)據(jù)并存入指定表中

第五步：從數(shù)據(jù)庫(kù)中讀取6個(gè)數(shù)據(jù)

第六步：將讀取出來(lái)的數(shù)據(jù)打包

第七步：將打包的數(shù)據(jù)發(fā)送到MQTT

-需求實(shí)現(xiàn)

第一步：配置并連接數(shù)據(jù)庫(kù)

首次連接EG8200的Influxdb數(shù)據(jù)庫(kù)按照默認(rèn)的配置即可無(wú)需修改

第二步：創(chuàng)建一個(gè)數(shù)據(jù)庫(kù)

創(chuàng)建一個(gè)數(shù)據(jù)庫(kù)需要使用到sql語(yǔ)句 CREATE DATABASE myDatabase ，這條語(yǔ)句的意思是創(chuàng)建一個(gè)名字叫做myDatabase的數(shù)據(jù)庫(kù)。按照下面視頻的方式創(chuàng)建，日志窗口打印[empty]，說(shuō)明數(shù)據(jù)庫(kù)創(chuàng)建成功

第三步：指定使用新創(chuàng)建的數(shù)據(jù)庫(kù)

在第一步創(chuàng)建了一個(gè)名字叫做myDatabase的數(shù)據(jù)庫(kù)，現(xiàn)在需要使用這個(gè)數(shù)據(jù)庫(kù)，將Influxdb的一個(gè)配置名Database改成myDatabase

第四步；DO能控制的設(shè)備

Modbus TCP數(shù)據(jù)采集此處不做過(guò)多贅述，這里已經(jīng)配置好Modbus TCP詳細(xì)使用請(qǐng)參考

從節(jié)點(diǎn)庫(kù)里面拿出一個(gè)寫時(shí)序數(shù)據(jù)庫(kù)節(jié)點(diǎn)，選擇前面步驟已經(jīng)添加的配置信息，并將表名填寫在Measurement，

這里使用myTable作為表名

第五步：從數(shù)據(jù)庫(kù)中讀取6個(gè)數(shù)據(jù)

通過(guò)函數(shù)節(jié)點(diǎn)構(gòu)造sql讀取指令，通過(guò)時(shí)間查詢最近6條數(shù)據(jù)

上面視頻中使用到的函數(shù)代碼

if (global.get("startTime") == undefined || global.get("startTime") == null) global.set("startTime", new Date().getTime())
var startTime = global.get("startTime")
var temp = new Date(startTime).toISOString()
var table = "myTable"
msg.query = "SELECT * FROM" + " "" + table + "" " + " WHERE time > '" + temp + "' LIMIT 6"
return msg;

第六步：將讀取出來(lái)的數(shù)據(jù)打包

使用函數(shù)節(jié)點(diǎn)將數(shù)據(jù)封裝成對(duì)應(yīng)的json字符串

上面視頻中使用到的函數(shù)代碼

function dateFormat(fmt, timestamp) {
    let ret;
    const opt = {
        "Y+": timestamp.getFullYear().toString(), // 年
        "m+": (timestamp.getMonth() + 1).toString(),  // 月
        "d+": timestamp.getDate().toString(), // 日
        "H+": timestamp.getHours().toString(), // 時(shí)
        "M+": timestamp.getMinutes().toString(), // 分
        "S+": timestamp.getSeconds().toString() // 秒
        // 有其他格式化字符需求可以繼續(xù)添加，必須轉(zhuǎn)化成字符串
    };
    for (let k in opt) {
        ret = new RegExp("(" + k + ")").exec(fmt);
        if (ret) {
            fmt = fmt.replace(ret[1], (ret[1].length == 1) ? (opt[k]) : (opt[k].padStart(ret[1].length, "0")))
        };
    };
    return fmt;
}
// const fmt = dateFormat("YYYY-mm-dd HH:MM:SS", new Date())
var dataList = msg.payload
if (dataList.length == 0) {
    node.error("數(shù)據(jù)庫(kù)無(wú)數(shù)據(jù)請(qǐng)檢查")
    return
}
dataList.forEach(item => item.time = dateFormat("YYYY-mm-dd HH:MM:SS", new Date(item.time)))
global.set("startTime", new Date(dataList[dataList.length - 1].time).getTime() + 1000)
msg.payload = JSON.stringify(dataList)
return msg

第七步：將打包的數(shù)據(jù)發(fā)送到MQTT

新增MQTT發(fā)布節(jié)點(diǎn)

客戶端ID：網(wǎng)關(guān)SN

用戶名：網(wǎng)關(guān)SN

密碼：EG87654321

發(fā)布主題：${sn}/send

-總結(jié)

本章節(jié)介紹了一個(gè)相對(duì)復(fù)雜的流程，旨在表述網(wǎng)關(guān)所具備的能力，因此并未對(duì)程序的安全性、穩(wěn)定性、靈活性等方面做優(yōu)化。通過(guò)理解本流程，相信你已經(jīng)對(duì)網(wǎng)關(guān)的可視化編程有了一定的熟悉。接下來(lái)，深入學(xué)習(xí)每個(gè)節(jié)點(diǎn)的功能用法吧，掌握它們將會(huì)為你制作更復(fù)雜的流程提供更多的選擇和可能！

-注意

MQTT配置節(jié)點(diǎn)導(dǎo)出時(shí)，不會(huì)攜帶用戶名和密碼。因此導(dǎo)入時(shí)需要重新錄入用戶名和密碼

審核編輯 黃宇