(19)中华 人民共和国 国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202111581964.6 (22)申请日 2021.12.2 2 (71)申请人 深圳供电局有限公司 地址 518000 广东省深圳市罗湖区深南 东 路4020号电力调度通信大楼 (72)发明人 魏华杰　黄慧山　钟聪　薛冰　 陈敏　刘迪　庄婉铃　耿博　 (74)专利代理 机构 深圳汇智容达专利商标事务 所(普通合伙) 44238 代理人 熊贤卿 (51)Int.Cl. H04Q 9/00(2006.01) H04L 47/24(2022.01) G06F 16/215(2019.01) G06Q 50/06(2012.01) (54)发明名称 一种基于大数据的电表核收数据分流处理 系统及方法 (57)摘要 本发明提供一种基于大数据的电表核收数 据分流处理方法， 包括： 步骤S10， 周期性地采集 各类电表相关设备的运行数据； 步骤S11， 对采集 的运行数据进行预处理， 并将每一运行数据标准 化； 步骤S12， 将预处理后的所有数据进行数据类 别划分， 分别导入多个数据处理通道中； 步骤 S13， 根据系统实时响应率， 确定 是否需要对各通 道的数据进行分流处理； 步骤S14， 在需要分流 时， 则将需要分流的数据分流至相应的并行服务 器中； 否则， 将数据传 送给主服务器中； 步骤S15， 主服务器或并行服务器对数据进行整合分析以 及核对处理， 形成各用户的用户数据包。 本发明 还公开了相应的系统。 实施本发明， 可 以提升抄 表效率， 缩短电表数据的采集核收的整体时间。 权利要求书2页 说明书5页 附图2页 CN 114286203 A 2022.04.05 CN 114286203 A 1.一种基于大 数据的电表核收数据分流处 理方法， 其特 征在于， 包括如下步骤： 步骤S10， 周期性 地通过前置机采集各类电表相关 设备的运行 数据； 步骤S11， 对所述采集的运行数据进行预处理， 并将每一运行数据标准化； 所述预处理 至少包括： 对缺损数据进行修复、 删除无用数据、 去除数据中含有的乱码和重复部分； 步骤S12， 确定每一预处理后的数据的数据类别， 将所述预处理后的所有数据根据 数据 类别进行划分， 分别导入多个数据处理通道中； 其中， 每一个所述数据处理通道分别对应一 个类别的数据； 步骤S13， 根据系统实时响应率， 确定是否需要对各数据处理通道的数据进行分流处 理； 步骤S14， 如果判断结果为需要分流， 则将需要分流的数据处理通道的数据分流至与主 服务器相连的多个并行服务器中的一个中； 否则， 将所述数据 处理通道的数据传送给主服 务器中； 步骤S15， 所述主服务器或并行服务器接收到数据处理通道的数据后， 对所述数据进行 整合分析以及核对处理， 形成各用户的用户数据包； 并将所述用户数据包推送至相应的用 户端。 2.如权利要求1所述的方法， 其特 征在于， 进一 步包括： 预先配置并行服务器与数据类别之间的对应关系， 其中， 每一并行服务器对应于一个 数据类别。 3.如权利要求2所述的方法， 其特 征在于， 所述 步骤S13进一 步包括： 将系统实时响应率与一预设的响应率阈值进行比较， 如果系统实时响应率小于所述响 应阈值， 则确定需要 进行分流处 理； 否则， 确定无需分流处 理； 如果确定需要分流处理， 则根据实时响应率查询一响应率与分流数量对应表， 确定需 要分流的数据 处理通道的数量， 并获得每一数据处理通道所对应的并行服务器信息， 以将 每一需要分流的数据处 理通道的数据分流至相应的并行服 务器中。 4.一种基于大 数据的电表核收数据分流处 理系统， 其特 征在于， 包括： 数据采集单 元， 用于周期性 地通过前置机采集各类电表相关 设备的运行 数据； 预处理单元， 用于对所述采集的运行数据进行预处理， 并将每一运行数据 标准化； 所述 预处理至少包括： 对缺损数据进行修复、 删除无用数据、 去除数据中含有的乱码和重复部 分； 数据划分单元， 用于确定每一预处理后的数据的数据类别， 将所述预处理后的所有数 据根据数据类别进 行划分， 分别导入多个数据处理通道中； 其中， 每一个所述数据处理通道 分别对应一个 类别的数据； 分流判断单元， 用于根据系统实时响应率， 确定是否需要对各数据处理通道的数据进 行分流处 理； 分流处理单元， 用于在所述分流判断单元的判断结果为需要分流， 则将需要分流的数 据处理通道的数据分流至与主服务器相连的多个并行服务器中的一个中； 否则， 将所述数 据处理通道的数据传送给主服 务器中； 核对处理单元， 用于在所述主服务器或并行服务器接收到数据处理通道的数据后， 对 所述数据进行整合分析以及核对处理， 形成各用户的用户数据包； 并将所述用户数据包推权　利　要　求　书 1/2 页 2 CN 114286203 A 2送至相应的用户端。 5.如权利要求 4所述的系统， 其特 征在于， 进一 步包括： 配置单元， 用于预先配置并行服务器与数据类别之间的对应关系， 其中， 每一并行服务 器对应于一个数据类别。 6.如权利要求2所述的系统， 其特 征在于， 所述分流判断单 元进一步包括： 比较单元， 用于将系统实时响应率与一预设的响应率阈值进行比较， 如果系统实时响 应率小于所述响应阈值， 则确定需要 进行分流处 理； 否则， 确定无需分流处 理； 分流通道数量确定单元， 用于在比较单元确定需要分流处理时， 则根据实时响应率查 询一响应率与分流数量对应表， 确定需要分流的数据 处理通道的数量， 并获得每一数据 处 理通道所对应的并行服 务器信息 。权　利　要　求　书 2/2 页 3 CN 114286203 A 3