智能甲醛检测（在线甲醛监测系统案例）

智能甲醛检测（在线甲醛监测系统案例）腾讯云图效果展示终端：终端组件注：RaspberryPi后续简写为Rpi云端：腾讯云产品

导语：本文详述腾讯云多产品组合设计和体验报告 之 “树莓派 腾讯云=在线甲醛监测系统”。涉及腾讯云产品：API网关、无服务器云函数、云数据库、腾讯云图。

正文

身边朋友在装修新房，顺便来吐槽甲醛检测麻烦，比如 有检测无监测（一次性），比如测试复杂（现场 人工）等等。刚好作为云产品经理，经常想的就是如何了解和验证多云产品组合方案的可用性问题，索性结合一下，直接把这个需求上云，然后就有了这套系统。老规矩，先上结论。

系统概要

产品设计特性

• 原型验证：验证多产品联动效果与开发成本。
• 软硬结合：扩展云端能力至线下物理环境。
• 能力扩展：serverless分离云端与终端，独立扩展云监控、消息队列等其它产品。
• 通用架构：云端使用通用数据结构及接口，免开发即对接各种监测数据上报。
• 弱环境要求：可PoE供电，5V/0.5A低功耗可长期运行。

系统组成

终端：终端组件

• RaspberryPi 3B （raspbian-stretch-lite/GPIO接口/python2.7)
• UART-CH2O传感器（UART接口）
• 128X32 OLED屏 SSD1306芯片（I2C接口）

注：RaspberryPi后续简写为Rpi

云端：腾讯云产品

• 腾讯云 API网关
• 腾讯云 无服务器云函数
• 腾讯云 云数据库 MySQL
• 腾讯云 腾讯云图

效果展示

腾讯云图

终端组件

当前版本中，Rpi 使用wifi 连接互联网（也可使用有线网），故此处上云有网络依赖。

传感器原理与功能定位

UART-CH2O传感器

• 原理：电化学传感器通过与被测气体发生反应并产生与气体浓度成正比的电信号来工作。
• 优点：简单易操作
• 缺点：非定量分析法，受温湿度、其它气体干扰准确度，且需要较准。
• 结论：以长期使用后的房间环境做为基准，进行0基准点参考。用于温湿度差异不大的环境下，提供实时监测（相对值），并附加长期趋势分析。

设计与实现

产品设计与技术策略

设计过程中，也进行了产品生命周期的思考，尝试进行了产品长短期设计的分析与定义（暂不展开，后续有时间写一下）。

确认了形态目标后，遵循下面几个基本原则，进行具体技术设计：

• 分级可用：避免单环故障，系统全面崩溃
• 读写分离：便于后续调试、优化、更新版本
• 远程维护：避免出现场处理异常

概要架构图

从架构看来

• 云端部分：由于云产品的能力提供了各种便利，学习和搭建成本很低。
• 终端部分：需要多考虑免维护与自动恢复，各项工作内容稍多一些。

分级可用目标

4.本地实时展示 本地缓存 数据上云 云端显示。

3.本地实时展示 本地缓存 数据上云。云图异常。

2.本地实时展示 本地缓存。上云通路异常。

1.本地实时展示。本地Sqlite异常。

0.本地无展示。硬件故障或断电。

硬件接线与打开系统接口

Rpi GPIO

GPIO

(General-purpose input/output)即通用IO接口，是一种常见的端口扩展器，树莓派使用的是40针的GPIO接口。

RPI GPIO图示

UART-CH2O

注：本次使用传感器，硬件接口是1.25mm端子，Rpi是2.5mm端子，使用了 7P1.25转2.5杜邦线，进行连接

OLED

接线方式(I2C协议)

打开I2C接口

raspi-config

按下图打开I2C接口

测试执行

i2cdetect -y 1

看到 3C 即识别硬件成功

本地开发与配置

本文暂仅放出关键代码(硬件操作部分)，便于大家撸硬件。完整包(代码 配置) 稍后放出，请关注 github/DemoOnTencentCloud。

环境配置

• 启动对时：rc.local 增加 nptdata cn.ntp.org.cn。避免重启后时间错位，监测错位。
• 启动拉起：getdata.py oled.py 需持续在线。
• 定时检测：getdata.py oled.py cron每分钟判断活性，进程挂掉即拉起。
• 定时同步：sync.py cron每分钟执行
• 远程维护：使用ssh tunnel 的 Remote Port Forwarding 模式，进行反向代理。

ssh tunnel

此处使用 autossh 进行连接，autossh可完成建立通道与监控通道的工作，通道断开后，可自主重连。远端连接云主机，之后可以云主机为跳板，反向代理访问NAT环境Rpi设备。

bash autossh -M 监控端口 -R 远程通信端口:localhost:22 账号名@远程IP或域名 -p端口号 -i 账号KEY -o serveraliveinterval=60 -N -f

连接时，在云主机执行

bash ssh -p 远程通信端口 localhost

getdata.py

获取传感器读数代码（完整代码待放出 github/DemoOnTencentCloud）

import serial from time import sleep ser=serial.Serial("/dev/serial0" 9600) while True : r_data = ser.read() sleep(0.3) data_left = ser.inWaiting() r_data = ser.read(data_left) if 9 != len(r_data): print 'error length: %d'%len(r_data) continue else: n=ord(r_data[4])*256 ord(r_data[5]) updatedata(n/1000.0) # ppm = n/1000.0

flusholed.py

依赖库安装

