物联网平台数据流转到函数计算|学习笔记

简介: 快速学习物联网平台数据流转到函数计算

开发者学堂课程【物联网平台云上开发物联网平台数据流转到函数计算】学习笔记,与课程紧密联系,让用户快速学习知识。

课程地址:https://developer.aliyun.com/learning/course/563/detail/7709


物联网平台数据流转到函数计算

内容介绍:

一、规则引擎

二、开发实践


一、规则引擎

1、规则引擎的划分:

分为两部分,一部分是数据处理,就是通过circle来处理原始数据。

2、topic的不同:

它的处理过程会有一些差异,就是自定义的topic是直接推送到规则引擎来处理;物模型的topic它会先流转到物模型模块做解析,那此时它的payload会发生一个结构的变化,那规则引擎是根据物模型处理的结构体来做circle处理的。


二、开发实践

1、主要过程

第一:在钉钉群里创立一个机器人,

第二:创建函数计算FC的脚本,

第三:配置规则引擎,流转函数计算,第四:设备上报数据,规则引擎流转,钉钉收到消息。

2、具体流程

首先在群设置里添加机器人,选择自定义机器人,然后添加,给机器人取名字后点击完成即可。

这时会有一个webhook的地址,这个就是推送消息时pose的地址。将其复制下来,接下来到函数计算这个应用里,来创建一个新的服务,给它起一个名字’IoT2Dingtalk‘,取完名字点击确定即可。

接着进入服务当中,来新建一个函数,采用node语言,不创建触发器,直接进行下一步,函数名字postDingtalk,运行环境选择nodejs8,接着点击下一步,模板由于不需要,直接进行下一步,然后点击创建。这是有一个原始的脚本,接下来来编写整个脚本。

以下是直接从机器人获得的Token,如图

image.png

这部分是要往钉钉群里发布的消息,消息里面的一部分是通过IoT平台推过来的event里获得的一些参数,这一部分是https pose的一个方法,随后进行保存即可。

3、对规则引擎的创建进行回顾

首先会取一些数据,然后把它流转到了表格里,再这一次添加操作,流转到函数计算里,然后选择函数计算所在的华东2,接着找到创建的IoT2Dingtalk服务,找到对应的函数,拟定一个决策授权,接着点击确定

那这一条规则就是把设备上报的数据通过这样一个circle进行处理,把处理后的数据推送到表格存储;同时把数据推送到函数计算,最终推送到钉钉的消息群里。

此时就需要先停止IoT规则引擎流转再启动,这时启动设备上报一条数据,然后可以看到表格存储里就已经有一条这样的数据生成。这就是通过规则引擎把数据流转到了表格存储里。

同时来看一下钉钉群,这时候钉钉群的机器人也推送过来一条消息,这就完成了数据上报通过规则引擎流转到函数计算,最终推送到钉钉群里。同样在函数计算里,也可以以邮件,短信的方式推送到运营同学手上

