概覽概覽

在工業環境中,許多工業傳感器(PLCs)在不同協議中生成時間序列數據。工業網關軟件Neron* 可以解析這些協議。規則引擎 eKuiper* 可以設置數據流的過濾器和算法。 EMQX是MQT信息經紀人,提供高度可用和高性能的信息服務。 數據隨后流入用于數據存儲和監測的ITC Intel?é Edge Insights(Intel* EII)數據庫。

選定配置 下載下下載工業3.0的邊緣透視,并使用時間序列使用案例,然后遵循以下步驟開始吧

配置 下載

目標系統要求

最低系統要求:

第8代或第8代以上Intel Atom處理器、Intel CoreTM處理器或Intel Xeon處理器。

至少4GB內存。

至少128GB硬盤。

互聯網連接。

烏本圖* 20.04

如何運作

工業的邊緣透視 工業使用的TICK數據序列分析器。Telegraf*、Influction DB*和Grafana*是ITK Intelé EI堆的一部分。在這種使用情況下,工業協議網關軟件Neuron、規則引擎eKuiper和MQTT信息經紀人EMQX可以在Telegraf 之前在Tick堆中采集各種工業數據。

The high-level flow of data is as follows: Modbus Simulator -> Neuron -> eKuiper -> EMQX -> Telegraf -> InfluxDB -> Grafana.

Modbus模擬器在Modbus TCP中生成發電廠的時間序列數據。

中子剖析 Modbus TCP 數據 。

eKuiper通過添加規則和算法處理數據流。

EMQX 以 Pub/Sub 模式在 MQTT 協議中重新發布消息 。

Telegraf 配置為輸入 MQTT 并訂閱 EMQX 的數據 。

流入量DB與Telegraf連接以存儲數據。

Grafana用于數據可視化和監測。

當使用 EMQ IoT 信息軟件與 Intel EI 使用時, 所有模塊都在同一個節點上運行 。

Figure 1: Architecture Diagram

開始

先決條件

選定配置 下載以時間序列使用案例下載工業3.0的邊緣透視。 關于要求和安裝步驟,請參見工業啟動指南的邊緣透視.

配置 下載

第1步:用EMQ運行 EII 時間序列

生成 EI 時間序列部署和配置文件 :

cd [WORK_DIR]/IEdgeInsights/build 
python3 builder.py -f usecases/time-series.yml

用新配置構建 ia_telegraf。 替換[工作_dir]/對應視覺/遠程/配置/遠程/遠程/遠程.conf與Telegraf.conf配置 MQTT 輸入插件。

cd [WORK_DIR]/IEdgeInsights/build
docker-compose -f docker-compose-build.yml build --no-cache ia_telegraf

如果任何服務在建設期間失敗, 運行以下命令以重建服務 。 在這種情況下,以 _ eiibase和常見(_公)之前要求的建設 ia_telegraf:

docker-compose -f docker-compose-build.yml build --no-cache 

獲取docker- competable. yml 轉換器EMQ 軟件docker- competable. yml 轉換器替換[工作_dir]/前置視覺/建筑/多克合成.yml和新的一個。

啟動 EMQX 的 EII 時間序列使用大小寫 :

cd [WORK_DIR]/IEdgeInsights/build
./eii_start.sh

檢查是否所有服務都已啟動 :

docker ps

啟動 Modbus 模擬器power_plant_modbus_simulator.py:

sudo pip3 install pymodbus==2.5.3
sudo python3 ./power_plant_modbus_simulator.py

第2步:配置新元

登錄到 Neuron 網絡控制臺http://localhost:7000 與 用戶名 :管理員and 密碼 :000.0。

添加名為南端設備Name電池電池庫以及 a 和 a模式bus-tcp插件 。

點擊點擊設備配置會 議 日 程 和 議 程電池電池庫選項卡以添加配置。將 IP 地址更改為主機 IP 。

點擊電池電池庫選項卡中導入預定義列表upload-tag-template.xlsx.

點擊數據流處理選項卡。添加南設備電池的訂閱量。

步驟3:配置 eKuiper

在容器中安裝依賴關系:

sudo docker exec -it ekuiper /bin/bash 
pip install numpy==1.22.3 -i http://pypi.douban.com/simple/ --trusted-host pypi.douban.com 
pip install scipy==1.8.0 -i http://pypi.douban.com/simple/ --trusted-host pypi.douban.com

下載插件BatteryAlgs.zip和bcmath.zip。從主機復制到容器。

sudo docker cp ./bcmath.zip ekuiper:/kuiper/bcmath.zip
sudo docker cp ./BatteryAlgs.zip ekuiper:/kuiper/BatteryAlgs.zip

