使用IoT云上大屏展示物聯網設備的實時數據監測

使用IoT云上大屏展示物聯網設備的實時數據監測

創建虛擬私有云虛擬私有云-控制臺 (huaweicloud.com)

基本信息：

區域：華北-北京四

名稱：vpc-nice(自定義)

IPv4網段 建議使用網段: 10.0.0.0/8-24 或者172.16.0.0/12-24

高級配置：默認

默認子網：

可用區：可用區1

名稱：subnet-nice(自定義)

子網IPv4網段：10-0-0-0/24

子網IPv6網段：不開啟

關聯路由表：默認

高級配置：默認

立即創建

購買彈性公網IP

購買彈性公網IP (huaweicloud.com)

計費模式：按需計費

區域：華北-北京四

線路：全動態BGP

公網帶寬：按流量計費

帶寬大?。?00

IPv6轉換：不開啟

彈性公網IP名稱：ip-nice

高級配置：

帶寬名稱：

bandwidth-nice

標簽：不設置

購買量：1

立即購買，記下彈性公網ip的地址

創建一個MapReduce點擊此處

區域：華北-北京四

集群名稱：mrs_nice(自定義)

集群版本：MRS 1.9.2

集群類型：分析集群

分析組件：默認必選Hadoop，同時勾選Spark、Hive、Tez

元數據：本地元數據

進入下一步：硬件配置

計費模式：按需計費

可用區：可用區1

虛擬私有云：選擇創建好的vpc-nice

子網：創建好的子網subnet-nice

安全組：自動動創建

彈性公網IP：預先創建的ip

集群節點：最小規格默認配置

配置如圖。

標簽、主機名前綴、彈性伸縮、引導操作暫不設置

委托使用MRS_ECS_DEFAULT_AGENCY

告警：開啟

規則名稱：默認

主題名稱：創建主題

主題名稱：mrs_info

顯示名：mapreduce

標簽：不設置

回到mrs創建界面，點擊右側選擇mrs_info

日志記錄：開啟

Kerberos認證：關閉

用戶名：admin

密碼：Admin@20220214

登錄方式：密碼

用戶名：root

密碼：Root@20220214

通信安全授權：確認授權

創建成功后查看詳情

創建桶

Console (huaweicloud.com)

區域：華北-北京四

桶名稱：ton-0214

數據冗余策略：多AZ存儲

默認存儲類別：標準存儲

桶策略：私有

默認加密：關閉

歸檔數據直讀：關閉

數據接入服務(Data Ingestion Service)_DIS_實時數據_Kafka-華為云 (huaweicloud.com)

計費模式：按需計費

區域：華北-北京四

通道名稱：dis-0214（自定義）

通道類型：普通

分區數量：1

生命周期 (小時)：24

源數據類型：JSON

自動擴縮容：關

Schema：關

高級配置：暫不配置

通道購買成功后，進入DIS控制臺“接入管理 > 通道管理”頁面。

單擊需要查看的通道名稱，進入所選通道的管理頁面，選擇“轉儲任務”頁簽。

單擊“添加轉儲任務”按鈕。

訪問設備接入服務，單擊“管理控制臺”進入設備接入控制臺。

選擇左側導航欄的“產品”

單擊右上角的“創建產品”，創建一個基于MQTT協議的產品，填寫參數后，單擊“確認”。

獲取產品ID為：620b136ac7fb24029b11ff82.

單擊Profile.zip，獲取產品模型文件樣例。

在產品詳情->模型定義頁面，單擊“上傳模型文件”，在彈出的頁面中加載產品模型文件，然后單擊“確認”。

選擇左側導航欄的“設備>所有設備”，單擊右上角的“注冊設備”，填寫設備注冊參數。

填寫完成后單擊“確定”，請注意保存注冊成功返回的“設備ID”和“設備密鑰”。

設備ID

620b136ac7fb24029b11ff82_202202151045

設備密鑰

MQTTDevice_20220215

選擇左側導航欄的“規則>數據轉發”，單擊右上角的“創建規則”。

注：您也可以基于已經創建的規則，在規則詳情頁面，添加新的轉發目標MySQL。

