基于MQTT的数据通信在聚合物挤出工艺中的应用

在第四次工业革命的浪潮中，各种加工数据的采集和监控已成为重要的任务¹.特别是，使用过程数据改进制造过程并建立有效的运营计划将是所有制造设施^2，3的重要目标。如果可以在工厂外发出警报，或者可以及时执行预测性维护，则可以大大减少停机时间⁴.最近，在聚合物工艺^5，6中的数据分析方面已经做出了许多努力。然而，由于难以从现有系统⁷获取此类数据，因此执行这些任务并不容易。控制和仪表的分层结构使数据采集和通信变得困难。

首先，不可能从具有不同制造日期的不同机器获取数据。很难实现不同机器之间的通信，因为这需要不同现场总线之间以专有格式进行互操作性。通过这种方式，通信方法和数据格式保持私密。这有助于人们轻松维护数据安全性，但使用户依赖机器制造商的服务和未来发展。最近连接到聚合物加工机器的人机界面（HMI）在内的控制计算机现在大多基于Windows，但加载了在专有开发环境中创建的软件。可以使用来自不同公司的可编程逻辑控制器（PLC）与传感器或执行器进行通信，但在许多情况下，上层监控和数据采集（SCADA）系统依赖于控制计算机⁸。这种做法导致许多协议，现场总线和控制系统在市场上竞争。虽然随着时间的推移，这种复杂性已经逐渐减轻，但许多类型的现场总线和协议仍在积极使用。

另一方面，控制设备和SCADA之间的通信已由开放平台通信联合架构（OPCUA）⁹标准化。此外，SCADA和制造执行系统（MES）之间的通信也主要通过OPCUA进行。在如此严格的层次结构中，自由提取数据以进行过程监控和分析并不容易。通常，必须从SCADA或MES¹⁰中提取数据。如前所述，这些系统是特定于供应商的，数据格式很少是开放的。因此，数据提取需要原始信息技术/运营技术（IT/OT）解决方案供应商的大量支持。这可能会阻碍用于监测和分析的数据采集。

在薄膜挤出生产线中，控制PC由SCADA系统^11监控。SCADA系统由不易修改的计算机程序操作。计算机程序可能是可编辑的，但编辑非常昂贵且耗时。为了轻松监视和分析处理数据，应可从任何位置访问数据。为了监视远离现场的处理数据，计算机程序应该能够将处理数据流式传输到因特网¹²。此外，自由开放方法降低了数据采集¹³的费用。这种方法即使在无力投资商业IT解决方案的小型工厂中也可以进行数据分析¹⁴.

在本研究中，采用了基于发布者-订阅者模型的消息协议。消息队列遥测传输 （MQTT） 是一种开放且标准的协议，它支持在多个数据提供者和使用者¹⁵ 之间进行消息传递。在这里，我们提出了一个系统，该系统使用MQTT为现有制造设施获取，传输和监控数据。该系统在薄膜挤出生产线上进行测试，以验证性能。来自原始控制器的数据 通过 Modbus协议传输到边缘设备。然后，数据发布到代理。与此同时，两个Raspberry Pis将测量的温度和照度发布给同一个经纪人。然后，互联网上的任何设备都可以订阅数据，然后监视和记录它，如图 1所示。这项工作中的协议显示了如何完成整个过程。

1. 代理安装

注:为了 通过 因特网监测和记录处理数据，应准备一个中继数据的计算机系统。系统应可从发布者和订阅者访问，如图 2 所示。因此，它需要具有在任何通信之前已知的公共IP地址。一个名为Eclipse Mosquitto的开放MQTT代理安装在系统¹³上。

1. 将计算机连接到互联网，提供公共 IP 地址。在操作系统的 IP 设置中提供地址。
2. 在计算机上安装代理软件，如 Eclipse Mosquitto。使用浏览器下载安装文件并执行它。
3. 使用测试程序（如 MQTT 透镜）测试代理。使用浏览器下载 MQTT 镜头并进行安装。然后，确保订阅了已发布的消息。

2. 主要出版商准备

注意:此计算机 通过 TCP 上的 MQTT 将计算机数据发布到代理。遗留数据应进行解释和重新打包以发送出去。这通常可以通过RS485或以太网完成。应根据总线类型验证硬件级别的连接。挤出机通过以太网端口 通过 Modbus发送数据。

1. 将计算机物理放置在计算机站点中，并将其设置为主发布者。
   注意:虽然不是强制性的，但在这项工作中选择了一台工业计算机。
