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

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

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

课程地址: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规则引擎流转再启动,这时启动设备上报一条数据,然后可以看到表格存储里就已经有一条这样的数据生成。这就是通过规则引擎把数据流转到了表格存储里。

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

相关实践学习
【文生图】一键部署Stable Diffusion基于函数计算
本实验教你如何在函数计算FC上从零开始部署Stable Diffusion来进行AI绘画创作,开启AIGC盲盒。函数计算提供一定的免费额度供用户使用。本实验答疑钉钉群:29290019867
建立 Serverless 思维
本课程包括: Serverless 应用引擎的概念, 为开发者带来的实际价值, 以及让您了解常见的 Serverless 架构模式
相关文章
|
26天前
|
物联网 数据管理 Apache
拥抱IoT浪潮,Apache IoTDB如何成为你的智能数据守护者?解锁物联网新纪元的数据管理秘籍!
【8月更文挑战第22天】随着物联网技术的发展,数据量激增对数据库提出新挑战。Apache IoTDB凭借其面向时间序列数据的设计,在IoT领域脱颖而出。相较于传统数据库,IoTDB采用树形数据模型高效管理实时数据,具备轻量级结构与高并发能力,并集成Hadoop/Spark支持复杂分析。在智能城市等场景下,IoTDB能处理如交通流量等数据,为决策提供支持。IoTDB还提供InfluxDB协议适配器简化迁移过程,并支持细致的权限管理确保数据安全。综上所述,IoTDB在IoT数据管理中展现出巨大潜力与竞争力。
40 1
|
3月前
|
运维 监控 Serverless
Serverless 应用引擎产品使用合集之如何查看监控数据
阿里云Serverless 应用引擎(SAE)提供了完整的微服务应用生命周期管理能力,包括应用部署、服务治理、开发运维、资源管理等功能,并通过扩展功能支持多环境管理、API Gateway、事件驱动等高级应用场景,帮助企业快速构建、部署、运维和扩展微服务架构,实现Serverless化的应用部署与运维模式。以下是对SAE产品使用合集的概述,包括应用管理、服务治理、开发运维、资源管理等方面。
|
1月前
|
存储 传感器 监控
理解并利用物联网(IoT)数据的技术探索
【8月更文挑战第11天】物联网数据是数字化转型的重要资源。通过深入理解物联网数据的特性和价值,并采取有效的收集、处理和分析策略,我们可以更好地利用这些数据为企业决策提供支持、优化运营效率、创造新的商业模式并推动数字化转型的深入发展。
|
2月前
|
SQL canal Serverless
Serverless 应用引擎使用问题之每次记录的数据很少,如何不使用外链数据库储存数据
阿里云Serverless 应用引擎(SAE)提供了完整的微服务应用生命周期管理能力,包括应用部署、服务治理、开发运维、资源管理等功能,并通过扩展功能支持多环境管理、API Gateway、事件驱动等高级应用场景,帮助企业快速构建、部署、运维和扩展微服务架构,实现Serverless化的应用部署与运维模式。以下是对SAE产品使用合集的概述,包括应用管理、服务治理、开发运维、资源管理等方面。
|
21天前
|
关系型数据库 Serverless API
神秘的 ADB Serverless 模式,究竟是怎样实现数据共享的?答案等你来揭晓!
【8月更文挑战第27天】在数字化时代,数据共享至关重要。阿里云AnalyticDB for MySQL的Serverless模式提供了一种高效便捷的解决方案。它采用多租户架构,确保数据安全隔离的同时支持资源共享;具备自动弹性伸缩能力,优化资源利用;支持多样化的数据导入导出方式及丰富的API,便于集成到各类应用中,实现数据价值最大化。无论是初创企业还是大型组织,均可从中获益。
36 0
|
1月前
|
监控 Serverless Go
Golang 开发函数计算问题之Go 语言中切片扩容时需要拷贝原数组中的数据如何解决
Golang 开发函数计算问题之Go 语言中切片扩容时需要拷贝原数组中的数据如何解决
|
2月前
|
JSON Java Serverless
函数计算产品使用问题之如何使用Go SDK从HTTP上下文中提取JSON数据
函数计算产品作为一种事件驱动的全托管计算服务,让用户能够专注于业务逻辑的编写,而无需关心底层服务器的管理与运维。你可以有效地利用函数计算产品来支撑各类应用场景,从简单的数据处理到复杂的业务逻辑,实现快速、高效、低成本的云上部署与运维。以下是一些关于使用函数计算产品的合集和要点,帮助你更好地理解和应用这一服务。
|
2月前
|
物联网
好的资源链接,gitee全糖咖啡,B站视频转成mp4,全糖咖啡 / 物联网网关数据上传,,全糖咖啡 / springboot+百度智能车牌检测
好的资源链接,gitee全糖咖啡,B站视频转成mp4,全糖咖啡 / 物联网网关数据上传,,全糖咖啡 / springboot+百度智能车牌检测
|
3月前
|
关系型数据库 MySQL Serverless
实时计算 Flink版产品使用问题之使用cdas语法同步mysql数据到sr serverless是否支持动态加表
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
|
3月前
|
JSON Serverless 开发工具
函数计算产品使用问题之要使用Python写入时序数据到阿里云表格存储时序表,该怎么办
函数计算产品作为一种事件驱动的全托管计算服务,让用户能够专注于业务逻辑的编写,而无需关心底层服务器的管理与运维。你可以有效地利用函数计算产品来支撑各类应用场景,从简单的数据处理到复杂的业务逻辑,实现快速、高效、低成本的云上部署与运维。以下是一些关于使用函数计算产品的合集和要点,帮助你更好地理解和应用这一服务。

相关产品

  • 物联网平台