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

简介: 温湿度计通过MQTT协议连接到IoT套件,规则引擎针对数据上报Topic配置转发到函数计算(FunctionComputer)中编写好的函数pushData2DingTalk,Nodejs脚本函数处理数据,post到钉钉群机器人

0. 背景介绍

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

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

关系图.png

1. 钉钉群机器人配置

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

钉钉群机器人配置.png

2. 函数计算脚本编写

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

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

2.2 编写函数脚本

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

2.2.1 创建函数

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

函数计算.png

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用于身份验证,
③、给设备添加两个设备属性

属性 属性值 描述
tag 云栖小镇 2号楼3层007S 设备所在位置
deviceISN T20180102XnbKjmoAnUb 设备序列号

设备信息.png

3.2 创建并订阅Topic

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

topic设置.png

3.3 创建并启用规则引擎

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

3.3.1 配置数据处理脚本

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

规则引擎SQL.png

具体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 配置转发动作到函数计算

FC转发配置.png

3.3.3 完整规则如下

我们定义好的规则toFC完整信息如下:
一条规则引擎.png

3.3.4 启用规则引擎

这里找到我们定义好的规则toFC,并启用。
规则引擎启用.png

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

执行.png

5.2 钉钉群消息效果:

钉钉群效果.png

IoT套件技术交流群
iot套件交流群-钉钉.png

相关实践学习
钉钉群中如何接收IoT温控器数据告警通知
本实验主要介绍如何将温控器设备以MQTT协议接入IoT物联网平台,通过云产品流转到函数计算FC,调用钉钉群机器人API,实时推送温湿度消息到钉钉群。
阿里云AIoT物联网开发实战
本课程将由物联网专家带你熟悉阿里云AIoT物联网领域全套云产品,7天轻松搭建基于Arduino的端到端物联网场景应用。 开始学习前,请先开通下方两个云产品,让学习更流畅: IoT物联网平台:https://iot.console.aliyun.com/ LinkWAN物联网络管理平台:https://linkwan.console.aliyun.com/service-open
相关文章
|
28天前
|
机器人 关系型数据库 MySQL
shell脚本实现文件自动清理并推送钉钉机器人告警
shell脚本实现文件自动清理并推送钉钉机器人告警
23 0
|
28天前
|
运维 监控 安全
调用钉钉机器人API接口将堡垒机安全运维告警单发给运维人员
调用钉钉机器人API接口将堡垒机安全运维告警单发给运维人员
52 0
|
1月前
|
安全 机器人 数据安全/隐私保护
基于钉钉的阿里云管理实践(四)之续费充值
在阿里云资源的运营过程中,及时续费和充值是保障服务不中断的关键行动。借助钉钉及其集成的阿里云管理功能,用户可以方便地接收到续费通知,并完成充值过程。本教程将为您详细介绍从收到续费提醒信息到完成充值的全过程。
|
17天前
|
传感器 机器学习/深度学习 存储
植保机器人生长数据记录与分析
植保机器人生长数据记录与分析
9 3
|
23天前
|
弹性计算 安全 Linux
基于阿里云搭建幻兽帕鲁服务器部署实践评测
基于阿里云搭建幻兽帕鲁服务器部署实践评测,如何自建幻兽帕鲁服务器?基于阿里云服务器搭建幻兽帕鲁palworld服务器教程来了,一看就懂系列。本文是利用OOS中幻兽帕鲁扩展程序来一键部署幻兽帕鲁服务器,阿里云百科分享官方基于阿里云服务器快速创建幻兽帕鲁服务器教程
114 0
|
28天前
|
安全 机器人 Shell
shell脚本实现Linux磁盘空间超过阈值自动钉钉机器人告警
shell脚本实现Linux磁盘空间超过阈值自动钉钉机器人告警
22 0
|
28天前
|
运维 监控 安全
【优化篇】调用钉钉机器人API接口将堡垒机安全运维告警单发给运维人员
【优化篇】调用钉钉机器人API接口将堡垒机安全运维告警单发给运维人员
55 0
|
1月前
|
机器人
在钉钉中,自动化小助手是一种机器人
在钉钉中,自动化小助手是一种机器人【1月更文挑战第20天】【1月更文挑战第100篇】
35 3
|
存储 弹性计算 安全
成功案例-钉钉 | 学习笔记
快速学习 成功案例-钉钉
275 0
|
存储 弹性计算 安全
案例分享——钉钉|学习笔记
快速学习 案例分享——钉钉
269 0

相关产品

  • 物联网平台