登錄到 ekuiper 網絡控制臺http://localhost:9082,與 用戶名 :管理員and 密碼 :公開。

添加服務電源_ 電源_ 電源_ 電源_ 電源_ 電源_ 電源_ 電源_ 電源_ 電源。使用主機 IP 進行結束點。

點擊點擊service(電源_ 電源_ 電源_ 電源_ 電源_ 電源_ 電源_ 電源_ 電源_ 電源)->Extension->Portable->Create portable,添加便攜式電池交換器和電池布。

file:///kuiper/bcmath.zip
file:///kuiper/BatteryAlgs.zip

添加串流 :神經流, dt1流.

添加規則ekuiper_rules.md.

步驟4:配置EMQX

登錄到 EMQX 網絡控制臺http://localhost:18083,與 用戶名 :管理員and 密碼 :公共公共.

添加規則emqx_rules.md.

步驟5:配置格拉法納

登錄到 Grafana 網絡控制臺https://localhost:30:3000,與 用戶名 :管理員and 密碼 :管理員.

導入儀表板。 您可以從grafana_dashboard.json.

在演示儀表板上查看數據 。

概述和下一步步驟

這一使用案例展示了工業解決方案中典型的工作流程和時間序列數據的使用情況。

作為下一步,增加更多的規則和算法,例如在eKuiper中發現異常現象,或者在Neuron中增加更多的工業協議,以探索更多的能力。

學習更多

繼續學習,見下列指南和軟件資源:

EMQX github*

Neuron github

LF eKuiper github

EMQX Documentation

Neuron Documentation

LF eKuiper Documentation

排除故障

要檢查 Modbus 模擬器和 eKuiper 的連接是否健康, 請在 Neuron 的網絡控制臺找到連接狀態 。

監測南方裝置的數據。

檢查 eKuiper 規則狀態以找出每個步驟的規則執行狀態。 您可以單擊每個規則的狀態圖標打開狀態窗口 。

使用 EMQX 中的 Websocket 工具訂閱一個專題并實時接收信件 。

打印 ia_ infulpuldbconter 的日志 :docker logs ia_influxdbconnector

支助論壇支助論壇

如果你無法解決你的問題,請訪問InfoFinland論壇論壇, 緊扣或github為Neuron和EMQX提供技術支持。

概覽概覽

在工業環境中,許多工業傳感器(PLCs)在不同協議中生成時間序列數據。工業網關軟件Neron* 可以解析這些協議。規則引擎 eKuiper* 可以設置數據流的過濾器和算法。 EMQX是MQT信息經紀人,提供高度可用和高性能的信息服務。 數據隨后流入用于數據存儲和監測的ITC Intel?é Edge Insights(Intel* EII)數據庫。

選定配置 下載下下載工業3.0的邊緣透視,并使用時間序列使用案例,然后遵循以下步驟開始吧

配置 下載

目標系統要求

最低系統要求:

第8代或第8代以上Intel Atom處理器、Intel CoreTM處理器或Intel Xeon處理器。

至少4GB內存。

至少128GB硬盤。

互聯網連接。

烏本圖* 20.04

如何運作

工業的邊緣透視 工業使用的TICK數據序列分析器。Telegraf*、Influction DB*和Grafana*是ITK Intelé EI堆的一部分。在這種使用情況下,工業協議網關軟件Neuron、規則引擎eKuiper和MQTT信息經紀人EMQX可以在Telegraf 之前在Tick堆中采集各種工業數據。

The high-level flow of data is as follows: Modbus Simulator -> Neuron -> eKuiper -> EMQX -> Telegraf -> InfluxDB -> Grafana.

Modbus模擬器在Modbus TCP中生成發電廠的時間序列數據。

中子剖析 Modbus TCP 數據 。

eKuiper通過添加規則和算法處理數據流。

EMQX 以 Pub/Sub 模式在 MQTT 協議中重新發布消息 。

Telegraf 配置為輸入 MQTT 并訂閱 EMQX 的數據 。

流入量DB與Telegraf連接以存儲數據。

Grafana用于數據可視化和監測。

當使用 EMQ IoT 信息軟件與 Intel EI 使用時, 所有模塊都在同一個節點上運行 。

Figure 1: Architecture Diagram

開始

先決條件

選定配置 下載以時間序列使用案例下載工業3.0的邊緣透視。 關于要求和安裝步驟,請參見工業啟動指南的邊緣透視.

配置 下載

第1步:用EMQ運行 EII 時間序列

生成 EI 時間序列部署和配置文件 :

cd [WORK_DIR]/IEdgeInsights/build 
python3 builder.py -f usecases/time-series.yml

