想象这样一个场景：设备上包的数据比如马路上的摄像头拍照数据；冰箱的温度数据；活着是零售柜的实时销售数据。这些数据上传给我们的业务系统后台后我们需要转发到大数据部门给他们做数据分析和舆情分析或者是深度学习，那么在这种业务场景下我们怎么实现数据的扭转呢？
其实这就是阿里云物联网平台的“云产品流转”。
顾名思义你只能选着你已经购买的云产品去流转，比如tsdb，rds，rocketmq等。


1-数据源

1.1-创建数据源

image.png

1.2-添加数据源输入的topic

image.png

2-数据目的

2.1-创建数据流转的目的（目标更准确）

image.png
当然前提是你已经拥有的一个RcoketMq的云产品实例

3-解析器

3.1-创建数据的解析器

image.png

3.2-关联数据

image.png3.2.1-关联数据源

image.png

3.2.2-关联数据目的

image.png

image.png3.3.3-编写解析脚本

所谓解析脚本其实是数据上报的时候的处理规则，比如如果室内报警器的温度大于35度我就处理不然不处理。
image.png

  1. //当温度大于30的时候才流转到我的的RocketMQ
  2. //通过payload函数，获取设备上报的消息内容，并按照JSON格式转换。
  3. var data = payload("json"); //筛选出上报的温湿度值。
  4. var t = data.items.Temperature.value;// 设置温度值大于30时触发规则， 流转到我的的RocketMQ
  5. if (t > 30) { 
  6.    writeMq(1003, data, "Temperature");//这里的1002是上一步创建数据目的id
  7.  }

解析脚本不能为空 我也不知道为什么不能为空

具体的脚本语法见阿里云文档：https://help.aliyun.com/document_detail/270937.html
3.3.4-启动解析解析器

image.png
image.png

4-数据上报测试

4.1-mqtt.fx上报数据

image.png

4.2-阿里云日志

image.png
有两个操作日志，先设备给物联网发消息然后物联网通过规则引擎转发到我们设置的解析规则中
image.png
image.png和之前的api 方式发送消息远程控制是一样的有两条操作日志，messageID不一样但是traceId是一样的。

4.3-RocketMq日志

image.png