概覽概覽

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

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

配置 下載

目標系統(tǒng)要求

最低系統(tǒng)要求:

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

至少4GB內存。

至少128GB硬盤。

互聯(lián)網連接。

烏本圖* 20.04

如何運作

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

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

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

中子剖析 Modbus TCP 數據 。

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

EMQX 以 Pub/Sub 模式在 MQTT 協(xié)議中重新發(fā)布消息 。

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

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

Grafana用于數據可視化和監(jiān)測。

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

Figure 1: Architecture Diagram

開始

先決條件

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

配置 下載

第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流.

添加規(guī)則ekuiper_rules.md.

步驟4:配置EMQX

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

添加規(guī)則emqx_rules.md.

步驟5:配置格拉法納

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

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

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

概述和下一步步驟

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

作為下一步,增加更多的規(guī)則和算法,例如在eKuiper中發(fā)現異?，F象,或者在Neuron中增加更多的工業(yè)協(xié)議,以探索更多的能力。

學習更多

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

EMQX github*

Neuron github

LF eKuiper github

EMQX Documentation

Neuron Documentation

LF eKuiper Documentation

排除故障

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

監(jiān)測南方裝置的數據。

檢查 eKuiper 規(guī)則狀態(tài)以找出每個步驟的規(guī)則執(zhí)行狀態(tài)。 您可以單擊每個規(guī)則的狀態(tài)圖標打開狀態(tài)窗口 。

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

打印 ia_ infulpuldbconter 的日志 :docker logs ia_influxdbconnector

支助論壇支助論壇

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

概覽概覽

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

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

配置 下載

目標系統(tǒng)要求

最低系統(tǒng)要求:

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

至少4GB內存。

至少128GB硬盤。

互聯(lián)網連接。

烏本圖* 20.04

如何運作

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

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

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

中子剖析 Modbus TCP 數據 。

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

EMQX 以 Pub/Sub 模式在 MQTT 協(xié)議中重新發(fā)布消息 。

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

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

Grafana用于數據可視化和監(jiān)測。

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

Figure 1: Architecture Diagram

開始

先決條件

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

配置 下載

第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流.

添加規(guī)則ekuiper_rules.md.

步驟4:配置EMQX

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

添加規(guī)則emqx_rules.md.

步驟5:配置格拉法納

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

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

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

概述和下一步步驟

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

作為下一步,增加更多的規(guī)則和算法,例如在eKuiper中發(fā)現異?，F象,或者在Neuron中增加更多的工業(yè)協(xié)議,以探索更多的能力。

學習更多

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

EMQX github*

Neuron github

LF eKuiper github

EMQX Documentation

Neuron Documentation

LF eKuiper Documentation

排除故障

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

監(jiān)測南方裝置的數據。

檢查 eKuiper 規(guī)則狀態(tài)以找出每個步驟的規(guī)則執(zhí)行狀態(tài)。 您可以單擊每個規(guī)則的狀態(tài)圖標打開狀態(tài)窗口 。

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

打印 ia_ infulpuldbconter 的日志 :docker logs ia_influxdbconnector

支助論壇支助論壇

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

審核編輯 黃宇