-
公开(公告)号:CN114387124B
公开(公告)日:2024-06-07
申请号:CN202111577843.4
申请日:2021-12-22
Applicant: 中核武汉核电运行技术股份有限公司
IPC: G06Q50/06 , H04L67/12 , H04L67/565
Abstract: 本发明提供了一种核电工业互联网平台的时序数据存储方法,包括如下步骤:各电厂接口机上的时序数据采集和上传工具将时序数据经由相应的MQTT客户端分别发送至核电工业互联网平台中心侧的MQTT服务器,并依据时序数据的属性分别上传到不同的Topic中;设置第一个消费者模块,第一个消费者模块订阅并消费MQTT服务器中的数据然后进行处理;Kafka系统接收第一个消费者模块发送过来的时序数据,把不同类型的时序数据存储在不同的Topic中;设置第二个消费者模块,第二个消费者模块订阅并消费Kafka消息系统中的数据然后进行处理;时序数据库用于将依据时序数据的属性将低频时序数据和高频时序数据分开保存。本发明提供的方法能够更加合理、高效地管理时序数据。
-
公开(公告)号:CN115776378B
公开(公告)日:2024-02-09
申请号:CN202111036401.9
申请日:2021-09-06
Applicant: 中核武汉核电运行技术股份有限公司
IPC: H04L9/40 , H04L67/568 , H04L69/04 , H04L69/08 , H04L67/12 , G06F16/215 , G06F16/25
Abstract: 本发明公开了一种核电工业互联网平台时序数据实时接入方法,包括以下步骤:采集传感器数据或者PI系统数据,将其传输至进入边缘服务器;边缘服务器对时序数据进行缓存和数据清洗、数据转换、数据降频、降维和数据压缩处理;将处理后的数据以MQTT协议或者Kafka协议接入核电工业互联网平台的MQTT服务器或者Kafka中,数据以二进制或JSON数据包方式进行传输;核电工业互联网平台侧接收时序数据并将解析后得到的时序数据信息写入时序数据库中心。其有益效果在于:(1)传感器数据进入边缘服务器之前需要通过安全网闸,保证了数据传输的安全性。
-
公开(公告)号:CN115185898B
公开(公告)日:2024-02-09
申请号:CN202210553023.X
申请日:2022-05-20
Applicant: 中核武汉核电运行技术股份有限公司
Abstract: 本发明属于核电站控制技术领域,具体的涉及一种核电厂数据周期性实时处理方法。包括如下步骤:S1:根据需求生成组态文件;S2:所述组态文件经由下装工具形成可直接调用文件后下装至算法配置库;S3:算法配置库收到所述可直接调用文件后通知MST,所述MST从算法配置库中加载二进制文件,生成相应的算法模块进程并管控;S4:所述算法模块进程从Redis数据库获取所需要的数据以执行计算,并将计算结果存储至Redis数据库中。其有益效果在于:本发明能够按照预定的周期来对实时数据进行周期性的计算,智能化程度高,提高了数据实时处理系统的使用便利性,加快了数据处理的速度,保证了数据处理的实时性。
-
公开(公告)号:CN115185900A
公开(公告)日:2022-10-14
申请号:CN202210553056.4
申请日:2022-05-20
Applicant: 中核武汉核电运行技术股份有限公司
Abstract: 本发明属于核电站控制技术领域,具体涉及一种时序数据实时计算算法下装方法。包括如下步骤:S1:获取组态文件并将所述组态文件转换为源码文件;S2:对所述源码文件进行数据合规性检查与逻辑合规性检查,若所述源码文件通过所述检查,则转入步骤S3;S3:格式转换,将通过检查所述源码文件转换为目标码文件;S4:形成函数调用,将所述目标码文件转换为动态链接库文件。其有益效果在于:在下装过程中,结合核电厂组态文件的特殊性,专门设置数据合规性检查和逻辑合规性检查,以确保组态文件经转换后所形成的中的动态链接库文件是正确无误的。
-
公开(公告)号:CN114387124A
公开(公告)日:2022-04-22
申请号:CN202111577843.4
申请日:2021-12-22
Applicant: 中核武汉核电运行技术股份有限公司
IPC: G06Q50/06 , H04L67/12 , H04L67/565
Abstract: 本发明提供了一种核电工业互联网平台的时序数据存储方法,包括如下步骤:各电厂接口机上的时序数据采集和上传工具将时序数据经由相应的MQTT客户端分别发送至核电工业互联网平台中心侧的MQTT服务器,并依据时序数据的属性分别上传到不同的Topic中;设置第一个消费者模块,第一个消费者模块订阅并消费MQTT服务器中的数据然后进行处理;Kafka系统接收第一个消费者模块发送过来的时序数据,把不同类型的时序数据存储在不同的Topic中;设置第二个消费者模块,第二个消费者模块订阅并消费Kafka消息系统中的数据然后进行处理;时序数据库用于将依据时序数据的属性将低频时序数据和高频时序数据分开保存。本发明提供的方法能够更加合理、高效地管理时序数据。
-
公开(公告)号:CN115185900B
公开(公告)日:2024-06-11
申请号:CN202210553056.4
申请日:2022-05-20
Applicant: 中核武汉核电运行技术股份有限公司
Abstract: 本发明属于核电站控制技术领域,具体涉及一种时序数据实时计算算法下装方法。包括如下步骤:S1:获取组态文件并将所述组态文件转换为源码文件;S2:对所述源码文件进行数据合规性检查与逻辑合规性检查,若所述源码文件通过所述检查,则转入步骤S3;S3:格式转换,将通过检查所述源码文件转换为目标码文件;S4:形成函数调用,将所述目标码文件转换为动态链接库文件。其有益效果在于:在下装过程中,结合核电厂组态文件的特殊性,专门设置数据合规性检查和逻辑合规性检查,以确保组态文件经转换后所形成的中的动态链接库文件是正确无误的。
-
公开(公告)号:CN117170627A
公开(公告)日:2023-12-05
申请号:CN202210589470.0
申请日:2022-05-26
Applicant: 中核武汉核电运行技术股份有限公司
IPC: G06F8/20 , G06F9/445 , G06F16/2458 , G06F16/25
Abstract: 本发明涉及一种时序数据网关采集与分发驱动开发框架及实现方法,属于计算机技术领域。该框架包括控制层、service层和客户端,通过控制层输入控制指令与配置参数,service层根据指令调取采集和上传驱动,客户端通过采集和上传驱动建立采集和上传服务,将采集数据解析、统一格式后,通过上传驱动发送至数据库,数据库对数据进行解析,提取分发驱动,形成对外分发数据接口,共其他系统、数据库调用。该框架及实现方法的应用减轻了非专业技术开发人员的压力,帮其免去了代码编写工作,同时也为专业开发人员提供了支持,自动化完成应用开发过程中的基础数据采集工作,便于专业开发人员聚焦于业务逻辑。
-
公开(公告)号:CN115776378A
公开(公告)日:2023-03-10
申请号:CN202111036401.9
申请日:2021-09-06
Applicant: 中核武汉核电运行技术股份有限公司
IPC: H04L9/40 , H04L67/568 , H04L69/04 , H04L69/08 , H04L67/12 , G06F16/215 , G06F16/25
Abstract: 本发明公开了一种核电工业互联网平台时序数据实时接入方法,包括以下步骤:采集传感器数据或者PI系统数据,将其传输至进入边缘服务器;边缘服务器对时序数据进行缓存和数据清洗、数据转换、数据降频、降维和数据压缩处理;将处理后的数据以MQTT协议或者Kafka协议接入核电工业互联网平台的MQTT服务器或者Kafka中,数据以二进制或JSON数据包方式进行传输;核电工业互联网平台侧接收时序数据并将解析后得到的时序数据信息写入时序数据库中心。其有益效果在于:(1)传感器数据进入边缘服务器之前需要通过安全网闸,保证了数据传输的安全性。
-
公开(公告)号:CN115186016A
公开(公告)日:2022-10-14
申请号:CN202110357623.4
申请日:2021-04-01
Applicant: 中核武汉核电运行技术股份有限公司
IPC: G06F16/25 , G06F16/215 , G06F21/62 , G06F21/60 , G06F3/04847 , G06F9/48
Abstract: 本发明公开了一种基于核电工业互联网平台的数据集成方法,包括以下步骤:步骤1:数据采集管理;步骤2:数据处理;步骤3:数据分发。本发明的有益效果在于:(1)通过前端页面图形化方式配置数据采集组件(Source)的对应数据存储参数选项,执行调度后,可以抽取指定数据存储中的数据;(2)通过前端页面图形化方式配置数据处理组件(Processor)的对应处理参数选项,连接数据采集组件,执行调度后,可以对采集到的数据进行处理转换;(3)通过前端页面图形化方式配置数据分发组件(Sink)的对应分发参数选项,连接数据处理组件,执行调度后,可以将处理后的数据分发到指定数据存储中。
-
公开(公告)号:CN115185898A
公开(公告)日:2022-10-14
申请号:CN202210553023.X
申请日:2022-05-20
Applicant: 中核武汉核电运行技术股份有限公司
Abstract: 本发明属于核电站控制技术领域,具体的涉及一种核电厂数据周期性实时处理方法。包括如下步骤:S1:根据需求生成组态文件;S2:所述组态文件经由下装工具形成可直接调用文件后下装至算法配置库;S3:算法配置库收到所述可直接调用文件后通知MST,所述MST从算法配置库中加载二进制文件,生成相应的算法模块进程并管控;S4:所述算法模块进程从Redis数据库获取所需要的数据以执行计算,并将计算结果存储至Redis数据库中。其有益效果在于:本发明能够按照预定的周期来对实时数据进行周期性的计算,智能化程度高,提高了数据实时处理系统的使用便利性,加快了数据处理的速度,保证了数据处理的实时性。
-
-
-
-
-
-
-
-
-