2. 在计算机上安装 Python3。使用浏览器下载安装程序文件并执行它。
3. 安装 PyModbus¹⁶。使用浏览器下载安装程序文件并执行它。
4. 检查挤压控制器，HMI控制机器，并将挤出控制器连接到主发布器。
5. 使用Modbus工具（如ModbusPoll或QModMaster）从机器中完全识别Modbus协议中的数据和相应地址。确保发送的机器数据显示在 Modbus 工具的相应单元格中。
6. 在发布者电脑上编写从挤出控制器检索数据的 Python 代码。
   注意:下面是一个代码示例:
   from pyModbusTCP.client import ModbusClient
   client = ModbusClient（host="192.168.1.***"， port=***， unit_id=***）
   client.open（）
   挤出数据 = str（client.read_holding_registers（1000， 58））
7. 通过 PCIe、USB、RS232 和 RS485 合并来自其他设备的其他数据流。
   注意:这很简单。获得其他数据字符串后，只需将数据添加到现有数据流中，这由以下代码完成:
   拉伸数据 += 附加数据
8. 安装 paho-mqtt 后导入 paho.mqtt.client by pip install paho-mqtt¹⁷ .
9. 实现代码以连接数据并将其发布到代理。
   注意:请参考下面的代码示例:
   url="117.xx.xxx.xx";端口 = 1883;用户名 = "****";密码 = "xxxxx";主题 = "挤出机"
   mqttc = mqtt.客户端（）
   mqttc.username_pw_set（用户名，密码）
   mqttc.connect（host=url， port=port）
   mqttc.loop_start（）
   挤出数据 = str（client.read_holding_registers（1000， 58））
   Pub1= mqttc.publish（topic， ExtrusionData））
   Pub1.wait_for_publish（）

3. 其他发布者准备

注意:此计算机还 通过 TCP 通过 MQTT 将计算机数据发布到代理。有时，需要在主发布商上无法进行的额外测量。物联网（IoT）设备，如Raspberry Pi和Arduino可以扮演这个角色。在这项工作中，Raspberry Pi被用于温度数据和照度数据。该过程类似于协议第 2 节。

1. 将树莓派放在传感器位置附近。
   注意:由于布线距离有限，树莓派不能放置在离测量位置很远的地方。然而，由于挤出机附近非常热，因此需要将设备放置在距离测量位置至少1米的地方。
2. 在 Raspberry Pi 上通过命令行中的以下命令安装 Python3:
   sudo apt update
   sudo apt install Python3 idle3
3. 实现代码以获取传感器数据。传感器数据 可通过 I ²C 或 GPIO 传输。
   注:有关 通过 GPIO 获取的其他温度数据，请参阅以下代码示例:
   从 max6675 导入 MAX6675
   cs_pin1 = 24;clock_pin1 = 25;data_pin1 = 18
   cs_pin2 = 9;clock_pin2 = 11;data_pin2 = 19
   单位 = "C"
   热电偶1 = MAX6675（cs_pin1、clock_pin1、data_pin1、单位）
   热电偶2 = MAX6675（cs_pin2、clock_pin2、data_pin2、单位）
   T1 = 热电偶1.get（）
   T2 = 热电偶2.get（）
4. Import paho.mqtt.client.
5. 重用第 2 节中的代码以连接数据并将其发布到代理。

4. 订户设置

注意:互联网上的任何设备都可能 通过 代理接收处理数据。数据也由Python代码处理和可视化。如果开发困难，可以使用可用的应用程序，例如Google Play中的MQTT客户端和App Store中的MQT工具。由于用户界面的实现非常冗长，因此此处不介绍详细信息。另请注意，现有应用程序（如 App Store 中的 MQT 工具）可以接收数据。

1. 使用设备订阅互联网。确保物理电缆连接，然后在命令行上对代理 IP 执行 ping 操作（例如，ping 117.xx.xxx.xx）。
2. 根据设备和操作系统安装合适的 Python 环境。例如，在Android设备上安装Pydroid3，而不是从Google Play安装Python3。
3. 导入 paho.mqtt.client 和 paho.mqtt.subscribe 以连接到代理并从中接收数据。
   注意:请参考下面的代码示例:
   import paho.mqtt.client as mqtt
   import paho.mqtt.subscribe as subscribe
   url="117.xx.xxx.xx";端口 = 1883;用户名 = "****";密码 = "xxxxx";主题 = "挤出机"
   mqttc.username_pw_set（用户名、密码）
   mqttc.connect（host=url， port=port）
   mqttc.subscribe（topic， 0）
   mqttc.loop_start（）
   Sub1 = subscribe.simple（topic， hostname=url）
   ExtruderData = Sub1.payload.decode（"utf-8"）
4. 根据需要使用 PyQT5 构建用户界面。
   注意:这部分非常冗长，侧重于接收数据的图形表示，而不是通信。相应的代码作为补充数据提供。
5. 通过执行构建的代码在 GUI 上显示传入的数据。

5. 数据记录

注意:监控时，处理数据可以写入数据库中。在这项工作中，选择了实验室规模的数据库。数据连接到Microsoft Access文件，以便从用户计算机轻松写入和检索。此外，可以通过查询立即构建表，以分析电子表格（如Microsoft Excel）中的数据。

