(19)国家知识产权局 (12)发明 专利 (10)授权公告 号 (45)授权公告日 (21)申请 号 202210978002.2 (22)申请日 2022.08.16 (65)同一申请的已公布的文献号 申请公布号 CN 115048390 A (43)申请公布日 2022.09.13 (73)专利权人 国能日新科技股份有限公司 地址 100096 北京市海淀区西三 旗建材城 内1幢二层2 27号 (72)发明人 夏全军　姚宁坡　雷从武　 (74)专利代理 机构 北京路浩知识产权代理有限 公司 11002 专利代理师 聂俊伟 (51)Int.Cl. G06F 16/22(2019.01) G06F 16/2455(2019.01)G06F 16/25(2019.01) (56)对比文件 CN 114817334 A,202 2.07.29 CN 111190928 A,2020.0 5.22 CN 114528049 A,202 2.05.24 US 2020301941 A1,2020.09.24 CN 113515499 A,2021.10.19 审查员 林筱枫 (54)发明名称 基于influxdb的数据存 储方法及装置 (57)摘要 本申请涉及数据处理技术领域， 提供一种基 于influxdb的数据存储方法及装置， 该方法包 括： 根据读取到的配置信息结合 设备配置表确定 目标处理数据， 根据目标处理数据构建key数据； 根据定时任务的方法参数确定key数据中被调度 的key信息， 并根据被调度的key信息确定业务数 据； 将业务数据封装为InfluxdbHistoryDataVo 对 象 ，并 将 预 设 时 长 内 所 有 的 InfluxdbHistoryDataVo对象转换为influxdb数 据格式存储至influxdb数据库中。 本申请实施例 提供的基于influxdb的数据存储方法通过 Influxdb数据库的高吞吐量和压缩率高特性， 提 升了聚合查询操作时的查询效率。 权利要求书2页 说明书11页 附图2页 CN 115048390 B 2022.11.01 CN 115048390 B 1.一种基于i nfluxdb的数据存 储方法， 其特 征在于， 包括： 根据读取到的配置信 息结合设备配置表确定目标处理数据， 并根据所述目标处理数据 构建key数据； 根据定时任务的方法参数确定所述key数据中被调度的key信息， 并根据所述被调度的 key信息确定业 务数据； 将所述业务数据封装为InfluxdbHistoryDataVo对象， 并将预设时长内所有的 InfluxdbHistoryDataVo对象转换为 influxdb数据格式存 储至influxdb数据库中； 其中， 所述 根据读取到的配置信息结合设备配置表确定目标处 理数据， 包括： 将所述配置信息按照所述设备配置表中的信息进行 数据转换， 得到各个待处 理数据； 将各个所述待 处理数据以map结构进行封装， 得到数据集合对象， 其中， 所述map结构包 括key信息和value信息， key信息为列名信息， value信息为各列中的具体值信息； 通过周期时间对所述数据集合对象进行过滤， 剔除所述数据集合对象中没有配置周期 时间的待处理数据， 并保存所述数据集合对 象中配置有周期时间的待处理数据， 得到所述 目标处理数据。 2.根据权利 要求1所述的基于influxdb的数据存储方法， 其特征在于， 所述根据所述目 标处理数据构建key数据， 包括： 根据所述目标处 理数据中的类型名称和周期时间， 构建 map的key信息； 根据所述目标处理数据中的类型名称和标识号ID， 构建redis的key信息， 并将所述 redis的key信息存 储至额外增 加的value信息中； 根据所述map的key信息和所述 额外增加的value信息， 构建所述 key数据。 3.根据权利要求1至2任一项所述的基于influxdb的数据存储方法， 其特征在于， 所述 将预设时长内所有的InfluxdbHistoryDataVo对象转换为influxdb数据格式存储至 influxdb数据库中之后， 还 包括： 通过redis消息订阅方式监听队列historyUpdate， 确定所述队列historyUpdate中的 配置信息是否发生变更； 若所述队列 historyUpdate中 的配置信息发生了变更， 则根据所述队列 historyUpdate 中配置表结合时间戳的消息重新加载新的配置表， 以通过所述新的配置表完成数据重新采 集。 4.一种基于i nfluxdb的数据存 储装置， 其特 征在于， 包括： 构建模块， 用于根据读取到的配置信息结合设备配置表确定目标处理数据， 并根据所 述目标处 理数据构建key数据； 确定模块， 用于根据定时任务的方法参数确定所述key数据中被调度的key信息， 并根 据所述被调度的key信息确定业 务数据； 存储模块， 用于将所述业务数据封装为InfluxdbHistoryDataVo对象， 并将预设时长内 所有的InfluxdbHistoryDataVo对象转换为 influxdb数据格式存 储至influxdb数据库中； 所述构建模块还用于： 将所述配置信息按照所述设备配置表中的信息进行 数据转换， 得到各个待处 理数据； 将各个所述待 处理数据以map结构进行封装， 得到数据集合对象， 其中， 所述map结构包 括key信息和value信息， key信息为列名信息， value信息为各列中的具体值信息；权　利　要　求　书 1/2 页 2 CN 115048390 B 2通过周期时间对所述数据集合对象进行过滤， 剔除所述数据集合对象中没有配置周期 时间的待处理数据， 并保存所述数据集合对 象中配置有周期时间的待处理数据， 得到所述 目标处理数据。 5.根据权利 要求4所述的基于influxdb的数据存储装置， 其特征在于， 所述构 建模块还 用于： 根据所述目标处 理数据中的类型名称和周期时间， 构建 map的key信息； 根据所述目标处理数据中的类型名称和标识号ID， 构建redis的key信息， 并将所述 redis的key信息存 储至额外增 加的value信息中； 根据所述map的key信息和所述 额外增加的value信息， 构建所述 key数据。 6.一种电子设备， 所述电子设备包括存储器、 处理器及存储在存储器上并可在处理器 上运行的计算机程序， 其特征在于， 所述处理器执行所述计算机程序时实现权利要求1至3 任一项所述的基于i nfluxdb的数据存 储方法。 7.一种非暂态计算机可读存储介质， 所述非暂态计算机可读存储介质包括计算机程 序， 其特征在于， 所述计算机程序被处理器执行时实现权利要求1至3任一项所述的基于 influxdb的数据存 储方法。权　利　要　求　书 2/2 页 3 CN 115048390 B 3