本文介紹如何對接物聯網平台和阿里雲巨量資料平台,以實現裝置資料分析、統計、計算和可視化即時展示。
前提條件
開通、購買相關阿里雲產品執行個體和計算資源。使用阿里雲巨量資料平台處理物聯網平台裝置相關資料,涉及多個阿里雲產品,包括雲資料庫RDS MySQL版、物聯網平台等。
瞭解涉及產品的配置使用方法和注意事項。
背景資訊
任務情境:在DataV可視化大屏上,即時展示物聯網平台某產品下的裝置相關資料。
實現過程:
物聯網平台採集裝置資料。
通過規則引擎,物聯網平台將一個產品下的裝置資料轉寄至流資料處理平台DataHub中。
DataHub根據相關配置,將裝置資料發送至Realtime Compute平台進行計算處理後,再寫入RDS MySQL版資料庫中。(若無需計算處理的資料,可通過DataConnector將資料直接從DataHub 平台同步到雲資料庫RDS MySQL版資料庫中。)
DataV根據配置,以MySQL資料庫表作為資料來源,即時展示相關裝置資料 。
操作步驟
建立一個雲資料庫RDS版MySQL資料庫,用於存放裝置資料。
瞭解雲資料庫RDS版,請參見雲資料庫RDS MySQL版。
登入雲資料庫RDS版控制台。
在雲資料庫管理頁,單擊建立執行個體,建立一個MySQL類型的資料庫執行個體。
說明RDS for MySQL資料庫執行個體的地區須與物聯網平台裝置地區和DataHub專案地區保持一致。
在您的資料庫執行個體列表中,單擊該執行個體對應的管理。
在左側導覽列中,單擊帳號管理,建立資料庫使用者帳號。
在左側導覽列中,單擊資料庫管理,建立資料庫。
在左側導覽列中,單擊資料安全性,添加資料庫白名單。請參見設定IP白名單文檔中的設定方法。
在左側導覽列中,單擊基本資料,查看該資料庫的資訊。
後續步驟中,該資料庫資訊需配置到DataHub、DataV或阿里Realtime Compute開發平台中,用於同步資料。
在基本資料頁上方導覽列中,單擊登入資料庫,輸入資訊登入資料庫。
建立資料庫表。如,表mytable包含兩個欄位:
表 1. mytable
欄位名
類型
說明
d_data
varchar(32)
時間。
device_num
int
活躍裝置數量。
在物聯網平台控制台,建立產品和裝置,並配置規則引擎。
登入物聯網平台控制台。
在執行個體概覽頁簽的全部環境下,找到對應的執行個體,單擊執行個體卡片。
在左側導覽列中,單擊建立產品。 ,然後建立產品。如需協助,請參見
產品建立成功後,進入該產品的產品詳情頁,根據您的業務需要,為產品建立自訂Topic類,定義產品功能(即定義物模型)等。
在左側導覽列中,單擊註冊裝置。 ,然後
在左側導覽列中,單擊 ,建立一條規則。
重要若當前頁面為雲產品流轉新版頁面,需先單擊右上方返回舊版,再單擊目標規則對應的查看。
在規則列表中,單擊規則對應的查看按鈕。
在資料流轉規則頁,單擊處理資料欄的編寫SQL按鈕,為該條規則編寫資料處理SQL,並調試SQL語句。
單擊轉寄資料欄對應的添加操作按鈕,並配置規則動作將裝置資料轉寄至DataHub的Topic中。如需協助,請參見設定資料流轉規則。
規則配置完成後,在雲產品流轉頁的規則列表中,單擊該規則對應的啟動按鈕,啟動規則。
規則啟動後,使用類比裝置發送訊息,檢驗裝置發送的訊息是否成功流轉至DataHub中。可以在裝置的Log Service頁查看裝置日誌;在DataHub控制台對應的Topic中,查看Shards中資料量的變化,並通過資料抽樣功能,可以看到具體的訊息內容。
開發裝置端,串連裝置與物聯網平台。
本例以Java Link SDK為例開發裝置:下載Java SDK Demo。開發方法,請參見環境要求與配置。
裝置端SDK開發完成,並將SDK燒錄至物理裝置中。裝置上電連網後,建立與物聯網平台之間的串連,便可與物聯網平台進行資料交換。資料通過規則引擎轉寄至DataHub中,再經過Realtime Compute處理後,寫入資料庫中。
測試。配置完成之後,使用不同的裝置登入,並發送訊息,大屏展示的活躍裝置數會即時改變。