(基于
https://github.com/adafruit/Adafruit_python_SSD1306)

sudo python -m pip install --upgrade pip setuptools wheel sudo pip install Adafruit-SSD1306

下为功能伪代码。（完整代码待放出 github/DemoOnTencentCloud）

# 读取 cachefile 缓存文件 # 刷新 OLED 显示

sync.py

下为功能伪代码。（完整代码待放出 github/DemoOnTencentCloud）

# 访问 APIGW，获取最新记录时间戳 # 读本地sqlite库，获取增量数据 # 访问 APIGW，提交更新数据

Sqlite结构

表结构

CREATE TABLE "sensordata" ( "id" INTEGER PRIMARY KEY AUTOINCREMENT "utime" INTEGER NOT NULL "utype" INTEGER DEFAULT 0 NOT NULL "udata" REAL NOT NULL "sdata" TEXT );

云端开发与配置

无服务器云函数

优先配置 无服务器云函数，参考 文档 建立并保存“函数代码”后，在管理页面的“触发方式”功能中，直接生成对应API网关。

https://github.com/eckygao/DemoOnTencentCloud

当前主要强调几个注意事项：

1. 自动提交：连接数据库必须使用“autocommit = True ”参数，否则由于事务隔离，DB链接重新连接前，查询结果不变。（查不到新增记录ID）
2. 返回头：API网关开启“响应集成”时，云函数返回值需结合返回信息，指定"Content-Type"，否则出现 "transfer closed with outstanding read data remaining" 错误。
3. 验证连接：云函数实例可长期存在，但一定时间未操作Mysql链接时，mysql将释放链接，所以代码中需要进行验证链路可用性。

API网关

配置服务

参考 文档 ，以上“触发方式”中建立的API网关服务，由API网关的 服务 页面，点击相应服务名，选择“API管理”分页，点击“编辑”，然后配置“请求方法-POST”、“鉴权类型-密钥对”、“使用响应集成”，其它余配置按默认即可。

下载与使用SDK

API网关 控制台 -> 点击 服务名 -> 点击 API文档/SDK -> 点击 下载SDK

（完整配置待放出 github/DemoOnTencentCloud）

云数据库 Mysql

表结构

SET SQL_MODE = "NO_AUTO_VALUE_ON_ZERO"; SET AUTOCOMMIT = 0; START TRANSACTION; SET time_zone = " 00:00"; CREATE TABLE `sensordata` ( `id` int(11) NOT NULL `stime` timestamp NULL DEFAULT NULL `utype` int(11) NOT NULL DEFAULT '0' `udata` float NOT NULL `sdata` varchar(256) DEFAULT NULL ) ENGINE=InnoDB DEFAULT CHARSET=utf8; ALTER TABLE `sensordata` ADD PRIMARY KEY (`id`); ALTER TABLE `sensordata` MODIFY `id` int(11) NOT NULL AUTO_INCREMENT; COMMIT;

云图配置

简要使用说明

拖选组件 -> 点击数据栏 -> 选择数据库 -> 填写SQL -> 开启自动更新 -> 预览 -> 发布

操作示例图

组件配置信息

• 最新同步时间 - 通用文本

select concat('最新同步时间 ' stime) as value from sensordata order by id desc limit 1

• 国标系数比 - 水位图

select round((udata)/0.08*100 2) as value from sensordata order by id desc limit 1

• 实时读数 - 基本条形图

select round(udata 3) as x '' as y from sensordata order by id desc limit 1

• 10分钟数据 - 基本折线图

select * from (select id round(udata 3) as y date_format(stime '%H:%i:%S') as x utype as s from sensordata order by id desc limit 360) as t1 order by id asc

• 7天数据 - 基本折线图

select distinct (dt) round(AVG(udata) 3) as y dt as x '0' as s from (select id date_format(stime '%Y-%m-%d %H') as dt udata from sensordata order by id desc limit 604800) as t1 group by dt order by dt ASC 写在最后

关于丢数据（非守护进程）、脏数据（未较验数据唯一性）、缺乏系统监控告警（未接入云监控）等等待优化点

分享MySQL连接知识详解

用两个表（a_table、b_table），关联字段a_table.a_id和b_table.b_id来演示一下MySQL的内连接、外连接（ 左(外)连接、右(外)连接、全(外)连接）。

MySQL版本：Server version: 5.6.31 MySQL Community Server (GPL)

数据库表：a_table、b_table

主题：内连接、左连接（左外连接）、右连接（右外连接）、全连接（全外连接）

前提

建表语句：

表测试数据：

一、内连接

说明：组合两个表中的记录，返回关联字段相符的记录，也就是返回两个表的交集（阴影）部分。

二、左连接（左外连接）

说明：

left join 是left outer join的简写，它的全称是左外连接，是外连接中的一种。

左(外)连接，左表(a_table)的记录将会全部表示出来，而右表(b_table)只会显示符合搜索条件的记录。右表记录不足的地方均为NULL。

三、右连接（右外连接）

四、全连接（全外连接）

MySQL目前不支持此种方式，可以用其他方式替代解决。

五、补充，MySQL如何执行关联查询

MySQL认为任何一个查询都是一次“关联”，并不仅仅是一个查询需要到两个表匹配才叫关联，所以在MySQL中，每一个查询，每一个片段（包括子查询，甚至基于单表查询）都可以是一次关联。

当前MySQL关联执行的策略很简单：MySQL对任何关联都执行嵌套循环关联操作，即MySQL先在一个表中循环取出单条数据，然后在嵌套循环到下一个表中寻找匹配的行，依次下去，直到找到所有表中匹配的行为止。然后根据各个表匹配的行，返回查询中需要的各个列。请看下面的例子中的简单的查询：

上面的执行计划对于单表查询和多表关联查询都适用，如果是一个单表查询，那么只需要上面外层的基本操作。对于外连接，上面的执行过程仍然适用。例如，我们将上面的查询语句修改如下：

select tbl1.col1 tbl2.col2 from tbl1 left outer join tbl2 using(col3) where tbl1.col1 in (5 6);

那么，对应的伪代码如下：