在企業IoT業務場景中,往往需要将裝置上報到IoT物聯網平台的資料進行加工處理,存儲到資料庫中,以便供業務系統使用。物聯網平台提供了3種擷取資料的方式:
- -通過阿裡雲POP API擷取裝置資料
- -通過HTTP/2服務端訂閱取裝置資料
- -通過規則引擎配置流轉資料到雲産品
方案一、阿裡雲POP API擷取裝置資料
參考
https://www.yuque.com/cloud-dev/iot-tech/upqoog方案二、HTTP/2服務端訂閱 (2019年12月5日更新:現已更新成AMQP服務端訂閱)
https://www.yuque.com/cloud-dev/iot-tech/cev3cn方案三、使用規則引擎詳解
規則引擎提供初級的資料過濾轉換能力,支援對裝置資料進行過濾并轉換,然後再流轉到其他雲産品執行個體。

上圖展示了規則引擎對接的雲産品,主要包含消息隊列産品(MQ,MNS),資料庫産品(關系型資料庫RDS,表格存儲OTS,時序時空資料庫TSDB)和實時處理産品(函數計算FC,Datahub)。
規則引擎執行個體
完整規則引擎包含如下圖3部分:處理資料,正常轉發資料,轉發錯誤時流轉。
資料處理SQL
規則引擎的資料處理支援類SQL文法,可以處理裝置上下文資料和消息Payload資料。文法規則如下:
SQL配置頁面如下:
資料轉發配置
資料轉發異常時流轉配置
規則引擎相關文檔
規則引擎介紹文檔:
https://help.aliyun.com/document_detail/68677.htmlSQL表達式
https://help.aliyun.com/document_detail/30554.html内置SQL函數清單:
https://help.aliyun.com/document_detail/30555.html物模型(/sys/)Topic的資料結構文檔:
https://help.aliyun.com/document_detail/73736.html消息體Payload的資料結構變換過程
自定義Topic
物模型Topic(/sys/開頭Topic)
注:原始payload經過物模型處理後,結構會變化,SQL要根據物模型payload來編寫