(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210492515.2 (22)申请日 2022.05.07 (71)申请人 安徽凯炎电力保护设备有限公司 地址 230000 安徽省合肥市高新区潜水东 路3号安徽铸诚公司厂房 (72)发明人 陈珺　尹波　 (74)专利代理 机构 合肥律众知识产权代理有限 公司 34147 专利代理师 赵娟 (51)Int.Cl. G06F 16/26(2019.01) G06F 16/2455(2019.01) G06F 16/22(2019.01) G06F 16/182(2019.01) G06Q 50/06(2012.01) (54)发明名称 一种用电数据集成系统 (57)摘要 本发明涉及数据集 成， 具体涉及一种用电数 据集成系统， 包括服务器， 服务器通过用电数据 采集单元采集不同类型用电主体的用电数据， 服 务器通过存储区块创建模块创建用于按照用电 主体类型存储用电数据的存储区块， 并通过存储 数据更新模块对 各区块数据进行数据更新， 服务 器通过存储数据聚合单元按照数据类型对各区 块数据进行数据聚合， 服务器通过数据集市构建 模块构建数据集市， 并通过数据导入模块将区块 数据、 聚合数据导入数据集市， 服务器通过数据 索引模块提供数据集市的数据检索服务； 本发明 提供的技术方案能够有效克服现有技术所存在 的无法全面有效地采集用电数据、 可扩展性较 差、 不具备数据快速 检索功能的缺陷。 权利要求书2页 说明书4页 附图2页 CN 114756619 A 2022.07.15 CN 114756619 A 1.一种用电数据集成系统， 其特征在于： 包括服务器， 所述服务器通过用电数据采集单 元采集不同类型用电主体的用电数据， 所述服务器通过存储区块创建模块创建用于按照用 电主体类型存储用电数据的存储区块， 并通过存储数据更新模块对各区块数据进 行数据更 新； 所述服务器通过存储数据聚合单元按照数据类型对各区块数据进行数据聚合， 所述服 务器通过数据集市构建模块构建数据集市， 并通过数据导入模块将区块数据、 聚合数据导 入数据集市， 所述 服务器通过 数据索引模块 提供数据集市的数据检索服 务。 2.根据权利要求1所述的用电数据集成系统， 其特征在于： 所述用电数据采集单元包括 用户信息采集模块、 设备信息采集模块和用电量统计模块， 所述用户信息采集模块用于采 集用户信息， 所述设备信息采集模块用于采集用电设备信息， 所述用电量统计模块用于统 计各类型用户的用电量。 3.根据权利要求1所述的用电数据集成系统， 其特征在于： 所述存储区块创建模块创建 用于按照用电主体类型存储用电数据的存储区块， 所述存储区块包括居民用户用电数据存 储区块、 工商业用户用电数据存储区块、 工业用户用电数据存储区块和农业用户用电数据 存储区块。 4.根据权利要求3所述的用电数据集成系统， 其特征在于： 所述存储数据 更新模块将用 电数据采集单元上传的类型用电主体的用电数据存储至对应存储区块， 并删除设定时间段 范围外的历史用电数据。 5.根据权利要求1所述的用电数据集成系统， 其特征在于： 所述存储数据聚合单元包括 区块数据读取模块、 数据特征提取模块和区块数据聚合模块， 所述区块数据读取模块用于 从存储区块创建模块创建的存储区块中读取区块数据， 所述数据特征提取模块用于提取区 块数据的数据特征， 并根据数据特征确定适配的聚合算法， 所述区块数据聚合模块利用聚 合算法对区块数据按照数据类型进行 数据聚合。 6.根据权利要求5所述的用电数据集成系统， 其特征在于： 所述数据导入模块内部封装 有多种数据导入组件， 并支持原生API， 所述数据导入模块基于区块数据、 聚合数据的数据 类型， 选择适配的数据导入组件将区块数据、 聚合数据导入数据集市。 7.根据权利要求6所述的用电数据集成系统， 其特征在于： 所述数据导入组件包括 Kettle组件和Sqoop组件， 所述Kettle组件用于将多种 格式的区块数据、 聚合数据， 以及关 系型数据导入Hadop p分布式平台； 所述Sqoop组件用于将关系型 数据导入Hadop p分布式平台； 所述原生API用于调用Hadopp分布式文件系统， 以及Hbase数据的API， 并导入Hadopp分 布式平台。 8.根据权利要求6所述的用电数据集成系统， 其特征在于： 所述数据集市包括用于存储 用户信息、 用电设备信息的项目信息表， 以及用于存 储各类型用户的用电量的数据信息表； 所述项目信息表中存储的字段包括用户编号、 用户名称、 用电地址、 用电类别、 用户分 类、 电价类别和电表ID； 所述数据信 息表中存储的字段包括用户编号、 抄表时间、 抄表数据、 时间段内用电量和 电表ID， 所述抄表时间、 抄表数据在原记录位置重新覆盖， 所述时间段内用电量以天为单位 分行记录 。权　利　要　求　书 1/2 页 2 CN 114756619 A 29.根据权利要求8所述的用电数据集成系统， 其特征在于： 所述数据索引模块通过 rowkey映射索引表对项目信息表进行索引， 所述r owkey映射索引表包括两个HBase表， 其中 一个HBase表的rowkey为电表ID， 每一列为该电表ID下对应的用户信息； 另一个HBase表的 rowkey为索引条件， 每一列为索引条件下对应的电表ID； 所述项目信息表的索引条件 包括用户名称、 用电地址、 用电类别、 用户分类。 10.根据权利要求8所述的用电数据集成系统， 其特征在于： 所述数据索引模块通过 rowkey映射索引表对数据信息表表进行索引， 所述r owkey映射索引表包括一个HBase表， 所 述HBase表的r owkey为电表 ID和抄表时间， 每一列为该电表在对应抄表时间下的抄表数据、 时间段内用电量。权　利　要　求　书 2/2 页 3 CN 114756619 A 3