当前位置:网站首页>Nodered系列—使用mqtt写入国产数据库tDengine
Nodered系列—使用mqtt写入国产数据库tDengine
2022-08-11 05:20:00 【鲸鱼姐】
本文使用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数据库存入数据,验证成功
边栏推荐
猜你喜欢
随机推荐
最全总结Redis数据类型使用场景
04-开发自己的npm包及发布流程详细讲解
BoredApeYachtClub 无聊猿-NFT 源码解析第一节
[C language advanced] The first in-depth analysis of the storage of integer data in memory (1)
08-Express路由详解
error: The following untracked working tree files would be overwritten by merge: .hbuilderx/launch
C语言----输出格式控制串
《现代密码学》学习笔记——第七章 密钥管理[一]
二,八,十,十六进制转换
Laravel5.7反序列化
C语言结构体详解 (2) 结构体内存对齐,默认对齐数
[C language from elementary to advanced] Part 2 Initial C language (2)
无字母数字RCE
看完这篇博客之后,含着泪学会了TCP/IP
Windows64位MySQL配置式安装(绿色版)
写博客周志
C language version - advanced address book (file version)
Hooks在函数组件中使用useState、useEffect、useRef、useContext
全国青少年信息学奥林匹克联赛大纲
CSDN 社区内容创作规范