參考下表參數說明，填寫規則內容。以下參數取值僅為示例，您可參考

用戶指南創建自己的規則，填寫完成后單擊“創建規則”。

數據轉發規則創建成功，并分配以下規則ID：

9954ccb5-88a3-4dc9-9e16-4ee8802a52a5

請您繼續設置轉發目標，完成規則的完整定義

單擊“設置轉發目標”頁簽，單擊“添加”，設置轉發目標。

單擊“啟動規則”，激活配置好的數據轉發規則。

圖2 激活規則

配置數據可視化服務，新建數據報表視圖。

登錄華為云官方網站，訪問數據可視化服務。

單擊“進入控制臺”。也可體驗試用。

訪問DLV控制臺“我的大屏”頁面，新建一個大屏。

選擇空白模板，輸入大屏名稱后（如mrs_nice_screen），單擊“創建大屏”。

單擊“文本 > 標題”新增一個標題。

在右側“數據”面板修改靜態數據中“value”的值為“每日銷量”。

在大屏內拖動標題到左上角，并拉伸成合適的形狀。

單擊“常用圖表 > 線狀圖”新增一個線狀圖報表。

拖動圖表到標題下面并拉伸成合適的形狀。

重復以上步驟再添加一個標題為“時間段銷量”柱狀圖，一個標題為“種類銷量”的餅狀圖，一個標題為“地區銷量”的區域排行圖，并根據自己的需要設置圖表的樣式。最終效果類似下圖。

單擊頁面右上角的按鈕退出編輯頁面。

首先控制設備上報10條數據。

您可以使用配置設備接入服務時注冊的真實設備接入平臺，上報數據。

您也可以使用模擬器模擬設備上報數據。

這里以MQTT.fx虛擬設備方式為例

在Huaweicloud IoTDA Mqtt ClientId Generator (myhuaweicloud.com)生成接入信息

打開MQTT.fx軟件

在設備接入-控制臺 (huaweicloud.com)獲取設備對接地址。

ping 獲取ip地址

上報數據的樣例如下，請自行修改參數的取值模擬真實設備數據：

樣例1

{ "services": [{ "service_id": "sales", "properties": { "category": "juice", "number": 2, "area": "SZFT" }, "event_time": "20190426T170005Z" }] }

上述樣例表示UTC時間2019年4月25日9點11分57秒深圳羅湖的自動販賣機賣出了一支碳酸飲料。

樣例2

{ "services": [{ "service_id": "sales", "properties": { "category": "juice", "number": 2, "area": "SZFT" }, "event_time": "20190426T170005Z" }] }

上述樣例表示UTC時間2019年4月26日17點05秒深圳福田的自動販賣機賣出了兩支果汁飲料。

本文以上報下表的數據為例。

NO.1

{ "services": [{ "service_id": "sales", "properties": { "category": "soda", "number": 1, "area": "SZLH" }, "event_time": "20190425T091157Z" }] }

NO.2

{ "services": [{ "service_id": "sales", "properties": { "category": "juice", "number": 1, "area": "SZFT" }, "event_time": "20190425T121511Z" }] }

NO.3

{ "services": [{ "service_id": "sales", "properties": { "category": "sport", "number": 1, "area": "SZLH" }, "event_time": "20190425T172433Z" }] }

NO.4

{ "services": [{ "service_id": "sales", "properties": { "category": "juice", "number": 2, "area": "SZFT" }, "event_time": "20190426T170005Z" }] }

NO.5

{ "services": [{ "service_id": "sales", "properties": { "category": "soda", "number": 1, "area": "SZNS" }, "event_time": "20190426T190905Z" }] }

NO.6

{ "services": [{ "service_id": "sales", "properties": { "category": "juice", "number": 1, "area": "SZNS" }, "event_time": "20190427T085959Z" }] }

NO.7

{ "services": [{ "service_id": "sales", "properties": { "category": "juice", "number": 2, "area": "SZLH" }, "event_time": "20190427T111111Z" }] }

NO.8

