全部產品

IoT Platform：雲產品流轉概述

更新時間：Oct 25, 2024

物聯網平台提供雲產品流轉服務，支援通過SQL指令碼處理裝置Topic資料，並將資料轉寄至其他Topic或其他阿里雲產品進行儲存或處理。

什麼是雲產品流轉

裝置基於Topic與物聯網平台進行通訊時，您可以在資料流轉中，編寫SQL對Topic中的資料進行處理，並配置轉寄規則將處理後的資料轉寄到其他裝置Topic或阿里雲其他服務。

資料目的	說明	相關文檔
Topic	將資料轉寄到另一個裝置的Topic中，實現裝置間的M2M通訊	資料轉寄到另一Topic
AMQP消費組	通過AMQP服務端訂閱消費組，將裝置訊息流程轉到您的商務服務器上。	AMQP用戶端接入說明資料轉寄到AMQP服務端訂閱消費組
RDS	將裝置資料轉寄到雲產品中進行儲存。	資料轉寄到雲資料庫RDS
Tablestore		資料轉寄到Table Store（Tablestore）
TSDB		資料轉寄到時序資料庫（TSDB）
RocketMQ	將裝置資料轉寄到訊息佇列RocketMQ、Simple Message Queue (formerly MNS) (SMQ)實現高可靠消費資料。	資料轉寄到訊息佇列RocketMQ
MNS		資料轉寄到Message Service（MNS）
Function Compute	將裝置資料轉寄到Function Compute中進行事件計算。	資料轉寄到Function Compute（FC）

資料流轉流程

使用雲產品流轉功能流轉資料，您無需購買伺服器部署分布式架構，即可實現採集、計算、儲存的全棧服務。

使用說明

使用物聯網平台提供的服務端訂閱和雲產品流轉服務，均可實現裝置資料流轉。您可根據實際業務情境，選擇合適的流轉方案。具體說明，請參見資料流轉方案對比。
使用雲產品流轉功能將裝置資料轉寄至其他阿里雲產品時，需確認目的雲產品已經在該地區上線，並且支援相應格式資料的轉寄。具體說明，請參見各地區功能說明。

限制說明

限制項	描述	限制
規則數量	一個執行個體下最多可以設定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次重試均失敗後，訊息會被丟棄，同時會向您指定的轉寄錯誤資料的目標雲產品發送一條錯誤記錄。對於被限流的訊息，系統會自動重試處理，多次重試失敗的資料會被丟棄。	舊版公用執行個體：2,000 TPS。受公用單元的資源限制影響，存量舊版公用執行個體規格上限會變更且不再支援擴容，具體說明，請參見舊版公用執行個體規格上限變更。新版公用執行個體：5 TPS。企業版執行個體：查看執行個體的可用資源
流轉目標要求	資料轉寄依賴目標雲產品，需確保目標雲產品執行個體正常。目標雲產品的執行個體宕機、欠費、參數錯誤（如授權變更、值非法）、配置錯誤等異常狀況會導致訊息流程轉失敗。	無
訊息去重	資料流轉時，為確保訊息送達，同一條訊息可能重複發送，直到用戶端返回ACK或訊息到期。同一條訊息的訊息ID相同，您可根據訊息ID去重。	無

使用指南

設定資料流轉規則：如何設定一條資料轉寄規則。
SQL運算式：規則中SQL運算式的寫法詳解。
函數列表：規則中SQL運算式支援的函數列表。
資料流轉過程：進行資料流轉的過程和各階段的資料格式。
資料格式：基礎通訊Topic、物模型通訊Topic訊息經物模型解析後的資料格式。資料流轉規則中，SQL欄位需按照解析後的資料格式編寫。

相關文檔

雲產品流轉（新版）