用新配置構建 ia_telegraf。 替換[工作_dir]/對應視覺/遠程/配置/遠程/遠程/遠程.conf與Telegraf.conf配置 MQTT 輸入插件。

cd [WORK_DIR]/IEdgeInsights/build
docker-compose -f docker-compose-build.yml build --no-cache ia_telegraf

如果任何服務在建設期間失敗, 運行以下命令以重建服務 。 在這種情況下,以 _ eiibase和常見(_公)之前要求的建設 ia_telegraf:

docker-compose -f docker-compose-build.yml build --no-cache 

獲取docker- competable. yml 轉換器EMQ 軟件docker- competable. yml 轉換器替換[工作_dir]/前置視覺/建筑/多克合成.yml和新的一個。

啟動 EMQX 的 EII 時間序列使用大小寫 :

cd [WORK_DIR]/IEdgeInsights/build
./eii_start.sh

檢查是否所有服務都已啟動 :

docker ps

啟動 Modbus 模擬器power_plant_modbus_simulator.py:

sudo pip3 install pymodbus==2.5.3
sudo python3 ./power_plant_modbus_simulator.py

第2步:配置新元

登錄到 Neuron 網絡控制臺http://localhost:7000 與 用戶名 :管理員and 密碼 :000.0。

添加名為南端設備Name電池電池庫以及 a 和 a模式bus-tcp插件 。

點擊點擊設備配置會 議 日 程 和 議 程電池電池庫選項卡以添加配置。將 IP 地址更改為主機 IP 。

點擊電池電池庫選項卡中導入預定義列表upload-tag-template.xlsx.

點擊數據流處理選項卡。添加南設備電池的訂閱量。

步驟3:配置 eKuiper

在容器中安裝依賴關系:

sudo docker exec -it ekuiper /bin/bash 
pip install numpy==1.22.3 -i http://pypi.douban.com/simple/ --trusted-host pypi.douban.com 
pip install scipy==1.8.0 -i http://pypi.douban.com/simple/ --trusted-host pypi.douban.com

下載插件BatteryAlgs.zip和bcmath.zip。從主機復制到容器。

sudo docker cp ./bcmath.zip ekuiper:/kuiper/bcmath.zip
sudo docker cp ./BatteryAlgs.zip ekuiper:/kuiper/BatteryAlgs.zip

登錄到 ekuiper 網絡控制臺http://localhost:9082,與 用戶名 :管理員and 密碼 :公開。

添加服務電源_ 電源_ 電源_ 電源_ 電源_ 電源_ 電源_ 電源_ 電源_ 電源。使用主機 IP 進行結束點。

點擊點擊service(電源_ 電源_ 電源_ 電源_ 電源_ 電源_ 電源_ 電源_ 電源_ 電源)->Extension->Portable->Create portable,添加便攜式電池交換器和電池布。

file:///kuiper/bcmath.zip
file:///kuiper/BatteryAlgs.zip

添加串流 :神經流, dt1流.

添加規則ekuiper_rules.md.

步驟4:配置EMQX

登錄到 EMQX 網絡控制臺http://localhost:18083,與 用戶名 :管理員and 密碼 :公共公共.

添加規則emqx_rules.md.

步驟5:配置格拉法納

登錄到 Grafana 網絡控制臺https://localhost:30:3000,與 用戶名 :管理員and 密碼 :管理員.

導入儀表板。 您可以從grafana_dashboard.json.

在演示儀表板上查看數據 。

概述和下一步步驟

這一使用案例展示了工業解決方案中典型的工作流程和時間序列數據的使用情況。

作為下一步,增加更多的規則和算法,例如在eKuiper中發現異常現象,或者在Neuron中增加更多的工業協議,以探索更多的能力。

學習更多

繼續學習,見下列指南和軟件資源:

EMQX github*

Neuron github

LF eKuiper github

EMQX Documentation

Neuron Documentation

LF eKuiper Documentation

排除故障

要檢查 Modbus 模擬器和 eKuiper 的連接是否健康, 請在 Neuron 的網絡控制臺找到連接狀態 。

監測南方裝置的數據。

檢查 eKuiper 規則狀態以找出每個步驟的規則執行狀態。 您可以單擊每個規則的狀態圖標打開狀態窗口 。

使用 EMQX 中的 Websocket 工具訂閱一個專題并實時接收信件 。

打印 ia_ infulpuldbconter 的日志 :docker logs ia_influxdbconnector

支助論壇支助論壇

如果你無法解決你的問題,請訪問InfoFinland論壇論壇, 緊扣或github為Neuron和EMQX提供技術支持。

審核編輯 黃宇