解锁工业数据流:NeuronEX 规则调试功能实操指南

简介: NeuronEX 工业边缘软件中的规则调试功能,可帮助用户在安全的环境中模拟数据输入,测试和优化数据处理规则,从而提前发现并解决潜在问题。规则调试功能对于实现智能制造、远程监控和预防性维护等应用尤为关键,能够有效提升生产效率,降低运营成本,同时保障系统的稳定性和安全性。

工业企业要实现数据驱动的新质生产力升级,一个重要的环节便是如何准确、可靠地收集并利用生产过程中的数据流。

NeuronEX 工业边缘软件中的规则调试功能,可帮助用户在安全的环境中模拟数据输入,测试和优化数据处理规则,从而提前发现并解决潜在问题。规则调试功能对于实现智能制造、远程监控和预防性维护等应用尤为关键,能够有效提升生产效率,降低运营成本,同时保障系统的稳定性和安全性。

作为一款专为工业场景设计的工业边缘网关软件,NeuronEX 提供设备数据采集和边缘智能分析服务。该软件主要部署在工业现场,可支持多种工业设备通信及工业总线协议的实时数据采集。NeuronEX 能够实现工业系统数据集成、边端数据过滤分析、AI 算法集成,以及工业互联网平台的对接集成等功能,为工业用户提供低延迟的数据接入管理及智能分析服务,帮助用户快速洞悉业务趋势,提升运营效率和业务可持续性。

NeuronEX 具备强大的多协议接入能力,支持如 Modbus、OPC UA、Ethernet/IP、BACnet、Siemens、Mitsubishi 等数十种工业协议的同时接入,实现企业内 MES(制造执行系统)、WMS(仓库管理系统)等多数据源系统的集成对接。

本文将重点介绍 NeuronEX 的规则调试功能,旨在帮助用户更高效地进行规则的调试和创建。

NeuronEX

准备工作

在开始调试规则之前,需要创建一个数据源,作为规则的数据输入流。以 MQTT 类型的数据源作为示例,操作步骤如下:

  1. 登录到 NeuronEX 系统,进入“数据处理” - “源管理”页面。在“流管理”区域,点击“创建流”按钮。

    源管理

  2. 选择 MQTT 类型,然后点击“下一步”按钮,进入到流配置页面。

    创建流

  3. 在流配置页面里,填入流名称和数据源。其它配置信息可保留默认值。数据源应填入计划订阅的 MQTT 主题,以便区分不同的数据流。例如,可以填入 neuronex/rule_test,点击“添加配置组”按钮以创建新的配置组。

    流配置页面

  4. 在源配置组里,填入配置组名称和 MQTT 消息服务器地址。此次演示中,服务器地址使用由 EMQX 提供的免费公共 MQTT 服务器,该服务器是由 EMQX 的 MQTT 接入平台提供,然后点击“提交”按钮,完成配置组的添加。

    源配置组

  5. 配置组添加完成后,可看到配置组中已选中刚才添加的 mqtt_conf 配置组,接着点击“提交”按钮即可完成数据源的创建。

    完成创建

利用模拟数据源进行规则调试

接下来进入本文核心环节,规则调试:

  1. 进入“数据处理” - “规则”页面,点击“新建规则“按钮来创建一条规则。

    规则页面

  2. 在规则新建页面,将默认的数据源替换为之前创建的 MQTT 类型数据源 mqtt_stream。接着,点击“模拟数据源”按钮来配置模拟数据源。

    规则新建页面

  3. 在模拟数据源对话框中,“选择 SQL 中模拟数据源”为我们需要模拟的数据源 mqtt_stream,如果 SQL 语句涉及多个数据源,可通过右侧的加号按钮按需添加。在 “payload” 区域填入要模拟的 JSON 数据,支持模拟多条 JSON 数据。设置“发送间隔”以确定每条 JSON 数据的发送频率。启用“循环发送”功能,可让 payload 中定义的 JSON 数据持续循环发送。若有多条 JSON 数据,则会按顺序逐条循环发送。请确保模拟数据源已开启,即红框内容显示为“关闭模拟数据源”。完成配置后,点击“保存”按钮。

    模拟数据源

  4. 配置好模拟数据源后,即可开始进行规则调试。点击页面右侧的运行测试按钮。运行后,在输出结果中可看到循环输出上一步配置的两条 JSON 数据。如需暂停调试,点击右侧停止按钮;若要清除输出结果,点击清除按钮。

    规则调试

  5. 接下来进行一些简单的规则应用。首先,停止测试并清除输出结果。然后,对 SQL 语句稍作修改,使 SELECT 语句仅查询 a 属性。修改完成后,再次点击运行测试按钮,输出结果现在就只包含 a 属性的数据,充分展示了规则调试的灵活性和便捷性。

    调试规则

