全部產品
Search
文件中心

IoT Platform:雲產品流轉概述

更新時間:Jun 30, 2024

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

什麼是雲產品流轉

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

資料目的說明相關文檔
Topic將資料轉寄到另一個裝置的Topic中,實現裝置間的M2M通訊資料轉寄到另一Topic
AMQP消費組通過AMQP服務端訂閱消費組,將裝置訊息流程轉到您的商務服務器上。
RDS將裝置資料轉寄到雲產品中進行儲存。資料轉寄到雲資料庫RDS
Tablestore資料轉寄到Table Store(Tablestore)
TSDB資料轉寄到時序資料庫(TSDB)
RocketMQ將裝置資料轉寄到訊息佇列RocketMQ、Message ServiceMNS實現高可靠消費資料。資料轉寄到訊息佇列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次重試均失敗後,訊息會被丟棄,同時會向您指定的轉寄錯誤資料的目標雲產品發送一條錯誤記錄。

  • 對於被限流的訊息,系統會自動重試處理,多次重試失敗的資料會被丟棄。

流轉目標要求

資料轉寄依賴目標雲產品,需確保目標雲產品執行個體正常。目標雲產品的執行個體宕機、欠費、參數錯誤(如授權變更、值非法)、配置錯誤等異常狀況會導致訊息流程轉失敗。

訊息去重

資料流轉時,為確保訊息送達,同一條訊息可能重複發送,直到用戶端返回ACK或訊息到期。同一條訊息的訊息ID相同,您可根據訊息ID去重。

使用指南

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

相關文檔

雲產品流轉(新版)