1. 选择订阅者设备以记录数据。
2. 通过在命令行上执行"pip install pyodbc"来导入 pyodbc，以便 Python 代码访问数据库，如图 3¹⁸ 所示。
3. 通过Python代码向数据库发送查询，用于记录处理数据。有关该方法，请参阅 图 3 中的 Python 代码。
4. 将查询发送到数据库以检索记录的数据。
   注意:下面给出了数据检索的代码示例:
   import pyodbc
   x for x in pyodbc.drivers（） if x.startswith（'Microsoft Access Driver'）]
   conn_str = （
   r'DRIVER={Microsoft Access Driver （*.mdb， *.accdb）};'
   r'DBQ=C:\Users\data_analysis\db1.accdb;'
   )
   cnxn = pyodbc.connect（conn_str）
   crsr = cnxn.cursor（）
   对于 crsr.tables（tableType='TABLE'） 中的table_info）:
   print（table_info.table_name）
   sql = """\
   从Process_Condition中选择 *
   """
   crsr = cnxn.execute（sql）
   对于 crsr 中的行:
   RetrievedData = pd.read_sql（sql， cnxn）
   crsr.close（）
   cnxn.close（）

6. 部署

注意:如果所有设备都可以连接到互联网，则设置很简单。但是，为了保护计算机端数据，发布者只能位于 Intranet 中。在这种情况下，代理可以是互联网的网关。为此，代理应配备两个以太网适配器，其中一个适配器必须具有公共 IP 地址。开发完所有项目后，应将代码部署到每个设备上，如图 4 所示。有线或无线连接模式并不重要，但必须加以保护，以便每个设备都能够访问代理。这意味着出于安全目的，代理可以充当 Intranet 和 Internet 之间边界上的网关。当然，即使所有设备都暴露在互联网上，从通信的角度来看也没有问题。

1. 通过以太网将挤出控制器、主发布者和其他发布者连接到 Intranet 端口。
2. 将代理的一个以太网端口连接到内部网，另一个连接到因特网。
3. 通过对所有用户重复步骤 4.1 将订阅者连接到 Internet。

7. 执行

注意:为了测试整个系统，我们启动了挤出生产线，并运行了所有Python代码和Mosquitto。

1. 开始挤出过程。在机器的HMI上，设置温度并通过触摸HMI屏幕上的按钮打开加热器。一旦达到所需的温度，开始旋转螺杆以挤出聚合物熔体。
2. 打开所有计算机，通过命令"net start mosquitto"在代理设备上启动代理软件，然后运行Python代码以根据需要监视和记录处理数据。
   注意:步骤 7.1 和步骤 7.2 的顺序可以颠倒。只需在命令行上键入"python3 xxxxx.py"，然后按 Enter 即可执行 Python 代码。将此命令添加到启动程序中，以避免每次设备重新启动时都键入该命令。

已经发现，HMI中显示的数据和Raspberry Pis测量的数据在订户中进行了监控和记录，如图 5所示。如视频所示，处理数据被记录到数据库中。

图 1:使用 MQTT 协议的数据传输概述。 代理将消息从发布者中继到订阅者。此图中的发布者是主发布者和附加发布者（Raspberry Pi）。主发布者直接连接到挤出机以接收数据。只要网络容量允许，订户数量就不会受到限制。订阅者可以将数据重新发布到其他订阅者，以将其记录在 Microsoft Access 等数据库中。 请点击此处查看此图的大图。

图 2:薄膜挤出生产线中按出版物、经纪和订阅划分的数据流。 处理数据由左上角框中表示的物理系统发布。对于订阅者，基于PyQt5编写创建图形用户界面的Python代码，以在屏幕上显示接收到的数据。 请点击此处查看此图的大图。

图 3: 通过 ODBC 将订阅的数据记录到 MS Access 文件中。 为了建立与Microsoft Access的连接，使用了ODBC。使用pyodbc的Python代码是为连接编写的，它允许通过传输用户生成的查询来记录和分析。 请点击此处查看此图的大图。

图 4:整个系统的部署。 建筑物 2 中的代理设备需要两个以太网端口，一个连接到 Intranet，另一个连接到 Internet。出于安全考虑，发布者连接到 Intranet，而订阅者连接到 Internet。代理需要公共 IP 地址才能在校园外访问。因此，互联网上的任何设备都可以订阅已发布的数据。 请点击此处查看此图的大图。

图 5:在操作薄膜挤出生产线时运行数据监控系统。 部署整个系统后，可以在挤出操作期间（右下角）监控加工数据。HMI（右上）中显示的数据在外部发布。启动代理后，应执行发布者和订阅者设备中的代码。然后，数据流按计划在系统中开始。使用进料数据，可以监控和显示薄膜挤出生产线（左下角）。 请点击此处查看此图的大图。

补充数据。请点击此处下载此文件。

作者声明没有利益冲突。