全部产品
Search
文档中心

阿里云物联网平台:云产品流转概述

更新时间:Sep 14, 2024

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

什么是云产品流转

设备基于Topic与物联网平台进行通信时,您可以在数据流转中,编写SQL对Topic中的数据进行处理,并配置转发规则将处理后的数据转发到其他设备Topic或阿里云其他服务。

数据目的

说明

相关文档

Topic

将数据转发到另一个设备的Topic中,实现设备间的M2M通信

数据转发到另一Topic

AMQP消费组

通过AMQP服务端订阅消费组,将设备消息流转到您的业务服务器上。

RDS

将设备数据转发到云产品中进行存储。

数据转发到云数据库RDS

Tablestore

数据转发到表格存储(Tablestore)

TSDB

数据转发到时序数据库(TSDB)

RocketMQ

将设备数据转发到消息队列RocketMQ、轻量消息队列(原 MNS) SMQ(Simple Message Queue (formerly MNS))实现高可靠消费数据。

数据转发到消息队列RocketMQ

MNS

数据转发到消息服务(MNS)

函数计算

将设备数据转发到函数计算中进行事件计算。

数据转发到函数计算(FC)

数据流转流程

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

image

使用说明

  • 使用物联网平台提供的服务端订阅和云产品流转服务,均可实现设备数据流转。您可根据实际业务场景,选择合适的流转方案。具体说明,请参见数据流转方案对比

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

限制说明

限制项

描述

限制

规则数量

一个实例下最多可以设置1,000条规则。

1,000

流转目标数量

一条规则中转发数据的操作不能超过10个。

10

消息转发处理消息量

  • 新版和旧版公共实例:一个阿里云账号下,消息转发TPS为固定值。

  • 企业版实例:一个实例下消息转发处理消息量,由购买的消息转发TPS规格决定。

    购买企业版实例说明,请参见购买企业版实例

RAM用户共享阿里云账号配额。

消息转发TPS说明:

消息转发TPS=每秒钟通过服务端订阅发送到您的业务服务器的消息数量+云产品流转发送的消息数量

同一秒内,可能n条消息流转至消息转发,然后从消息转发流转到m个目的地,消息转发TPS计算规则为:

  • n>=m时,消息转发TPS计为n

  • n<m时,消息转发TPS计为m

说明
  • 对于流转至云产品的消息量,如果请求量超出该限制,或目标云产品写入耗时过高导致同一时刻写入请求量超出40个,数据转发会被限流。

    转发到RocketMQ、RDS、TSDB等类型的云产品时,若云产品资源变化导致目的云产品无法访问,系统会停止执行转发,并显示规则异常信息;其他异常情况,系统会间隔1秒、3秒、10秒进行3次重试,3次重试均失败后,消息会被丢弃,同时会向您指定的转发错误数据的目标云产品发送一条错误记录。

  • 对于被限流的消息,系统会自动重试处理,多次重试失败的数据会被丢弃。

流转目标要求

数据转发依赖目标云产品,需确保目标云产品实例正常。目标云产品的实例宕机、欠费、参数错误(如授权变更、值非法)、配置错误等异常状况会导致消息流转失败。

消息去重

数据流转时,为确保消息送达,同一条消息可能重复发送,直到客户端返回ACK或消息过期。同一条消息的消息ID相同,您可根据消息ID去重。

使用指南

  • 设置数据流转规则:如何设置一条数据转发规则。

  • SQL表达式:规则中SQL表达式的写法详解。

  • 函数列表:规则中SQL表达式支持的函数列表。

  • 数据流转过程:进行数据流转的过程和各阶段的数据格式。

  • 数据格式:基础通信Topic、物模型通信Topic消息经物模型解析后的数据格式。数据流转规则中,SQL字段需按照解析后的数据格式编写。

相关文档

云产品流转(新版)