{ "services": [{ "service_id": "sales", "properties": { "category": "soda", "number": 3, "area": "SZFT" }, "event_time": "20190428T182215Z" }] }

NO.9

{ "services": [{ "service_id": "sales", "properties": { "category": "sport", "number": 1, "area": "SZLH" }, "event_time": "20190429T205901Z" }] }

NO.10

{ "services": [{ "service_id": "sales", "properties": { "category": "soda", "number": 1, "area": "SZLG" }, "event_time": "20190430T225045Z" }] }

其余以此類推，發送下表數據

登錄MRS管理控制臺，選擇“集群列表 > 現有集群”，單擊集群名進入集群管理頁面。

單擊頁面上方的“文件管理”，再單擊“HDFS文件列表”，進入轉儲文件目錄（例如“temp”）查看是否存在轉儲的數據文件。

**注：**DIS會將數據合并轉發，所以此處的文件數量和上報的數據條數可能會不一致。

單擊頁面上方的“作業管理”，在“作業”頁簽中單擊“添加”，配置作業信息。本示例中創建一個spark類型的作業，實現分析設備上報數據，分別按日期、時間段、種類、區域統計銷量，將分析結果輸出為CSV文件并保存至OBS。

配置完成后單擊“確定”啟動作業，等待成功

作業完成后，可在OBS桶內看到output文件夾，里面有四個文件夾，每個文件夾內有一個“_SUCCESS”文件和一個“part”開頭的csv文件。

**注：**本實驗的樣例程序分析數據時會將UTC時間轉換為本地時間，因此數據分析結果中的日期與時間段數值會和上報時的數值不一致。

登錄華為云官方網站，訪問數據可視化服務。

單擊“進入控制臺”。

單擊“我的數據 > 新建數據連接” ，在“新建數據連接”頁面左側的數據庫類型中，選擇“CSV文件”，按照下表的數據規劃填寫配置后單擊“確定”。重復本步驟建立4個數據連接。

返回“我的大屏”頁簽，單擊配置數據可視化服務時創建的大屏右下的按鈕進入編輯頁面。

選中“每日銷量”表，在右側數據面板選擇數據類型為“CSV文件”，數據連接選擇步驟8添加的數據連接“salesByDate”。

根據響應數據的屬性名稱配置字段映射。

配置 “x”為 “saleDate”， “y”為 “saleNumber”。

選中“時間段銷量”表，在右側數據面板選擇數據類型為“CSV文件”，數據連接選擇步驟8添加的數據連接“salesByTime”。

根據響應數據的屬性名稱配置字段映射。

配置 “x”為 “saleTime”， “y”為 “saleNumber”。

選中“種類銷量”表，在右側數據面板選擇數據類型為“CSV文件”，數據連接選擇步驟8添加的數據連接“salesByCategory”。

根據響應數據的屬性名稱配置字段映射。

配置 “s”為 “category”， “y”為 “saleNumber”，并設置各個分類的名稱（本示例中為“soda”，“juice”，“sport”）和圖例的顏色。

選中“地區銷量”表，在右側數據面板選擇數據類型為“CSV文件”，數據連接選擇步驟8添加的數據連接“salesByArea”。

根據響應數據的屬性名稱配置字段映射。

配置 “num”為 “saleNumber”。

全部圖表配置完成后，單擊頁面右上角的預覽

可預覽報表，示例如下圖。

本案例已創建分享鏈接，如下：mrs_nice_screen (huaweicloud.com)

至此，本次體驗全部完成。

API MapReduce

版權聲明：本文內容由網絡用戶投稿，版權歸原作者所有，本站不擁有其著作權，亦不承擔相應法律責任。如果您發現本站中有涉嫌抄襲或描述失實的內容，請聯系我們jiasou666@gmail.com 處理，核實后本網站將在24小時內刪除侵權內容。

版權聲明：本文內容由網絡用戶投稿，版權歸原作者所有，本站不擁有其著作權，亦不承擔相應法律責任。如果您發現本站中有涉嫌抄襲或描述失實的內容，請聯系我們jiasou666@gmail.com 處理，核實后本網站將在24小時內刪除侵權內容。