关闭模拟数据源后的规则调试

先前是在利用模拟数据源完成规则调试,接下来,我们将尝试在关闭模拟数据源的情况下进行规则调试。为此,需用到 MQTTX 客户端,向指定的数据源主题 neuronex/rule_test 发送消息。

  1. 停止当前的测试并清除输出结果。然后在模拟数据源对话框中,点击“关闭模拟数据源”按钮。关闭后,按钮上文字将更新为“启用模拟数据源”。请记得点击“保存”按钮以确认更改。

    关闭模拟数据源

  2. 接下来,点击运行测试按钮,运行后可看到尽管测试正在运行,但输出结果中并没有新数据出现。

    点击运行测试按钮

  3. 下面打开 MQTTX 客户端,并连接到之前创建的 mqtt_conf 配置组中使用的免费公共 MQTT 服务器。建立连接后,向 neuronex/rule_test 主题发送三条消息。

    MQTTX 客户端

  4. 发送消息后,返回到 NeuronEX 的规则新建页面,可看到输出结果已更新了三条记录,对应 MQTTX 中发送的三条数据。由于 SQL 语句中指定只查询 a 属性,因此输出结果中也仅包含 a 属性的数据。

    输出结果

总结

至此,我们已经完整介绍了 NeuronEX 的规则调试功能。相信大家已经体会到规则调试功能的便捷和强大。通过实践,用户将能够更深入地理解规则调试的强大功能,并将其应用于实际工作中,以提高开发效率和数据处理的灵活性。

相关实践学习
快速体验阿里云云消息队列RocketMQ版
本实验将带您快速体验使用云消息队列RocketMQ版Serverless系列实例进行获取接入点、创建Topic、创建订阅组、收发消息、查看消息轨迹和仪表盘。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
传感器 编解码 IDE
ESP32开发板引脚介绍【附有引脚使用实例】
ESP32开发板引脚介绍👨‍🏫内容1:背景👨‍⚖️内容2:限制类引脚👨‍💻内容3:ESP32 周边设备🍉文末备注 👨‍🏫。
ESP32开发板引脚介绍【附有引脚使用实例】
|
Python
Python读取DataFarme中Nan值时显示“KeyError: 1”
Python读取DataFarme中Nan值时显示“KeyError: 1”
875 0
Python读取DataFarme中Nan值时显示“KeyError: 1”
|
Java p3c 开发者
阿里java开发规范学习(附P3C IDEA插件 帮助规范的养成)
浅析 阿里巴巴 Java 开发规约 (未完成) contents 为什么要学 编程规约 P3C IDEA 插件 why-use 我们知道,一般稍微大一点的公司,都会在系统架构设计完成之后,编码工作开始之前,给出一份属于自家公司,或是自家团队给出的编码规范文...
5732 0
|
7月前
|
人工智能 云计算 数据中心
龙蜥牵手如意 RISC-V 社区,共筑 RISC-V 软件生态新未来
未来,双方将携手在 RISC-V 操作系统、高性能计算等领域开展合作。
|
算法 Java Go
Go vs Java:内存管理与垃圾回收机制对比
对比了Go和Java的内存管理与垃圾回收机制。Java依赖JVM自动管理内存,使用堆栈内存并采用多种垃圾回收算法,如标记-清除和分代收集。Go则提供更多的手动控制,内存分配与释放由分配器和垃圾回收器协同完成,使用三色标记算法并发回收。示例展示了Java中对象自动创建和销毁,而Go中开发者需注意内存泄漏。选择语言应根据项目需求和技术栈来决定。
|
11月前
|
数据可视化 数据挖掘 Java
报表工具怎么选?8款主流报表工具大测评!
报表工具怎么选?8款主流报表工具大测评!
@SneakyThrows 是 Lombok 库中的一个注解
`@SneakyThrows` 是 Lombok 库中的一个注解,它可以让你在方法签名中省略异常声明,而不需要显式地使用 try-catch 块来处理这些异常。当你使用 `@SneakyThrows` 注解时,Lombok 会自动生成相应的 try-catch 代码,将异常封装成运行时异常(通常是 `RuntimeException` 或其子类)。 这个注解在某些情况下可以简化代码,但请注意,它可能会隐藏潜在的问题,因为异常被转换成了运行时异常,这可能导致调用者无法正确处理这些异常。 下面是一个使用 `@SneakyThrows` 的示例: ```java import lombok.S
984 0
|
缓存 关系型数据库 MySQL
Java 实现实时监听MySQL数据库变更MySQLBinListener
Java 实现实时监听MySQL数据库变更MySQLBinListener