物聯網平臺設備資料同步到RDS & MySQL資料庫(保姆級教學)
目標實作:
阿里云物聯網平臺某設備實時資料(MQTT協議上云)同步存盤到RDS MySQL資料庫
實作步驟:
注意:以下實作默認MQTT上云已經完成,可實時上傳資料
1、物聯網平臺接收到資料通過規則引擎轉發至DataHub,
2、在DataHub中通過DataConnector將資料同步到RDS MySQL資料庫中
阿里云教程概述

細節!!!拿來吧你!
1、創建RDS MySQL資料庫表
這步的依據是什么?
答:物聯網平臺的設備有什么資料?以我這邊的情況為例,有甲醛、PM2.5,

請思考:是不是現在新建一張資料表,表中創建兩個就可以欄位,分別是HCHO(甲醛)、PM25(PM2.5)就可以了呢?
答:表結構實際上有點問題,因為這樣的話那主鍵未明確,后面還要查出來看的,不單單是存著就好,于是這里決定再加一個欄位id作為主鍵(或許也可考慮復合主鍵,),并設定自動遞增,因為原設備上云資料中沒有對應id的值,然后可以再加兩個欄位create_time 和 devicename,create_time 和 devicename的值可通過阿里云內置函式獲取,后面會講到,

至此,第一步就完成了
2、創建DataHub專案
DataHub通俗理解:它是一條線,把兩個阿里云的產品連起來,通過一些轉發規則完成產品之間的資料流轉(我瞎扯的可能不準確,具體可看官網檔案)
1、開通服務(有個梗:這游戲求你下一個吧,不用錢好吧)
2、創建專案

點擊新建專案,隨便填,我這里填專案名alice_air

3、新建Topic
Topic通俗理解:一個話題,物聯網平臺后面需要去訂閱這個話題,把資料同步到Datahub

4、同步到RDS MySQL資料庫
注意:我這里先配完DataHub同步資料庫,后配置物聯網同步到DataHub,當然你也可以先配物聯網同步到DataHub,看看DataHub有沒有實時流量顯示
點擊查看

點擊同步

選擇RDS & MySQL

新建Connector(配置對應的MySQL Host,資料庫、資料表)

至此,第二步也完成了,
3、規則引擎
這步是為了把物聯網平臺資料轉發到DataHub
1、云產品流轉

2、創建規則

3、選擇json(我這邊設備資料是通過json格式上云)

4、撰寫SQL


5、轉發資料到DataHub,添加規則


注意:${key},key是什么,key就是撰寫SQL時,as xxx 的那個xxx
items.HCHO.value as HCHO ==> ${HCHO}
最后確定,完美撒花?NO,注意,記得啟動,這下應該完美撒花了,

經過以上步驟,如果資料庫并沒有新增任何資料記錄,可一步一步排查問題,
1、先確定設備資料是不是在實時上傳,在物聯網平臺查看設備物模型資料
2、看看DataHub有沒顯示實時流量資料,沒有的話說明云產品流轉這塊沒弄好
3、如果DataHub有資料流量顯示了,說明很可能是配置MySQL資料庫有問題,看看賬號密碼,host地址,和網路型別等,
轉載請註明出處,本文鏈接:https://www.uj5u.com/qita/290167.html
標籤:其他
下一篇:初識5G——揭開5G的神秘面紗
