(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211168038.0 (22)申请日 2022.09.23 (71)申请人 阳光电源 （南京） 有限公司 地址 210012 江苏省南京市雨 花台区宁双 路19号云密城D栋9 楼901室 (72)发明人 陈旺　 (74)专利代理 机构 北京品源专利代理有限公司 11332 专利代理师 初春 (51)Int.Cl. G06Q 10/10(2012.01) G06Q 10/06(2012.01) G06Q 50/06(2012.01) (54)发明名称 一种数据处 理方法、 装置、 设备及系统 (57)摘要 本发明公开了一种数据处理方法、 装置、 设 备及系统。 该方法包括： 接收第一数据流， 确定所 述第一数据流的数据类型， 其中， 所述第一数据 流为待处理数据流， 所述第一数据流中包含多个 数据类型的数据； 确定所述多个数据类型的数据 量， 并根据所述数据量确定所述数据类型的优先 级排序； 基于所述优先级排序和所述数据类型， 处理所述第一数据流。 本发明实施例的技术方 案， 通过确定数据流的数据的优先级， 让运维人 员能及时获取最需要的数据信息， 提高了处理数 据的效率。 权利要求书2页 说明书10页 附图3页 CN 115511453 A 2022.12.23 CN 115511453 A 1.一种数据处 理方法， 其特 征在于， 包括： 接收第一数据流， 确定所述第 一数据流的数据类型， 其中， 所述第一数据流为待处理数 据流， 所述第一数据流中包 含多个数据类型的数据； 确定所述多个数据类型的数据量， 并根据所述数据量确定所述数据类型的优先级排 序； 基于所述优先级排序和所述数据类型， 处 理所述第一数据流。 2.根据权利要求1所述的方法， 其特征在于， 在所述接收第一数据流， 确定所述第一数 据流的数据类型之后， 还 包括： 根据所述数据类型， 在预设集群中创建对应的预设数据库； 基于所述数据类型， 将所述第一数据流的数据分别写入 对应的预设数据库中。 3.根据权利要求1或2所述的方法， 其特征在于， 所述确定所述多个数据类型的数据量， 并根据所述数据量确定所述数据类型的优先级排序， 包括： 确定所述第一数据流包 含的各数据类型的数据量； 将所述数据类型按照所述数据量的大小进行依次排序， 得到所述数据类型的初始优先 级排序队列， 或， 基于所述数据量计算所述各数据类型的数据量占比， 并将所述数据类型， 按照所述数 据量占比的大小进 行依次排序， 得到所述数据类型的初始优先级排序队列， 其中， 所述数据 类型的数据量占比为所述第一数据流包含的各数据类型的数据量分别占所述第一数据流 的总数据量的百分比； 根据所述初始优先级排序队列， 确定所述数据类型的优先级排序。 4.根据权利要求3所述的方法， 其特征在于， 所述根据所述初始优先级排序队列， 确定 所述数据类型的优先级排序， 包括： 确定预设处 理引擎处 理所述数据类型的数据的速度； 根据所述速度和所述初始优先级排序队列， 确定所述数据类型的优先级排序。 5.根据权利要求4所述的方法， 其特征在于， 所述根据所述速度和所述初始优先级排序 队列， 确定所述数据类型的优先级排序， 包括： 基于所述初始优先级排序队列， 遍历所述数据类型的数据量占比或所述数据类型的数 据量， 将满足预设条件的数据类型的排序， 确定为第一排序队列， 其中， 所述预设条件包括 数据类型的数据量占比低于预设值， 或所述数据类型的数据量低于预设值； 根据所述第一 排序队列和所述速度， 确定所述数据类型的优先级排序。 6.根据权利要求5所述的方法， 其特征在于， 所述根据所述第一排序队列和所述速度， 确定所述数据类型的优先级排序， 包括： 将不满足所述预设条件的数据类型的排序， 确定为第二 排序队列； 将所述第一排序队列中的数据类型， 按照所述预设处理引擎处理所述数据类型的数据 的速度， 从快到慢， 进行排序， 得到第二 排序结果； 根据所述第二 排序结果， 确定所述数据类型的第三 排序队列； 将所述第三 排序队列添加至所述第二 排序队列的前面， 得到优先级排序。 7.根据权利要求1所述的方法， 其特征在于， 在所述基于所述优先级排序和所述数据类 型， 处理所述第一数据流之前， 还 包括：权　利　要　求　书 1/2 页 2 CN 115511453 A 2判断是否存在第二数据流， 若是， 则同时对所述第一数据流和所述第二数据流进行处 理， 其中， 所述第二数据流 为正在处理中的数据流； 待处理所述第二数据流完成后， 将所述第二数据流的处理结果， 存入预设内存数据库 中； 经过预设时间后， 将所述预设内存数据库中的处理结果， 输出到应用 层进行展示和应 用。 8.根据权利要求2或4所述的方法， 其特征在于， 所述预设集群包括Kafka， 和/或， 所述 预设处理引擎包括Fl ink。 9.根据权利要求1所述的方法， 其特征在于， 所述接收第一数据流， 确定所述第一数据 流的数据类型， 包括： 接收电站发送的第一数据流， 确定所述第一数据流的数据类型， 其中， 所述数据类型包 括遥测数据、 遥信数据以及电度数据。 10.一种数据处 理装置， 其特 征在于， 包括： 数据类型确定模块， 用于接收第一数据流， 确定所述第一数据流的数据类型， 其中， 所 述第一数据流 为待处理数据流， 所述第一数据流中包 含多个数据类型的数据； 优先级排序确定模块， 用于确定所述多个数据类型的数据量， 并根据所述数据量确定 所述数据类型的优先级排序； 第一数据流处理模块， 用于基于所述优先级排序和所述数据类型， 处理所述第一数据 流。 11.一种电子设备， 其特 征在于， 所述电子设备包括： 至少一个处 理器； 以及 与所述至少一个处 理器通信连接的存 储器； 其中， 所述存储器存储有可被所述至少一个处理器执行的计算机程序， 所述计算机程序被所 述至少一个处理器执行， 以使所述至少一个处理器能够执行权利要求1 ‑9中任一项所述的 数据处理方法。 12.一种电站监控系统， 其特征在于， 所述系统包括： 至少一个分布式电站， 以及至少一 个监控主站， 所述监控主站用于实现权利要求 1‑9中任一项 所述的数据处理方法， 所述监控 主站用于对所述分布式电站的运行 数据进行监控与管理。权　利　要　求　书 2/2 页 3 CN 115511453 A 3