1. 为什么要把WINCC7.5和MQTT连起来聊聊我的真实感受干了这么多年工业自动化我经常遇到一个头疼的问题车间里的数据就像被困在一个个孤岛里。PLC、DCS、SCADA系统各管一摊数据想拿出来做个分析或者跟别的系统比如MES、ERP或者我们自己写的分析程序打通那叫一个费劲。要么得买昂贵的OPC服务器要么就得写一堆复杂的通讯脚本调试起来能掉一把头发。后来接触到MQTT感觉像是打开了一扇新窗户。这东西特别轻巧专门为网络不稳定的物联网场景设计发布/订阅的模式也特别灵活。我就想要是能把WINCC7.5这个在工控界应用广泛的监控软件也变成一个能发布数据的MQTT客户端那不就相当于给WINCC装上了一对“会说话的翅膀”吗车间里的实时温度、压力、设备状态都能通过这个轻量的协议源源不断地发送出来。外面随便一个能联网的程序比如用Python写的数据分析脚本、用Node.js做的Web看板甚至手机APP都能轻松订阅到这些数据。WINCC7.5本身没有原生的MQTT功能但它提供了一个非常关键的“桥梁”——Cloud Connector。这个功能就是为了让WINCC的数据能走出去连接到各种云服务或者标准的物联网协议。我们这次要做的就是通过配置Cloud Connector让WINCC7.5变身成一个合格的MQTT客户端把变量数据发布到MQTT服务器也叫Broker上。然后我再手把手带你用Python写一个订阅程序把数据收下来。整个过程我会把每一步的细节、我踩过的坑还有怎么验证都讲清楚保证你照着做就能成功。2. 动手前的准备别急着开干先把环境搭好2.1 软件与网络环境清单工欲善其事必先利其器。咱们先看看需要哪些东西免得做到一半发现缺这少那。首先主角WINCC7.5得是正儿八经安装好的并且项目已经创建。这个不用多说。关键是Cloud Connector功能它是WINCC的一个可选组件在安装WINCC的时候记得要勾选上。如果你不确定自己的WINCC有没有可以按照后面的步骤去看看能不能找到配置界面。第二个关键角色是MQTT服务器Broker。这是数据的中转站WINCC把数据发到这里我们的Python程序从这里订阅数据。对于学习和测试我强烈推荐在本地电脑上搭建一个。有两个超级简单的选择Mosquitto这是Eclipse基金会维护的开源Broker非常轻量、稳定。你可以去官网下载Windows版本安装后作为一个系统服务运行几乎不用配置。EMQX另一个功能强大的开源Broker对中文文档支持友好Web管理界面做得也很漂亮适合新手直观地查看连接和主题。我这次演示会用Mosquitto因为它最“原始”也最通用。你把它安装在和WINCC同一台电脑上或者同一局域网的另一台电脑上都行。记住它的默认端口是1883非加密和8883SSL加密我们测试先用1883。第三个是我们的数据接收端Python环境。你需要安装Python3.6以上版本都行然后通过pip安装一个MQTT客户端库。最常用的就是paho-mqtt。打开你的命令行CMD或PowerShell输入下面这行命令就能搞定pip install paho-mqtt网络方面确保WINCC所在的工控机、MQTT Broker服务器、以及你运行Python的电脑它们之间网络是通的。最简单的方式就是全部放在同一台物理机或者同一个虚拟网络里避免防火墙的干扰。如果跨网段记得在防火墙里放行TCP 1883端口。2.2 在WINCC中激活Cloud Connector好了东西齐了咱们打开WINCC7.5开始操作。第一步不是直接去连MQTT而是先把“桥梁”的开关打开。双击桌面上的“SIMATIC WinCC Explorer”图标打开你的项目。在项目管理器左侧的树形视图里找到“计算机”列表右键点击你项目使用的计算机名称通常是本地计算机名选择“属性”。在弹出的“计算机属性”窗口里你会看到一堆标签页。我们需要找到“Cloud Connector”这个标签。如果你没找到那很可能就是安装WINCC时没选这个组件需要回去补装一下。在这个“Cloud Connector”标签页里你会看到一个明显的复选框“激活Cloud Connector”。毫不犹豫地勾选它勾选之后下面原本灰色的配置区域就会变成可编辑状态。这一步相当于给WINCC装上了数据外送的功能模块但还没告诉它往哪儿送。先点“确定”保存这个设置WINCC可能会提示你需要重启运行系统先不急等我们全部配置完再说。3. 核心步骤一步步配置WINCC成为MQTT客户端3.1 配置Cloud Connector连接参数激活开关之后我们就要来告诉WINCC数据该往哪个MQTT服务器送了。在计算机属性里勾选激活Cloud Connector后下面应该就有一个“配置”按钮或者直接有一个可编辑的表格区域。我们双击它进入详细的连接配置界面。这里会让我们创建一个新的连接。关键的几个参数我一个个解释云提供商这是一个下拉菜单里面可能有“SIEMENS MindSphere”、“AWS IoT”等选项。注意了我们不要选这些特定的云服务而是选择那个最通用的选项通常是“Generic MQTT”或者“Generic (MQTT)”。这个选项就是告诉我们要连接到一个标准的、通用的MQTT协议服务器。代理地址这里填你的MQTT Broker的IP地址。如果Broker和WINCC在同一台电脑就填127.0.0.1或localhost。如果在局域网另一台电脑就填那台电脑的局域网IP比如192.168.1.100。代理端口默认的非加密端口就是1883。如果你用的Broker没改过配置就填这个。站名称这个字段非常重要你可以把它理解为你这个WINCC站在MQTT网络里的“用户名”或者“设备标识符”。它会被用作MQTT主题Topic的第一部分。你可以起一个容易识别的名字比如“Press_Line1”、“WinCC_Station_A”。我这里为了演示就用MyWinCCStation。配置完大概长这样以我用的界面为例参数项配置值说明云提供商Generic MQTT选择通用MQTT协议代理地址192.168.1.200你的MQTT服务器IP代理端口1883默认非加密端口站名称MyWinCCStationWINCC在MQTT中的标识配置好后保存并关闭。这时候WINCC到MQTT Broker的“专用车道”就修好了但还没有车数据愿意开上去。3.2 为变量启用“云发布”功能路修好了现在得让数据变量自己“上车”。WINCC不会把所有的变量都自动发布出去那样太乱也不安全。我们需要手动指定哪些变量需要上传。回到WinCC Explorer打开“变量管理”。找到你想通过MQTT发布的变量比如一个来自PLC的“电机温度”变量Motor_Temp。右键点击这个变量选择“属性”或者直接在右下角的属性窗口里找。在变量的属性列表中仔细寻找一个叫做“WINCC Cloud”或者“云连接”的类别。展开后你应该能看到一个选项比如“激活”或“启用”。把它勾选上这就相当于给这个变量贴了一个“快递标签”告诉Cloud Connector“这个变量需要打包发出去”。勾选后通常还会出现一个“发布周期”的设置。这个决定了数据发送的频率。比如你设为1000毫秒那么这个变量就会每秒向MQTT Broker发送一次当前值。这里需要根据数据的实际需求来定对于温度、压力这种变化慢的周期可以设长点对于转速、瞬时流量这种可以设短点。但要注意太短的周期会给WINCC运行系统和网络带来负担。用同样的方法把你所有需要对外发布的变量都勾选上“激活WINCC云”。你可以分批操作管理起来非常灵活。4. 理解数据通道WINCC的MQTT主题规则配置都做完了数据开始往外发了。那我们的Python程序怎么知道该接收哪个数据呢这就涉及到MQTT的核心概念——主题。WINCC的Cloud Connector在发布变量数据时会遵循一个固定的主题格式。这个格式就像是一个文件路径订阅者通过这个路径来“定位”数据。格式是这样的站名称/变量组/变量名站名称就是我们之前在Cloud Connector里配置的“站名称”比如MyWinCCStation。这是所有从这台WINCC发出的数据的第一级目录。变量组这个对应WINCC变量管理里的组名。如果你把变量Motor_Temp放在了“Motor”组里那么这里就是Motor。如果变量直接在根目录下没有组那么这一级可能为空或者是一个默认名称有些版本可能是tags具体需要实测或查手册。为了清晰我建议大家都建立变量组来管理。变量名就是变量的实际名称比如Motor_Temp。举个例子假设站名称是MyWinCCStation变量Motor_Temp放在“Motor”组里那么它发布的完整MQTT主题就是MyWinCCStation/Motor/Motor_Temp这个主题里数据载荷就是该变量当前的值比如“75.3”一个浮点数格式的字符串。MQTT还有一个强大的功能——通配符。如果你不想一个一个变量去订阅可以使用单层通配和#多层通配。比如订阅MyWinCCStation/Motor/#就能收到Motor组下的所有变量数据。订阅MyWinCCStation/#就能收到这台WINCC站下所有组的所有变量数据。这在做数据采集和监控时非常方便你不需要事先知道所有变量名一个通配符订阅就能“一网打尽”。5. 实战Python订阅把数据拿到手理论说再多不如跑行代码。现在我们来写Python程序把WINCC发出来的数据接住。我会写两个例子一个订阅单个变量一个用通配符订阅一组变量。5.1 编写一个基础的MQTT订阅客户端首先确保你已经安装了paho-mqtt库。我们来创建一个Python脚本比如叫subscribe_wincc.py。import paho.mqtt.client as mqtt import json import time # MQTT服务器地址和端口 BROKER_ADDRESS 192.168.1.200 # 改成你的Broker IP BROKER_PORT 1883 # 当连接到Broker时的回调函数 def on_connect(client, userdata, flags, rc): print(f连接结果码: {rc}) if rc 0: print(连接成功) # 连接成功后订阅主题 # 例子1订阅单个特定变量 topic_single MyWinCCStation/Motor/Motor_Temp client.subscribe(topic_single) print(f已订阅单个主题: {topic_single}) # 例子2使用通配符订阅整个站的数据 topic_wildcard MyWinCCStation/# client.subscribe(topic_wildcard) print(f已订阅通配符主题: {topic_wildcard}) else: print(f连接失败错误码: {rc}) # 当收到消息时的回调函数 def on_message(client, userdata, msg): # msg.topic 是主题msg.payload 是载荷数据 # WINCC发送的数据通常是字符串格式的变量值 try: # 尝试将载荷解码为字符串 payload_str msg.payload.decode(utf-8) print(f收到消息 - 主题: [{msg.topic}], 数据: {payload_str}) # 这里你可以添加自己的逻辑比如把数据存入数据库、写入文件、触发报警等 # 例如if float(payload_str) 80: print(温度过高) except Exception as e: print(f处理消息时出错: {e}) # 创建MQTT客户端实例 client mqtt.Client() # 指定回调函数 client.on_connect on_connect client.on_message on_message print(f正在尝试连接到 {BROKER_ADDRESS}:{BROKER_PORT}...) try: client.connect(BROKER_ADDRESS, BROKER_PORT, 60) except Exception as e: print(f连接发生异常: {e}) exit(1) # 启动网络循环保持连接并处理消息 # client.loop_forever() 会阻塞直到程序停止 print(开始监听消息... (按 CtrlC 停止)) client.loop_forever()我把代码的关键点解释一下on_connect函数一旦成功连上Broker我们就立刻告诉Broker我们想“听”哪些主题。这里我演示了两种订阅方式。on_message函数这是核心每当有消息到达我们订阅的主题时这个函数就会被自动调用。msg.topic告诉我们数据是哪个变量发来的msg.payload里就是变量的值。我们把它从字节流解码成字符串打印出来。client.loop_forever()这行代码让程序进入一个永久循环持续监听网络消息。它是一个阻塞调用所以程序会一直运行直到你手动中断CtrlC。运行一下保存脚本在命令行里运行python subscribe_wincc.py。先确保你的Mosquitto Broker正在运行并且WINCC项目已经激活运行注意WINCC的Cloud Connector配置修改后通常需要重启WINCC运行系统才能生效。如果一切正常你会看到Python程序打印“连接成功”和订阅信息。然后当WINCC那边的变量值发生变化时比如你在WINCC里模拟修改一下Motor_Temp的值你的Python控制台就会立刻打印出类似这样的信息收到消息 - 主题: [MyWinCCStation/Motor/Motor_Temp], 数据: 76.85.2 数据处理与错误排查技巧看到数据出来只是第一步。真实项目里我们得考虑得更周全。数据处理WINCC发过来的数据默认是字符串。你需要根据变量类型在Python里做转换。比如温度是浮点数就用float(payload_str)开关量是0或1可以用int(payload_str)。然后你可以把数据追加到列表里做实时图表或者用pandas整理后分析也可以直接写入到MySQL、InfluxDB等数据库中。错误排查如果连接不上或者收不到数据别慌按这个顺序查Broker运行了吗在命令行输入netstat -an | findstr 1883Windows或sudo systemctl status mosquittoLinux看看1883端口是否在监听。防火墙关了吗临时关闭WINCC所在机器和Broker所在机器的防火墙试试确认是不是端口被拦了。WINCC运行系统重启了吗修改Cloud Connector配置或变量云属性后必须重启WINCC运行系统否则配置不生效。这是我最开始踩过的大坑。主题名拼对了吗在Python里打印一下你订阅的主题和WINCC实际发布的主题仔细对比。大小写、斜杠、组名一个都不能错。我建议先在Broker上用一个通用的MQTT客户端工具比如MQTT.fx订阅#看看WINCC到底发出了哪些主题确认主题结构。变量值变了吗WINCC的Cloud Connector通常只在变量值发生变化或者达到你设定的“发布周期”时才会发送数据。确保你测试的变量值有变动。6. 进阶话题与生产环境考量把基础跑通之后我们可以聊点更深的东西让这个方案更健壮、更安全。6.1 安全性与性能优化默认的1883端口是明文传输这在生产环境是不安全的。强烈建议启用MQTT over SSL/TLS端口8883。这需要在Mosquitto等Broker端配置证书并在WINCC的Cloud Connector配置中指定CA证书、客户端证书和密钥。虽然配置步骤稍多但对于防止数据窃听和中间人攻击至关重要。另外可以考虑使用用户名和密码认证。在Broker端设置访问控制列表让WINCC客户端和Python订阅客户端都用特定的用户名/密码连接而不是任何人都能连。性能方面注意“发布周期”不要设得太短。对于上百个高速变化的变量每秒都发可能会对WINCC运行系统造成压力。合理分组区分不同采集频率的变量。在Python端如果处理数据比较耗时比如写入数据库要小心不要在on_message回调函数里做太多阻塞性操作可以考虑使用队列queue.Queue将数据推送到另一个线程去处理避免消息堆积。6.2 扩展应用场景一旦数据通道打通想象空间就大了。这里分享几个我做过或见过的应用移动端监控用Python的Flask或FastAPI框架搭建一个简单的Web API。Python订阅到MQTT数据后不仅自己存起来还通过WebSocket实时推送给前端网页。这样工程师在手机上打开浏览器就能看到一个实时刷新的车间数据看板。数据持久化与高级分析用Python把数据存入时序数据库如InfluxDB然后利用Grafana制作历史趋势曲线、仪表盘。更进一步可以用scikit-learn等库对历史数据进行机器学习做预测性维护比如预测电机什么时候可能出故障。跨系统联动Python订阅到某个报警信号比如“水箱液位超低”可以自动调用另一个系统的API比如发送短信/邮件通知或者触发一个微信机器人推送消息到工作群。边缘计算在靠近WINCC的工控机或网关设备上运行Python程序。它订阅到原始数据后先进行本地预处理、滤波、简单逻辑判断再把结果通过另一个MQTT主题发布出去或者上传到云端减轻中心服务器的压力。这套WINCC MQTT Python的组合本质上是把传统封闭的工业控制数据用现代IT领域轻量、通用的协议开放出来。它技术门槛不高但带来的灵活性和可能性是巨大的。从我自己的项目经验来看花半天时间打通这个链路后续在数据利用上节省的时间和创造的价值远远超过投入。希望这篇从配置到代码的详细解析能帮你顺利迈出第一步。如果在实际操作中遇到奇怪的问题多检查主题路径和运行系统重启这两个点是最常见的“坑”。