概覽概覽

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

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

配置 下載

目標(biāo)系統(tǒng)要求

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

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

至少4GB內(nèi)存。

至少128GB硬盤。

互聯(lián)網(wǎng)連接。

烏本圖* 20.04

如何運(yùn)作

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

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

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

中子剖析 Modbus TCP 數(shù)據(jù) 。

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

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

Telegraf 配置為輸入 MQTT 并訂閱 EMQX 的數(shù)據(jù) 。

流入量DB與Telegraf連接以存儲(chǔ)數(shù)據(jù)。

Grafana用于數(shù)據(jù)可視化和監(jiān)測(cè)。

當(dāng)使用 EMQ IoT 信息軟件與 Intel EI 使用時(shí), 所有模塊都在同一個(gè)節(jié)點(diǎn)上運(yùn)行 。

Figure 1: Architecture Diagram

開始

先決條件

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

配置 下載

第1步:用EMQ運(yùn)行 EII 時(shí)間序列

生成 EI 時(shí)間序列部署和配置文件 :

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

用新配置構(gòu)建 ia_telegraf。 替換[工作_dir]/對(duì)應(yīng)視覺/遠(yuǎn)程/配置/遠(yuǎn)程/遠(yuǎn)程/遠(yuǎn)程.conf與Telegraf.conf配置 MQTT 輸入插件。

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

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

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

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

啟動(dòng) EMQX 的 EII 時(shí)間序列使用大小寫 :

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

檢查是否所有服務(wù)都已啟動(dòng) :

docker ps

啟動(dòng) Modbus 模擬器power_plant_modbus_simulator.py:

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

第2步:配置新元

登錄到 Neuron 網(wǎng)絡(luò)控制臺(tái)http://localhost:7000 與 用戶名 :管理員and 密碼 :000.0。

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

點(diǎn)擊點(diǎn)擊設(shè)備配置會(huì) 議 日 程 和 議 程電池電池庫選項(xiàng)卡以添加配置。將 IP 地址更改為主機(jī) IP 。

點(diǎn)擊電池電池庫選項(xiàng)卡中導(dǎo)入預(yù)定義列表upload-tag-template.xlsx.

點(diǎn)擊數(shù)據(jù)流處理選項(xiàng)卡。添加南設(shè)備電池的訂閱量。

步驟3:配置 eKuiper

在容器中安裝依賴關(guān)系:

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。從主機(jī)復(fù)制到容器。

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

登錄到 ekuiper 網(wǎng)絡(luò)控制臺(tái)http://localhost:9082,與 用戶名 :管理員and 密碼 :公開。

添加服務(wù)電源_ 電源_ 電源_ 電源_ 電源_ 電源_ 電源_ 電源_ 電源_ 電源。使用主機(jī) IP 進(jìn)行結(jié)束點(diǎn)。

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

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

添加串流 :神經(jīng)流, dt1流.

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

步驟4:配置EMQX

登錄到 EMQX 網(wǎng)絡(luò)控制臺(tái)http://localhost:18083,與 用戶名 :管理員and 密碼 :公共公共.

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

步驟5:配置格拉法納

登錄到 Grafana 網(wǎng)絡(luò)控制臺(tái)https://localhost:30:3000,與 用戶名 :管理員and 密碼 :管理員.

導(dǎo)入儀表板。 您可以從grafana_dashboard.json.

在演示儀表板上查看數(shù)據(jù) 。

概述和下一步步驟

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

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

學(xué)習(xí)更多

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

EMQX github*

Neuron github

LF eKuiper github

EMQX Documentation

Neuron Documentation

LF eKuiper Documentation

排除故障

要檢查 Modbus 模擬器和 eKuiper 的連接是否健康, 請(qǐng)?jiān)?Neuron 的網(wǎng)絡(luò)控制臺(tái)找到連接狀態(tài) 。

監(jiān)測(cè)南方裝置的數(shù)據(jù)。

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

使用 EMQX 中的 Websocket 工具訂閱一個(gè)專題并實(shí)時(shí)接收信件 。

打印 ia_ infulpuldbconter 的日志 :docker logs ia_influxdbconnector

支助論壇支助論壇

如果你無法解決你的問題,請(qǐng)?jiān)L問InfoFinland論壇論壇, 緊扣或github為Neuron和EMQX提供技術(shù)支持。

