(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210835821.1 (22)申请日 2022.04.13 (62)分案原申请数据 202210381778.6 202 2.04.13 (71)申请人 杭州涂鸦信息技 术有限公司 地址 310013 浙江省杭州市西湖区浙商财 富中心3幢701室 (72)发明人 陈志伟　 (74)专利代理 机构 北京品源专利代理有限公司 11332 专利代理师 郭德霞 (51)Int.Cl. G06F 9/50(2006.01) (54)发明名称 数据处理方法、 装置、 分发服务器、 系统及存 储介质 (57)摘要 本发明实施例公开了一种数据处理方法、 装 置、 分发服务器、 系统及存储介质。 该方法包括： 获取实体设备的上报数据， 并确定与所述上报数 据关联的规则； 按照设定分发策略将所述上报数 据以及所述规则以组合的形式分发至主题分区， 其中， 每个所述组合包括一个实体 设备的上报数 据与所关联的单个规则， 每个所述主题分区对应 一个执行服务器， 所述执行服务器用于处理对应 所述主题分区中的上报数据以及规则。 上述技术 方案通过将上报数据按照实体设备和规则两个 维度分发至不同的主题分区， 将规则的处理压力 分给各执行服务器， 解决了数据倾斜、 单个服务 器的负载压力过大 带来的业 务不稳定问题。 权利要求书2页 说明书13页 附图4页 CN 115237595 A 2022.10.25 CN 115237595 A 1.一种数据处 理方法， 其特 征在于， 包括： 获取实体设备的上报数据， 并确定与所述上报数据关联的规则； 按照设定分发策略将所述上报数据 以及所述规则以组合的形式分发至主题分区， 其 中， 每个所述组合包括一个实体设备 的上报数据与所关联 的单个规则， 每个所述主题分区 对应一个执行服务器， 所述执行服务器用于处理对应所述主题分区中的上报数据以及规 则； 所述按照设定分发策略将所述上报数据以及所述规则以组合的形式分发至主题分区， 包括： 根据各所述执行服务器的处 理能力确定各 所述执行服务器的权值； 根据各所述执行服务器的权值， 将各所述组合轮流分发至各所述执行服务器的主题分 区； 根据各所述执行服务器的权值， 将各所述组合轮流分发至各所述执行服务器的主题分 区， 包括： 轮流将每个执行服务器作为目标服务器， 并将与 所述目标服务器的权值相符的数量的 组合分发至所述目标服 务器的主题分区， 直至各 所述组合均分发至相应的主题分区。 2.根据权利要求1所述的方法， 其特征在于， 在按照设定分发策略将所述上报数据以及 所述规则以组合的形式分发至主题分区之前， 还 包括： 根据以下至少一项对所述上报数据以及所述 规则进行 过滤： 所述设定分发策略的开关状态； 过 滤名单； 设定实体号； 设定数据类型。 3.根据权利要求1所述的方法， 其特 征在于， 所述获取实体设备的上报数据， 包括： 基于实体设备划分主题分区， 其中， 每 个主题分区用于存 储一个实体设备的上报数据； 从各所述主题分区中读取 所述上报数据。 4.根据权利要求1所述的方法， 其特 征在于， 还 包括： 按照设定数据结构记录所述上报数据和所述 规则的处 理信息； 其中， 所述处 理信息包括以下至少一项： 链路追踪标识； 上报事件标识； 实体号； 设备类型标识； 数据名称； 数据结构； 上报数据 点； 规则处 理时间； 设备 上报时间； 规则分发时间； 处 理器类型； 数据属性。 5.一种数据处 理装置， 其特 征在于， 包括： 获取模块， 设置为获取实体设备的上报数据， 并确定与所述上报数据关联的规则； 分发模块， 设置为按照设定分发策略将所述上报数据以及所述规则以组合的形式分发 至主题分区， 其中， 每个所述组合包括一个实体设备的上报数据与所关联的单个规则， 每个 所述主题分区对应一个执行服务器， 所述执行服务器用于处理对应所述主题分区中的上报 数据以及规则； 所述分发模块， 包括： 权值确定单元， 设置为根据 各所述执行服务器的处理能力确定各所述执行服务器的权 值； 轮流分发单元， 设置为根据各所述执行服务器的权值， 将各组合轮流分发至各所述执 行服务器的主题分区。 所述轮流分发单 元设置为：权　利　要　求　书 1/2 页 2 CN 115237595 A 2轮流将每个执行服务器作为目标服务器， 并将与 所述目标服务器的权值相符的数量的 组合分发至所述目标服 务器的主题分区， 直至各 所述组合均分发至相应的主题分区。 6.一种分发服 务器， 其特 征在于， 包括： 至少一个处 理器； 以及 与所述至少一个处 理器通信连接的存 储器； 其中， 所述存储器存储有可被所述至少一个处理器执行的计算机程序， 所述计算机程序被所 述至少一个处理器执行， 以使所述至少一个处理器能够执行如权利要求1 ‑4中任一所述的 数据处理方法。 7.一种数据处理系统， 其特征在于， 包括： 实体设备、 执行服务器以及如权利要求6所述 的分发服 务器； 其中， 所述实体设备用于向所述分发服 务器发送上报数据； 所述执行服务器用于处 理分发至相应的主题分区的上报数据以及规则。 8.根据权利要求7 所述的系统， 其特 征在于， 所述执 行服务器具体用于： 将分发至所述主题分区的上报数据转换为标准格式， 并从标准格式的上报数据中提取 元数据信息； 根据所述元 数据信息确定业 务数据； 将所述业务数据以及分发至所述主题分区的规则加入规则池； 触发执行器执行所述规则池中的规则。 9.一种计算机可读存储介质， 所述计算机可读存储介质存储有计算机指令， 其特征在 于， 所述计算机指令用于使处 理器执行时实现权利要求1 ‑4中任一所述的数据处 理方法。权　利　要　求　书 2/2 页 3 CN 115237595 A 3