(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210553667.9 (22)申请日 2022.05.19 (71)申请人 北京达佳互联信息技 术有限公司 地址 100085 北京市海淀区上地西路6号1 幢1层101D1-7 (72)发明人 曹红阳　陶善文　 (74)专利代理 机构 北京律智知识产权代理有限 公司 11438 专利代理师 王辉 (51)Int.Cl. H04L 67/63(2022.01) H04L 67/5651(2022.01) H04L 67/1097(2022.01) H04L 67/10(2022.01) G06N 20/00(2019.01)G06F 9/50(2006.01) G06F 3/06(2006.01) (54)发明名称 数据分发方法、 装置、 系统、 设备、 介质和程 序产品 (57)摘要 本公开提供了一种数据分发方法、 装置、 系 统、 电子设备、 计算机可读存储介质以及计算机 程序产品， 涉及数据分发技术领域。 该方法包括： 响应于预设服务实例的启动指令， 启动全量数据 获取线程； 通过全量数据获取线程确定至少一第 一数据存储端， 从确定出的至少一第一数据存储 端获取并存储全量数据； 第一数据存储端存储有 全量数据； 基于预设服务实例启动增量数据获取 线程， 通过增量数据获取线程 从第二数据存储端 获取并存储增量数据； 响应于数据获取请求， 将 全量数据与增量数据分发至数据获取请求对应 的用户端。 本公开可以更快的读取历史全量数 据， 避免造成数据读取压力， 节省大量机器成本， 同时通过内部进行增量数据和全量数据分发， 无 需用户感知。 权利要求书2页 说明书12页 附图5页 CN 114979289 A 2022.08.30 CN 114979289 A 1.一种数据分发方法， 其特 征在于， 包括： 响应于预设服 务实例的启动指令， 启动全量数据获取线程； 通过所述全量数据获取线程确定至少一第 一数据存储端， 从确定出的至少一所述第 一 数据存储端获取并存 储全量数据； 所述第一数据存 储端存储有全量数据； 基于所述预设服务实例启动增量数据获取线程， 通过所述增量数据获取线程从第 二数 据存储端获取并存 储增量数据； 所述第二数据存 储端包括数据分发服 务端； 响应于数据获取请求， 将所述全量数据与 所述增量数据分发至所述数据获取请求对应 的用户端。 2.根据权利要求1所述的方法， 其特征在于， 所述通过所述全量数据获取线程确定至少 一第一数据存 储端， 包括： 确定所有已启动的数据存 储端， 向各 所述数据存 储端发送全量数据获取请求； 接收至少一所述数据存储端基于所述全量数据获取请求返回的响应报文， 将返回所述 响应报文的每一所述数据存 储端确定为所述第一数据存 储端。 3.根据权利要求1所述的方法， 其特征在于， 所述从确定出的至少一所述第 一数据存储 端获取并存 储全量数据， 包括： 根据接收到的响应报文的数量确定所述第一数据存 储端的数量； 根据所述第 一数据存储端的数量确定对应的数据获取方式， 基于与 所述第一数据存储 端的数量对应的数据获取方式， 从发送过所述响应报文的第一数据存储端获取所述全量数 据； 将所述全量数据存 储至本地数据表。 4.根据权利要求3所述的方法， 其特征在于， 所述基于与 所述第一数据存储端的数量对 应的数据获取 方式， 从发送过 所述响应报文的第一数据存 储端获取 所述全量数据， 包括： 当所述第一数据存储端的数量为一个时， 从确定出的所述第 一数据存储端集中获取所 述全量数据； 当所述第一数据存储端的数量为多个时， 从确定出的多个所述第 一数据存储端中选取 一目标全量存 储端； 从所述目标全量存储端中获取所述全量数据对应的关键字集合； 所述关键字集合包含 所述全量数据的所有关键 字； 根据所述关键 字集合从多个所述第一数据存 储端中获取 所述全量数据。 5.根据权利要求1所述的方法， 其特征在于， 所述通过所述增量数据获取线程从第 二数 据存储端获取并存 储增量数据， 包括： 获取所述预设服 务实例对应的数据消费树； 基于所述数据消费树并通过所述增量数据获取线程， 从所述第 二数据存储端获取所述 增量数据； 将所述增量数据存 储至本地数据表。 6.一种数据分发装置， 其特 征在于， 包括： 全量线程启动模块， 用于响应于预设服 务实例的启动指令， 启动全量数据获取线程； 全量数据获取模块， 用于通过所述全量数据获取线程确定至少一第一数据存储端， 从 确定出的至少一所述第一数据存储端获取并存储全量数据； 所述第一数据存储端存储有全权　利　要　求　书 1/2 页 2 CN 114979289 A 2量数据； 增量数据获取模块， 用于基于所述预设服务实例启动增量数据获取线程， 通过所述增 量数据获取线程从第二数据存储端获取并存储增量数据； 所述第二数据存储端包括数据分 发服务端； 数据分发模块， 用于响应于数据获取请求， 将所述全量数据与所述增量数据分发至所 述数据获取请求对应的用户端。 7.一种数据分发系统， 其特 征在于， 包括： 数据分发服 务端， 用于存 储和分发任务 运行过程中产生的全量数据与增量数据； 数据消费端， 用于启动全量数据获取线程， 基于所述全量数据获取线程从第一数据存 储端获取全量数据； 启动增 量数据获取线程， 基于所述增 量数据获取线程从所述数据分发 服务端获取增量数据； 将所述全量数据与所述增量数据分发至数据获取请求对应的用户 端； 第一数据存储端， 用于采用预设格式存储全量数据， 接收所述数据存储端的全量数据 获取请求， 并基于所述全量数据获取请求向数据存 储端发送响应报文。 8.一种电子设备， 其特 征在于， 包括： 处理器； 用于存储所述处 理器可执行指令的存 储器； 其中， 所述处理器被配置为执行所述指令， 以实现如权利要求1至5中任一项所述的数 据分发方法。 9.一种计算机可读存储介质， 当所述计算机可读存储介质中的指令由电子设备的处理 器执行时， 使得电子设备能够执 行如权利要求1至 5中任一项所述的数据分发方法。 10.一种计算机程序产品， 包括计算机程序/指令， 其特征在于， 所述计算机程序/指令 被处理器执行时实现权利要求1 ‑5任一项所述的数据分发方法。权　利　要　求　书 2/2 页 3 CN 114979289 A 3