一、應用設備

OT端設備：步進電機，MODBUS TCP遠程I/O模塊，PLC設備
邊緣側設備：宏集工業樹莓派；
IT端設備：PC、安卓手機；
IT端軟件：宏集HiveMQ MQTT通信平臺

二、原理

宏集工業樹莓派通過MODBUS協議分別采集步進電機、MODBUS TCP IO 模塊、PLC設備數據，并在工業樹莓派完成一些簡單的數據處理。宏集 HiveMQ 將 PC 端配置為 MQTT Broker；工業樹莓派可通過MQTT協議將數據傳輸到PC端；在手機端，操作人員可通過自行編寫的APP程序訂閱PC端的數據主題。

三、實際測試

1、工業樹莓派源碼

import threading
import time
from doctest import OutputChecker
from os import P_PID
from time import sleep
from threading import Thread
from tkinter import W
from myCtrlLib import *
import sys
import serial
import paho.mqtt.client as mqtt
import json
 
def on_connect(client, userdata, flags, rc):
    print(f"Connected with result code {rc}")
  
client = mqtt.Client()
client.on_connect = on_connect
client.connect("192.168.1.168", 1883, 60)
 
#讀取PLC數據
def read_plc_data():
    on_motor()
    i = 0
    j = 0
    while True:
        Weight = readFromName('Weight')         #讀取PLC重量值數據
        Humidity = readFromName('Humidity')     #讀取PLC濕度值數據
        Temperature = readFromName('Temperature')       #讀取PLC溫度值數據
         
        #讀取光電開關狀態，0表示兩個光電開關沒有被觸發；1表示光電開關1被觸發，2表示光電開關2被觸發，3表示兩個光電開關同時被觸發
        Switch = readFromName('Switch_1')
        sleep(1)
        Back_motor()
        sleep(1)
        Advance_motor()
 
        #根據光電開關狀態控制電機
        if Switch == 1:
            i = i+1
 
        if Weight > 500:
            j = 1
        else:
            j = 0
 
        #構建JSON數據
        data = {
            'Stepping_motor_speed':300,     #電機轉速
            'Temperature':Temperature,      #溫度值
            'Humidity':Humidity,        #濕度值
            'Obj_weighth':Weight,            #重量值
        }
 
        json_data = json.dumps(data)
        client.publish('IndustrialProductionLin', payload=json_data, qos=0, retain=True)
        print(i)
 
#電機啟動
def on_motor():
    writeToName('Motor',1)
    pass
 
#電機正轉
def Advance_motor():
    writeToName('DIR',0)
    pass
 
#電機反轉
def Back_motor():
    writeToName('DIR',1)
    pass
 
#電機停止
def stop_motor():
    writeToName('Motor',0)
    pass
 
 
# 創建并啟動線程
plc_thread = threading.Thread(target=read_plc_data)
 
#啟動線程
plc_thread.start()
 
# 主線程等待兩個線程結束
plc_thread.join()

四、為何選擇宏集工業樹莓派和宏集 HiveMQ 方案？

1、宏集工業樹莓派集成了較多的現場總線協議，配合對應的Python庫，能通過一些簡單配置就能夠實現OT端數據的采集，例如該案例使用的MODBUS協議，通過PiCtory配置，就能夠編寫Python程序，快速實現OT端的數據對接；
2、宏集工業樹莓派目前最高配置達到了8GB RAM，性能上等同于一臺PC，能夠完成一些較為復雜的運算和輕量化機器學習模型。
3、宏集HiveMQ平臺是基于MQTT通信的物聯網解決方案，支持快速配置MQTT Broker，支持高負載、高并發、高擴展性。在實際應用中，能夠確保數據的快速穩定傳輸，保證不會出現任何一條數據丟失。除此之外的話，它還支持企業級擴展，例如對接Kafka以及企業級信息安全管理等功能。