解锁工业数据流:NeuronEX 规则调试功能实操指南
![解锁工业数据流:NeuronEX 规则调试功能实操指南](https://static001.geekbang.org/infoq/10/101c8bb3d44eddecee07511c4da8ced4.png)
工业企业要实现数据驱动的新质生产力升级,一个重要的环节便是如何准确、可靠地收集并利用生产过程中的数据流。
NeuronEX 工业边缘网关软件中的规则调试功能,可帮助用户在安全的环境中模拟数据输入,测试和优化数据处理规则,从而提前发现并解决潜在问题。规则调试功能对于实现智能制造、远程监控和预防性维护等应用尤为关键,能够有效提升生产效率,降低运营成本,同时保障系统的稳定性和安全性。
作为一款专为工业场景设计的工业边缘网关软件,NeuronEX 提供设备数据采集和边缘智能分析服务。该软件主要部署在工业现场,可支持多种工业设备通信及工业总线协议的实时数据采集。NeuronEX 能够实现工业系统数据集成、边端数据过滤分析、AI 算法集成,以及工业互联网平台的对接集成等功能,为工业用户提供低延迟的数据接入管理及智能分析服务,帮助用户快速洞悉业务趋势,提升运营效率和业务可持续性。
NeuronEX 具备强大的多协议接入能力,支持如 Modbus、OPCUA、Ethernet/IP、BACnet、Siemens、Mitsubishi 等数十种工业协议的同时接入,实现企业内 MES(制造执行系统)、WMS(仓库管理系统)等多数据源系统的集成对接。
本文将重点介绍 NeuronEX 的规则调试功能,旨在帮助用户更高效地进行规则的调试和创建。
![](https://static001.geekbang.org/infoq/13/13add13ed50444631af65225beb4d275.webp?x-oss-process=image%2Fresize%2Cp_80%2Fformat%2Cpng)
准备工作
在开始调试规则之前,需要创建一个数据源,作为规则的数据输入流。以 MQTT 类型的数据源作为示例,操作步骤如下:
1. 登录到 NeuronEX 系统,进入“数据处理” - “源管理”页面。在“流管理”区域,点击“创建流”按钮。
![](https://static001.geekbang.org/infoq/25/2521188396a98fe269b19280df47b220.webp?x-oss-process=image%2Fresize%2Cp_80%2Fformat%2Cpng)
2. 选择 MQTT 类型,然后点击“下一步”按钮,进入到流配置页面。
![](https://static001.geekbang.org/infoq/92/926158c49179eaf131c482b19b5099b7.webp?x-oss-process=image%2Fresize%2Cp_80%2Fformat%2Cpng)
3. 在流配置页面里,填入流名称和数据源。其它配置信息可保留默认值。数据源应填入计划订阅的 MQTT 主题,以便区分不同的数据流。例如,可以填入 neuronex/rule_test
,点击“添加配置组”按钮以创建新的配置组。
![](https://static001.geekbang.org/infoq/78/78008c62305099e8340abeb370c3e0f2.webp?x-oss-process=image%2Fresize%2Cp_80%2Fformat%2Cpng)
4. 在源配置组里,填入配置组名称和 MQTT 消息服务器地址。此次演示中,服务器地址使用由 EMQX 提供的免费公共 MQTT 服务器(https://www.emqx.com/zh/mqtt/public-mqtt5-broker),该服务器是由 EMQX 的 MQTT 接入平台提供,然后点击“提交”按钮,完成配置组的添加。
![](https://static001.geekbang.org/infoq/1d/1d8a614a5f86fec856520ea8840384a4.webp?x-oss-process=image%2Fresize%2Cp_80%2Fformat%2Cpng)
5. 配置组添加完成后,可看到配置组中已选中刚才添加的 mqtt_conf
配置组,接着点击“提交”按钮即可完成数据源的创建。
![](https://static001.geekbang.org/infoq/b1/b152c9af0815bb2353b922ee1435c5fd.webp?x-oss-process=image%2Fresize%2Cp_80%2Fformat%2Cpng)
利用模拟数据源进行规则调试
接下来进入本文核心环节,规则调试:
1. 进入“数据处理” - “规则”页面,点击“新建规则“按钮来创建一条规则。
![](https://static001.geekbang.org/infoq/da/dac1653a7bd357f4f325ea0f7ec0b4e4.webp?x-oss-process=image%2Fresize%2Cp_80%2Fformat%2Cpng)
2. 在规则新建页面,将默认的数据源替换为之前创建的 MQTT 类型数据源 mqtt_stream
。接着,点击“模拟数据源”按钮来配置模拟数据源。
![](https://static001.geekbang.org/infoq/1b/1bea9cab73b6f167bc794293735c215f.webp?x-oss-process=image%2Fresize%2Cp_80%2Fformat%2Cpng)
3. 在模拟数据源对话框中,“选择 SQL 中模拟数据源”为我们需要模拟的数据源 mqtt_stream
,如果 SQL 语句涉及多个数据源,可通过右侧的加号按钮按需添加。在 “payload” 区域填入要模拟的 JSON 数据,支持模拟多条 JSON 数据。设置“发送间隔”以确定每条 JSON 数据的发送频率。启用“循环发送”功能,可让 payload 中定义的 JSON 数据持续循环发送。若有多条 JSON 数据,则会按顺序逐条循环发送。请确保模拟数据源已开启,即红框内容显示为“关闭模拟数据源”。完成配置后,点击“保存”按钮。
![](https://static001.geekbang.org/infoq/c6/c6434602f3443f992e581da0b4dc91a6.webp?x-oss-process=image%2Fresize%2Cp_80%2Fformat%2Cpng)
4. 配置好模拟数据源后,即可开始进行规则调试。点击页面右侧的运行测试按钮。运行后,在输出结果中可看到循环输出上一步配置的两条 JSON 数据。如需暂停调试,点击右侧停止按钮;若要清除输出结果,点击清除按钮。
![](https://static001.geekbang.org/infoq/70/7007a6a0efd25f69f2e195823a04655d.webp?x-oss-process=image%2Fresize%2Cp_80%2Fformat%2Cpng)
5. 接下来进行一些简单的规则应用。首先,停止测试并清除输出结果。然后,对 SQL 语句稍作修改,使 SELECT 语句仅查询 a
属性。修改完成后,再次点击运行测试按钮,输出结果现在就只包含 a
属性的数据,充分展示了规则调试的灵活性和便捷性。
![](https://static001.geekbang.org/infoq/c5/c5bb77f1b6c1c3ab5d77f094bf819491.webp?x-oss-process=image%2Fresize%2Cp_80%2Fformat%2Cpng)
关闭模拟数据源后的规则调试
先前是在利用模拟数据源完成规则调试,接下来,我们将尝试在关闭模拟数据源的情况下进行规则调试。为此,需用到 MQTTX 客户端,向指定的数据源主题 neuronex/rule_test
发送消息。
1. 停止当前的测试并清除输出结果。然后在模拟数据源对话框中,点击“关闭模拟数据源”按钮。关闭后,按钮上文字将更新为“启用模拟数据源”。请记得点击“保存”按钮以确认更改。
![](https://static001.geekbang.org/infoq/a4/a43de18d31d5f38247e62e714e60d176.webp?x-oss-process=image%2Fresize%2Cp_80%2Fformat%2Cpng)
2. 接下来,点击运行测试按钮,运行后可看到尽管测试正在运行,但输出结果中并没有新数据出现。
![](https://static001.geekbang.org/infoq/c7/c7e03ae13bf35ed3c26268f8f14cbf10.webp?x-oss-process=image%2Fresize%2Cp_80%2Fformat%2Cpng)
3. 下面打开 MQTTX 客户端,并连接到之前创建的 mqtt_conf
配置组中使用的免费公共 MQTT 服务器。建立连接后,向 neuronex/rule_test
主题发送三条消息。
![](https://static001.geekbang.org/infoq/11/11131fc86518be5f7a2ed124e41c8e7b.webp?x-oss-process=image%2Fresize%2Cp_80%2Fformat%2Cpng)
4. 发送消息后,返回到 NeuronEX 的规则新建页面,可看到输出结果已更新了三条记录,对应 MQTTX 中发送的三条数据。由于 SQL 语句中指定只查询 a
属性,因此输出结果中也仅包含 a
属性的数据。
![](https://static001.geekbang.org/infoq/74/74192438194c2d6a045ffe1889f3e2d2.webp?x-oss-process=image%2Fresize%2Cp_80%2Fformat%2Cpng)
总结
至此,我们已经完整介绍了 NeuronEX 的规则调试功能。相信大家已经体会到规则调试功能的便捷和强大。通过实践,用户将能够更深入地理解规则调试的强大功能,并将其应用于实际工作中,以提高开发效率和数据处理的灵活性。
![](https://static001.geekbang.org/infoq/a1/a153138db23c187ae9d373ad848b8b45.webp?x-oss-process=image%2Fresize%2Cp_80%2Fformat%2Cpng)
版权声明: 本文为 InfoQ 作者【EMQ映云科技】的原创文章。
原文链接:【http://xie.infoq.cn/article/6dd3a57121526592ebb1bcdf8】。文章转载请联系作者。
评论