(19)中华 人民共和国 国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202111577843.4 (22)申请日 2021.12.2 2 (71)申请人 中核武汉 核电运行技 术股份有限公 司 地址 430223 湖北省武汉市东湖新 技术开 发区民族大道1021号 (72)发明人 方华建　刘旭嘉　景应刚　徐奎　 程敏敏　杨强　李荣君　郑明　 (74)专利代理 机构 核工业专利中心 1 1007 代理人 李东斌 (51)Int.Cl. G06Q 50/06(2012.01) H04L 67/12(2022.01) H04L 67/565(2022.01) (54)发明名称 一种核电工业互联网平台的时序数据存储 方法 (57)摘要 本发明提供了一种核电工业互联网平台的 时序数据存储方法， 包括如下步骤： 各电厂接口 机上的时序数据采集和上传工具将时序数据经 由相应的MQTT客户端分别发送至核电工业互联 网平台中心侧的MQTT 服务器， 并依据时序数据的 属性分别上传到不同的Topic中； 设置第一个消 费者模块， 第一个消费者模块订阅并消费MQTT 服 务器中的数据然后进行处理； Kafka系统接收第 一个消费者模块发送过来的时序数据， 把不同类 型的时序数据存储在不同的Topic中； 设置第二 个消费者模块， 第二个消费者模块订阅并消费 Kafka消息系统中的数据然后进行处理； 时序数 据库用于将依据时序数据的属性将低频时序数 据和高频时序数据分开保存。 本发 明提供的方法 能够更加合理、 高效地管理时序数据。 权利要求书2页 说明书5页 附图2页 CN 114387124 A 2022.04.22 CN 114387124 A 1.一种核电工业互联网平台的时序数据存 储方法， 其特 征在于， 包括如下步骤： 步骤S1： 各电厂接口机上的时序数据采集和上传工具将时序数据经由相应的MQTT客户 端分别发送至核电工业互联网平台中心侧的MQTT服务器， 并依据所述时序数据的属性分别 上传到不同的Topic中； 步骤S2： 设置第一个消费者模块， 所述第一个消费者模块订阅并消费MQTT服务器中的 数据然后进行处 理； 步骤S3： Kafka系统接收第一个消费者模块发送过来的时序数据， 把不同类型的时序数 据存储在不同的Topic中； 步骤S4： 设置第二个消费者模块， 所述第二个消费者模块订阅并消费Kafka消息系统中 的数据然后进行处 理； 步骤S5： 所述时序 数据库用于将依据时序 数据的属性将所述低频时序 数据和所述高频 时序数据分开保存。 2.根据权利要求1所述的一种 核电工业互联网平台的时序 数据存储方法， 其特征在于， 所述第二个消费者模块对接收到的时序数据包处 理包括如下步骤： 步骤S41： 对收到的时序数据分别进行解包、 解密、 解压操作后获取原 始数据信息； 步骤S42： 根据 所获取的原始数据的高低频属性,调用预设规则将所述原始数据转换为 指定的数据格式并依据所述原始数据的测 点属性确定所述原始 时序数据在数据库中的存 储区域。 3.根据权利要求2所述的一种 核电工业互联网平台的时序 数据存储方法， 其特征在于， 所述步骤S42调用预设规则以将所述原始数据转换为指定的数据格式包括： 获取所述时序 数据的数据类型， 并依据所述数据类型以及预设规则将所述原始数据转换为指 定的数据格 式。 4.根据权利要求2所述的一种 核电工业互联网平台的时序 数据存储方法， 其特征在于， 所述预设规则为： 若所述数据类型 数值为0， 则将所述时序数据测点 值转换为双精度浮 点值； 若所述数据类型 数值为1， 则将所述时序数据测点 值转换为单精度浮 点值； 若所述数据类型 数值为2， 则将所述时序数据测点 值转换为整型值； 若所述数据类型 数值为3， 则将所述时序数据测点 值转换为字符串值； 若所述数据类型 数值为4， 则将所述时序数据测点 值转换为布尔值。 5.根据权利要求1所述的一种 核电工业互联网平台的时序 数据存储方法， 其特征在于， 所述数据库存储所述高频时序数据时， 每个高频测点一个数据包中的所有 数据会作为一个 整体进行打包 存储。 6.根据权利要求1所述的一种 核电工业互联网平台的时序 数据存储方法， 其特征在于， 所述数据库存储所述低频时序数据， 依据所述低频时序数据对应测点的编码， 将不同时间 段的同一测点的低频时序数据存储于一个区域， 将来自同一个电厂、 同一机组的不同测点 数据也存 储在同一个的区域中。 7.根据权利要求1所述的一种 核电工业互联网平台的时序 数据存储方法， 其特征在于， 所述第一消费者模块和第二消费模块均为 流式处理框架系统Fl ink。 8.根据权利要求1所述的一种 核电工业互联网平台的时序 数据存储方法， 其特征在于，权　利　要　求　书 1/2 页 2 CN 114387124 A 2所述时序数据库的数据可挂载到多块S SD固态硬盘， 底层存 储支持采用RAID方式进行。权　利　要　求　书 2/2 页 3 CN 114387124 A 3