物联网平台提供新版云产品流转服务,支持编辑脚本处理设备Topic数据,并将数据消息转发至其他Topic或其他阿里云产品进行存储或处理。

什么是云产品流转

旧版云产品流转介绍,请参见云产品流转(旧版)

与旧版云产品流转相比,新版云产品流转提供脚本解析器服务,可加工处理更复杂的消息数据后与云产品交互。例如在一个解析器中,可以配置多个Topic作为数据源,通过脚本加工后流转到其他Topic或云产品中。

支持流转的数据目的如下:

数据目的说明相关文档
Topic将数据转发到另一个设备的Topic中,实现设备间的M2M通信数据转发到另一Topic
AMQP消费组通过AMQP服务端订阅消费组,将设备消息流转到您的业务服务器上。
RDS将设备数据转发到云产品中进行存储。数据转发到云数据库RDS
Tablestore
TSDB数据转发到时序数据库(TSDB)
Lindorm将设备数据转发到云产品中进行存储。数据转发到时序数据库(Lindorm)
DataHub将设备数据转发到DataHub中,然后使用实时计算进行流计算;使用MaxCompute进行大规模离线计算。数据转发到DataHub
RocketMQ将设备数据转发到消息队列RocketMQ、消息服务MNS实现高可靠消费数据。数据转发到消息队列RocketMQ
MNS数据转发到消息服务(MNS)
函数计算将设备数据转发到函数计算中进行事件计算。数据转发到函数计算(FC)

数据流转流程

使用云产品流转功能流转数据,您无需购买服务器部署分布式架构,即可实现采集、计算、存储的全栈服务。

数据流转-中国站

使用说明

使用云产品流转功能将设备数据转发至其他阿里云产品时,需确认目的云产品已经在该地域上线,并且支持相应格式数据的转发。具体说明,请参见各地域功能说明

使用限制

云产品流转(新版)消息相关的限制与云产品流转(旧版)限制说明中消息相关的限制相同。

限制项描述限制
解析器一个实例最多包含解析器总数。 1,000
数据源一个解析器最多关联数据源总数。1
一个数据源最多包含Topic总数。1,000
数据目的一个解析器最多关联数据目的总数。10
一个数据目的最多包含的操作总数。1
一个解析器最多关联异常数据目的总数。1
解析脚本一个解析器的脚本内容大小限制。120 KB
一个解析器的脚本中循环执行流转函数的最大次数。

流转函数详细信息,请参见流转数据到数据目的函数

100

使用流程

  1. 创建数据源:添加待转发的消息Topic作为数据源。一个数据源支持添加多个Topic。
  2. 创建数据目的:添加数据转发的目的Topic或云产品。
  3. 配置并启动解析器:创建解析器,关联已添加的数据源和数据目的,配置解析器脚本,加工处理数据源并实现数据流转。

相关文档

  • 脚本语法:解析器脚本的编辑和语法说明。
  • 函数列表:解析器脚本中支持的函数列表。
  • 数据格式:基础通信Topic、物模型通信Topic消息经物模型解析后的数据格式。解析器脚本中字段需按照解析后的数据格式编写。