作者:三烽
一、資料流轉
1、基本概念
當裝置基于Topic進行通信時,您可以在規則引擎的資料流轉中,編寫SQL對Topic中的資料進行處理,并配置轉發規則将處理後的資料轉發到其他Topic或阿裡雲其他服務。
2、方案對比
規則引擎和服務端訂閱都可以進行資料流轉,兩者的對比詳見文檔
https://help.aliyun.com/document_detail/102335.html3、建立規則
資料類型可選JSON和二進制。因為資料流轉是基于Topic處理資料的,是以資料格式要和被處理Topic中的資料格式保持一緻。【若選擇為二進制,該規則不能處理系統Topic的消息,且不能将資料轉發至表格存儲、時序時空資料庫和雲資料庫RDS版。】

規則詳情頁的配置說明請參考文檔
https://help.aliyun.com/document_detail/42733.html4、SQL表達式舉例說明
産品中有一個屬性為struct,資料類型為結構體,結構體中JSON對象分别是length、height和weight。
要正确提取struct中的各參數值,sql語句應如下所示(注意items的使用,詳見5資料流轉過程)
SQL中的數組使用說明如下所示
【注意事項】
a.SELECT語句中的字段最多支援50個
b.不支援子SQL查詢
c.可以使用SQL内置函數,詳見文檔。
5、資料流轉過程
a.通過自定義topic上傳,透傳結構不變,sql語句中直接填寫payload中的key值。
b.通過系統topic上傳,注意經過物模型解析後的結果,sql語句中要使用items.xxx的形式。
6、資料格式
上傳到系統topic中的資料格式由平台定義,詳見文檔
https://help.aliyun.com/document_detail/73736.html二、資料流轉使用示例
1、資料轉發到另一Topic
https://help.aliyun.com/document_detail/42734.html2、資料轉發到消息隊列(RocketMQ)
https://help.aliyun.com/document_detail/59000.html3、資料轉發到表格存儲(Table Store)
https://help.aliyun.com/document_detail/42735.html4、資料轉發到DataHub
5、資料轉發到雲資料庫(RDS)
https://help.aliyun.com/document_detail/42736.html6、資料轉發到消息服務(Message Service)
https://help.aliyun.com/document_detail/44008.html7、資料轉發到時序時空資料庫(TSDB)
https://help.aliyun.com/document_detail/64143.html8、資料轉發到函數計算(FC)
https://help.aliyun.com/document_detail/64234.html三、場景關聯
場景關聯是規則引擎中,一種開發自動化業務邏輯的可視化程式設計方式,您可以通過可視化的方式定義裝置之間關聯規則,并将規則部署至雲端或者邊緣端。
例如,您每天18:00下班回家。在炎熱的夏天,您希望您到家後,家裡的溫度是涼爽、舒适的。您可以建立一條規則,使空調裝置自動化,實作這個需求。
2、規則配置
請參考文檔
https://help.aliyun.com/document_detail/102241.html