物联网平台提供新版云产品流转服务,支持编辑脚本处理设备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 数据转发到消息服务
函数计算 将设备数据转发到函数计算中进行事件计算。 数据转发到函数计算

数据流转流程

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

数据流转-中国站

使用说明

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

使用限制

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

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

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

100

使用流程

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

相关文档

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