Nodered系列—使用mqtt写入国产数据库tDengine

本文使用mqttx客户端，发送mqtt消息到nodered的mqtt broker，经nodered的function拼接成slq语句，使用nodered写入tDengine数据库

步骤：

1. 发送mqtt消息到nodered的mqtt broker，使用nodered的mqtt in接收消息。详见NodeRed创建mqtt broker（mqtt服务器），并使用mqttx进行消息发送验证_鲸鱼姐的博客-CSDN博客

2. 创建tdengine数据库表，详见

使用docker安装tdengine，创建挂载目录_鲸鱼姐的博客-CSDN博客_docker 安装tdengine

表字段如下

3. 使用nodered的function拼接sql语句

 函数内容如下，因为表里有ts字段为timestamp，所以传输now

var plc1=msg.payload.plc1;
var plc2=msg.payload.plc2;
var plc3=msg.payload.plc3;
var plc4=msg.payload.plc4;
var plc_id=msg.payload.plc_id;
var table = 'test.plc_data'
msg.payload = 'insert into ' + table + ' values (now,' + plc1 + ',' + plc2 + ',' + plc3 + ',' + plc4 + ',' + plc_id + ');'
return msg;

4. 配置httpRequest节点连接tDengine数据库

配置请求方式为post，url为http://IP:6041/rest/sql，基本认证为tDengine的数据库账户密码，本文为默认密码 root，taosdata。 

 5. 配置debug输出

（1）结果反馈debug输出

 （2）sql语句拼接输出

6. 部署运行验证

使用mqttx进行mqtt消息发送验证

nodered显示数据如下 

 tDengine数据库存入数据，验证成功