开发者学堂课程【物联网平台云上开发:物联网平台数据流转到函数计算】学习笔记,与课程紧密联系,让用户快速学习知识。
课程地址: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,如图
这部分是要往钉钉群里发布的消息,消息里面的一部分是通过IoT平台推过来的event里获得的一些参数,这一部分是https pose的一个方法,随后进行保存即可。
3、对规则引擎的创建进行回顾:
首先会取一些数据,然后把它流转到了表格里,再这一次添加操作,流转到函数计算里,然后选择函数计算所在的华东2,接着找到创建的IoT2Dingtalk服务,找到对应的函数,拟定一个决策授权,接着点击确定
那这一条规则就是把设备上报的数据通过这样一个circle进行处理,把处理后的数据推送到表格存储;同时把数据推送到函数计算,最终推送到钉钉的消息群里。
此时就需要先停止IoT规则引擎流转再启动,这时启动设备上报一条数据,然后可以看到表格存储里就已经有一条这样的数据生成。这就是通过规则引擎把数据流转到了表格存储里。
同时来看一下钉钉群,这时候钉钉群的机器人也推送过来一条消息,这就完成了数据上报通过规则引擎流转到函数计算,最终推送到钉钉群里。同样在函数计算里,也可以以邮件,短信的方式推送到运营同学手上。