相关实践学习
【AI破次元壁合照】少年白马醉春风,函数计算一键部署AI绘画平台
本次实验基于阿里云函数计算产品能力开发AI绘画平台,可让您实现“破次元壁”与角色合照,为角色换背景效果,用AI绘图技术绘出属于自己的少年江湖。
从 0 入门函数计算
在函数计算的架构中,开发者只需要编写业务代码,并监控业务运行情况就可以了。这将开发者从繁重的运维工作中解放出来,将精力投入到更有意义的开发任务上。
相关文章
|
11月前
|
传感器 人工智能 物联网
健康监测设备的技术革命:AI+物联网如何让你随时掌握健康数据?
健康监测设备的技术革命:AI+物联网如何让你随时掌握健康数据?
1334 19
|
10月前
|
存储 运维 Serverless
千万级数据秒级响应!碧桂园基于 EMR Serverless StarRocks 升级存算分离架构实践
碧桂园服务通过引入 EMR Serverless StarRocks 存算分离架构,解决了海量数据处理中的资源利用率低、并发能力不足等问题,显著降低了硬件和运维成本。实时查询性能提升8倍,查询出错率减少30倍,集群数据 SLA 达99.99%。此次技术升级不仅优化了用户体验,还结合AI打造了“一看”和“—问”智能场景助力精准决策与风险预测。
941 69
|
消息中间件 缓存 Serverless
在进行实时数据处理时,FaaS 如何保证数据的一致性和处理的实时性?
在进行实时数据处理时,FaaS 如何保证数据的一致性和处理的实时性?
|
物联网 数据管理 Apache
拥抱IoT浪潮,Apache IoTDB如何成为你的智能数据守护者?解锁物联网新纪元的数据管理秘籍!
【8月更文挑战第22天】随着物联网技术的发展,数据量激增对数据库提出新挑战。Apache IoTDB凭借其面向时间序列数据的设计,在IoT领域脱颖而出。相较于传统数据库,IoTDB采用树形数据模型高效管理实时数据,具备轻量级结构与高并发能力,并集成Hadoop/Spark支持复杂分析。在智能城市等场景下,IoTDB能处理如交通流量等数据,为决策提供支持。IoTDB还提供InfluxDB协议适配器简化迁移过程,并支持细致的权限管理确保数据安全。综上所述,IoTDB在IoT数据管理中展现出巨大潜力与竞争力。
530 1
|
11月前
|
存储 监控 安全
工业物联网关应用:PLC数据通过智能网关上传阿里云实战
本文介绍如何使用智能网关将工厂PLC数据传输至阿里云平台,适合中小企业远程监控设备状态。硬件准备包括三菱FX3U PLC、4G智能网关和24V电源。接线步骤涵盖PLC编程口与网关连接、运行状态检测及天线电源接入。配置过程涉及通讯参数、阿里云对接和数据点映射。PLC程序关键点包括数据上传触发和温度值处理。阿里云平台操作包含实时数据查看、数据可视化和规则引擎设置。最后提供常见故障排查表和安全建议,确保系统稳定运行。
1022 1
|
SQL 存储 运维
从建模到运维:联犀如何完美融入时序数据库 TDengine 实现物联网数据流畅管理
本篇文章是“2024,我想和 TDengine 谈谈”征文活动的三等奖作品。文章从一个具体的业务场景出发,分析了企业在面对海量时序数据时的挑战,并提出了利用 TDengine 高效处理和存储数据的方法,帮助企业解决在数据采集、存储、分析等方面的痛点。通过这篇文章,作者不仅展示了自己对数据处理技术的理解,还进一步阐释了时序数据库在行业中的潜力与应用价值,为读者提供了很多实际的操作思路和技术选型的参考。
424 1
|
弹性计算 运维 Serverless
超值选择:阿里云Elasticsearch Serverless在企业数据检索与分析中的高性能与灵活性
本文介绍了阿里云Elasticsearch Serverless服务的高性价比与高度弹性灵活性。
591 8
|
传感器 安全 算法
物联网发布者在数据传输过程中如何防止数据被篡改
在物联网数据传输中,为防止数据被篡改,可采用加密技术、数字签名、数据完整性校验等方法,确保数据的完整性和安全性。
|
存储 安全 算法
物联网发布者在发送数据时如何保证数据的安全性和完整性
数据加密、密钥管理和数据完整性验证是物联网安全的重要组成部分。对称加密(如AES)和非对称加密(如RSA)分别适用于大量数据和高安全需求的场景。密钥需安全存储并定期更新。数据完整性通过MAC(如HMAC-SHA256)和数字签名(如RSA签名)验证。通信协议如MQTT over TLS/SSL和CoAP over DTLS增强传输安全,确保数据在传输过程中的机密性和完整性。
|
消息中间件 缓存 Serverless
在进行实时数据处理时,FaaS 如何保证数据的一致性和处理的实时性?
在进行实时数据处理时,FaaS 如何保证数据的一致性和处理的实时性?

相关产品

  • 物联网平台