温湿度计设备通过阿里云IoT物联网套件上报数据到钉钉群机器人实践——数据价值类

0. 背景介绍

场景：办公室中已经布点的温湿度计设备上报数据到钉钉群机器人。

思路：温湿度计通过MQTT协议连接到IoT套件，规则引擎针对数据上报Topic配置转发到函数计算(FunctionComputer)中编写好的函数pushData2DingTalk，函数Nodejs脚本处理数据，post到钉钉群机器人的Webhook，配置了温湿度机器人的钉钉群组即可收到消息。

1. 钉钉群机器人配置

钉钉PC端
①、登录钉钉电脑版；
②、群聊天窗口右上角找到机器人?图标，点击图标。
③、选择自定义Webhook机器人,按指引添加名字和图标，并确认完成。
添加完成后，对应的机器人设置页面如下，其中红框中的webhook地址已经包含了访问用的accessToken

2. 函数计算脚本编写

2.1 开通阿里云函数计算服务

函数计算，是一个事件驱动的全托管计算服务，目前支持的语言Java、NodeJS、Python等语言，​​详见​​。

2.2 编写函数脚本

这里我们选择Nodejs执行环境，从上游IoT套件处获取到设备位置，设备编号，实时温度，相对湿度和上报时间，依据​​钉钉消息格式​​组装，并用https模块post数据到钉钉群机器人的webhook接口。

2.2.1 创建函数

我们选择华东2区,创建服务IoT_Service，新建空白Nodejs函数pushData2DingTalk。

2.2.2 函数pushData2DingTalk完整脚本如下：

const https = require('https');
const accessToken = '此处填写钉钉机器人webhook的accessToken';
module.exports.handler = function(event, context, callback) {
 var eventJson = JSON.parse(event.toString());
 //钉钉消息格式
 const postData = JSON.stringify({
 "msgtype": "markdown",
 "markdown": {
 "title": "温湿度传感器",
 "text": "#### 温湿度传感器上报\n" +
 "> 设备位置：" + eventJson.tag + "\n\n" +
 "> 设备编号：" + eventJson.isn+ "\n\n" +
 "> 实时温度：" + eventJson.temperature + "℃\n\n" +
 "> 相对湿度：" + eventJson.humidity + "%\n\n" +
 "> ###### " + eventJson.time + " 发布 by [物联网套件](https://www.aliyun.com/product/iot) \n"
 },
 "at": {
 "isAtAll": false
 }
 });
 const options = {
 hostname: 'oapi.dingtalk.com',
 port: 443,
 path: '/robot/send?access_token=' + accessToken,
 method: 'POST',
 headers: {
 'Content-Type': 'application/json',
 'Content-Length': Buffer.byteLength(postData)
 }
 };
 const req = https.request(options, (res) => {
 res.setEncoding('utf8');
 res.on('data', (chunk) => {});
 
 res.on('end', () => {
 callback(null, 'success');
 });
 });
 // 异常返回
 req.on('error', (e) => {
 callback(e);
 });
 // 写入数据
 req.write(postData);
 req.end();
};

3. IoT套件配置

首先我们要开通​​物联网套件服务​​

3.1 创建产品和设备

①、我们现在物联网套件控制台创建温湿度计产品，系统会生成productKey
②、在温湿度计产品创建一个具体设备，获得deviceName和deviceSecret用于身份验证，
③、给设备添加两个设备属性

3.2 创建并订阅Topic

这里我们选择温湿度计产品，在左侧消息通信下创建一个Topic为/productKey/${deviceName}/data，设备操作权限设置：发布。

3.3 创建并启用规则引擎

一条完整的规则包括基本信息，处理数据，转发数据三部分，其中转发数据支持配置多个转发动作。

3.3.1 配置数据处理脚本

规则引擎SQL脚本支持​​特定SQL和函数查询​​：
我们从设备本身信息中抽取设备名(deviceName),自定义属性中获取：标签(tag)和序列号(deviceISN)，
从温湿度采集设备上报数据消息的payload中获取温度值(temperature)和湿度值(humidity)。

具体SQL如下：

SELECT 
deviceName() as deviceName, 
attribute('tag') as tag, 
attribute('deviceISN') as isn, 
temperature, 
humidity,
timestamp('yyyy-MM-dd HH:mm:ss') as time 
FROM 
"/此处为产品productKey/+/data"

3.3.2 配置转发动作到函数计算

3.3.3 完整规则如下

我们定义好的规则toFC完整信息如下：

3.3.4 启用规则引擎

这里找到我们定义好的规则toFC，并启用。

4. 温湿度计设备

为了方便联调我们先用Nodejs程序模拟温湿度计，上报采集到的数据。
这里依赖了​​aliyun-iot-mqtt库​​
demo.js完整代码如下：

const mqtt = require('aliyun-iot-mqtt');
const client = mqtt.getAliyunIotMqttClient({
 productKey: "产品productKey",
 deviceName: "设备deviceName",
 deviceSecret: "设备的secret"
});
const topic = '添加了转发函数计算规则的Topic';
const data = {
 temperature: 18,
 humidity: 63,
};
client.publish(topic, JSON.stringify(data));

5. 完整演示

5.1 程序模拟发送数据：

$ npm install
$ node demo.js

5.2 钉钉群消息效果：

物联网平台产品介绍详情：​​https://www.aliyun.com/product/iot/iot_instc_public_cn​​

 阿里云物联网平台客户交流群