-
公开(公告)号: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)的对应分发参数选项,连接数据处理组件,执行调度后,可以将处理后的数据分发到指定数据存储中。
-