基于 IoT 物联网 + 表格存储 DB + DataV 搭建实时环境监控大屏——实践类

作者：阿里云AIoT

2023-02-23
浙江
本文字数：1521 字
阅读完需：约 5 分钟

今天给大家带来基于阿里云 IoT 物联网平台 + Tablestore 表格存储数据库 + DataV 大屏三大云产品组合搭建实时环境监控大屏的开发实战。

少啰嗦，先看效果。

image.png

部署后效果

1.技术架构

我们在室内每层部署 4 个温湿度传感器，实时采集数据，每 10 秒发送到阿里云 IoT 物联网平台，通过规则引擎写入表格存储 Tablestore 数据库。在 DataV 大屏工作台，创建可视化大屏，实时展示室内温湿度变化曲线。

技术架构如下：

image.png

2.IoT 物联网开发

2.1 创建产品和注册设备

首先，我们登陆 IoT 物联网平台的控制台，创建产品温湿度环境监测器，并在功能定义中添加温度和湿度两个属性，如下图：

image.png

然后，我们在产品下注册一个设备，获取设备身份证书，用于设备和 IoT 云平台建立 MQTT 长连接时的身份认证。

image.png

2.2 配置云产品流转

1.4.配置规则引擎，实时流转数据到 TSDB 中

image.png

编写数据处理 SQL：

完整 SQL 参考：

SELECT deviceName() as deviceName, timestamp('yyyy-MM-dd HH:mm:ss') as time, attribute('floor') as floor, items.temperature.value as temperature, items.humidity.value as humidity FROM "/a1kRdXDgN0v/+/thing/event/property/post"

复制代码

数据转发：

image.png

2.3 设备端程序脚本

我们以 Node.js 脚本来模拟设备上报温度和湿度，代码如下：

// 依赖mqtt库const mqtt = require('aliyun-iot-mqtt');// 设备身份var options = {    productKey: "设备 productKey",    deviceName: "设备 deviceName",    deviceSecret: "设备 deviceSecret",    regionId: "cn-shanghai"};// 建立连接const client = mqtt.getAliyunIotMqttClient(options);//模拟 设备 上报数据（原始报文）setInterval(function() {    client.publish(      `/sys/${options.productKey}/${options.deviceName}/thing/event/property/post`      , getPostData()      );}, 10 * 1000);// 模拟 温湿度function getPostData() {    const payload = {        id: Date.now(),        version:"1.0",        params: {            temperature: 10+Math.floor(Math.random() * Math.floor(50)),            humidity: 10+Math.floor(Math.random() * Math.floor(50))        },        method: "thing.event.property.post"    }    console.log("payload=[ " + payload + " ]")    return JSON.stringify(payload);}