概覽概覽

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

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

配置 下載

目標(biāo)系統(tǒng)要求

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

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

至少4GB內(nèi)存。

至少128GB硬盤。

互聯(lián)網(wǎng)連接。

烏本圖* 20.04

如何運(yùn)作

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

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

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

中子剖析 Modbus TCP 數(shù)據(jù) 。

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

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

Telegraf 配置為輸入 MQTT 并訂閱 EMQX 的數(shù)據(jù) 。

流入量DB與Telegraf連接以存儲(chǔ)數(shù)據(jù)。

Grafana用于數(shù)據(jù)可視化和監(jiān)測(cè)。

當(dāng)使用 EMQ IoT 信息軟件與 Intel EI 使用時(shí), 所有模塊都在同一個(gè)節(jié)點(diǎn)上運(yùn)行 。

Figure 1: Architecture Diagram

開始

先決條件

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

配置 下載

第1步:用EMQ運(yùn)行 EII 時(shí)間序列

生成 EI 時(shí)間序列部署和配置文件 :

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

用新配置構(gòu)建 ia_telegraf。 替換[工作_dir]/對(duì)應(yīng)視覺/遠(yuǎn)程/配置/遠(yuǎn)程/遠(yuǎn)程/遠(yuǎn)程.conf與Telegraf.conf配置 MQTT 輸入插件。

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

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

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

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

啟動(dòng) EMQX 的 EII 時(shí)間序列使用大小寫 :

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

檢查是否所有服務(wù)都已啟動(dòng) :

docker ps

啟動(dòng) Modbus 模擬器power_plant_modbus_simulator.py:

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

第2步:配置新元

登錄到 Neuron 網(wǎng)絡(luò)控制臺(tái)http://localhost:7000 與 用戶名 :管理員and 密碼 :000.0。

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

點(diǎn)擊點(diǎn)擊設(shè)備配置會(huì) 議 日 程 和 議 程電池電池庫選項(xiàng)卡以添加配置。將 IP 地址更改為主機(jī) IP 。

點(diǎn)擊電池電池庫選項(xiàng)卡中導(dǎo)入預(yù)定義列表upload-tag-template.xlsx.

點(diǎn)擊數(shù)據(jù)流處理選項(xiàng)卡。添加南設(shè)備電池的訂閱量。

步驟3:配置 eKuiper

在容器中安裝依賴關(guān)系:

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。從主機(jī)復(fù)制到容器。

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

登錄到 ekuiper 網(wǎng)絡(luò)控制臺(tái)http://localhost:9082,與 用戶名 :管理員and 密碼 :公開。

添加服務(wù)電源_ 電源_ 電源_ 電源_ 電源_ 電源_ 電源_ 電源_ 電源_ 電源。使用主機(jī) IP 進(jìn)行結(jié)束點(diǎn)。

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

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

添加串流 :神經(jīng)流, dt1流.

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

步驟4:配置EMQX

登錄到 EMQX 網(wǎng)絡(luò)控制臺(tái)http://localhost:18083,與 用戶名 :管理員and 密碼 :公共公共.

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

步驟5:配置格拉法納

登錄到 Grafana 網(wǎng)絡(luò)控制臺(tái)https://localhost:30:3000,與 用戶名 :管理員and 密碼 :管理員.

導(dǎo)入儀表板。 您可以從grafana_dashboard.json.

在演示儀表板上查看數(shù)據(jù) 。

概述和下一步步驟

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

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

學(xué)習(xí)更多

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

EMQX github*

Neuron github

LF eKuiper github

EMQX Documentation

Neuron Documentation

LF eKuiper Documentation

排除故障

要檢查 Modbus 模擬器和 eKuiper 的連接是否健康, 請(qǐng)?jiān)?Neuron 的網(wǎng)絡(luò)控制臺(tái)找到連接狀態(tài) 。

監(jiān)測(cè)南方裝置的數(shù)據(jù)。

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

使用 EMQX 中的 Websocket 工具訂閱一個(gè)專題并實(shí)時(shí)接收信件 。

打印 ia_ infulpuldbconter 的日志 :docker logs ia_influxdbconnector

支助論壇支助論壇

如果你無法解決你的問題,請(qǐng)?jiān)L問InfoFinland論壇論壇, 緊扣或github為Neuron和EMQX提供技術(shù)支持。

審核編輯 黃宇