(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210370949.5 (22)申请日 2022.04.11 (71)申请人 支付宝 （杭州） 信息技 术有限公司 地址 310023 浙江省杭州市西湖区西溪路 556号8层B段801-1 1 (72)发明人 唐坤　易鹏　 (74)专利代理 机构 上海专利商标事务所有限公 司 31100 专利代理师 段登新 (51)Int.Cl. G06Q 40/02(2012.01) G06F 3/06(2006.01) G06F 9/50(2006.01) (54)发明名称 用于处理数据的方法、 系统、 装置和介质 (57)摘要 公开了一种处理数据的方法。 该方法包括获 取最新周 期的新增数据， 生成增量图， 将该增量 图划分到多个计算节点 以生成最新版本的部分 增量图， 从持久存储加载先前版本的部分增量图 并对最新版本和先前版本的部分增量图执行处 理。 还公开了处理资金流转数据的方法、 相应的 系统、 装置和介质。 权利要求书2页 说明书14页 附图6页 CN 114493856 A 2022.05.13 CN 114493856 A 1.一种处 理数据的方法， 包括： 获取最新周期的增量数据； 基于所述增量数据生成最 新版本的增量图； 将所述增量图划分到多个计算节点， 其中所述多个计算节点的每个计算节点的内存中 存储所述增量图的一部分， 以生成最 新版本的部分增量图； 从相应计算节点的持久存储读取多个先前版本的部分增量图， 所述最新版本和所述多 个先前版本共同构成活跃 版本； 以及 在相应计算节点处使用图策略算法对所述活跃 版本执行处理。 2.如权利要求1所述的方法， 其中将所述增量图划分到多个计算节点包括采用邻居表 的方式将所述增量图划分到所述多个 计算节点的内存中。 3.如权利要求1所述的方法， 其中从相应计算节点的持久存储读取多个先前版本的部 分增量图包括采用延迟载入的方式执 行所述读取。 4.如权利要求1所述的方法， 其中使用图策略算法对所述活跃版本执行处理包括执行 所述活跃 版本中的时序路径的新增、 删除和更新中的一 者或多者。 5.如权利要求1所述的方法， 其中使用图策略算法对所述活跃版本执行处理包括采用 基于顶点编程的遍历算法对所述 最新版本的部分增量图中的顶点执 行遍历。 6.如权利要求5所述的方法， 进一 步包括： 对被遍历到的每 个顶点： 获取该顶点的时间有序出边 集合； 以及 依次遍历所述 时间有序 出边集合中的每条出边， 并对该遍历到的出边调用图策略算法 来执行处理。 7.如权利要求6所述的方法， 其中对所述活跃 版本中的顶点执 行遍历包括： 判断是否满足 终止条件， 且在满足 终止条件时停止遍历。 8.如权利要求1所述的方法， 进一 步包括： 将经处理的所述活跃 版本存储到所述持久存 储。 9.如权利要求1所述的方法， 进一 步包括： 以先进先 出的次序， 按滑动窗口方式将所述 最新版本更新到所述持久存 储。 10.如权利要求1所述的方法， 进一 步包括： 使用KKV存储引擎来在所述持久存储中执行存储， 其中在所述KKV存储引擎中第一主键 K1为顶点 ID， 第二主键K2为版本， 值V为路径数据。 11.一种用于处 理资金流 转数据的方法， 包括： 接收最新周期的资金流转数据， 所述资金流转数据包括多个资金池实体以及所述多个 资金池实体之间的资金流 转关系； 基于所述资金流 转数据生成最 新版本的增量图； 将所述增量图划分到多个计算节点， 其中所述多个计算节点的每个计算节点的内存中 存储所述增量图的一部分， 以生成最 新版本的部分增量图； 从相应计算节点的持久存储读取多个先前版本的部分增量图， 所述最新版本和所述多 个先前版本共同构成活跃 版本； 以及 在相应计算节点处使用图策略算法对所述活跃 版本执行处理。权　利　要　求　书 1/2 页 2 CN 114493856 A 212.如权利要求11所述的方法， 其中将所述增量图划分到多个计算节点包括采用邻居 表的方式将所述增量图划分到所述多个 计算节点的内存中。 13.如权利要求11所述的方法， 其中从相应计算节点的持久存储读取多个先前版本的 部分增量图包括采用延迟载入的方式执 行所述读取。 14.如权利要求1 1所述的方法， 进一 步包括： 以先进先 出的次序， 按滑动窗口方式将所述 最新版本更新到所述持久存 储。 15.一种处 理数据的系统， 包括： 数据获取节点， 用于获取最 新周期的增量数据； 增量图生成节点， 用于： 基于所述增量数据生成最 新版本的增量图； 以及 将所述增量图划分到计算节点 集群中的多个 计算节点； 以及 所述计算节点 集群， 所述计算节点 集群中的每 个计算节点： 在内存中存 储所述增量图的一部分， 以生成最 新版本的部分增量图； 从其持久存储读取多个先前版本的部分增量图， 所述最新版本和所述多个先前版本共 同构成活跃 版本； 以及 使用图策略算法对所述活跃 版本执行处理。 16.如权利要求15所述的系统， 其中所述增量图生成节点采用邻居表的方式将所述增 量图划分到所述多个 计算节点的内存中。 17.如权利要求15所述的系统， 其中所述计算节点采用延迟载入的方式读取所述多个 先前版本的部分增量图。 18.如权利要求15所述的系统， 进一 步包括： 以先进先 出的次序， 按滑动窗口方式将所述 最新版本更新到所述持久存 储。 19.一种用于处 理数据的装置， 包括： 存储器； 以及 处理器， 所述处 理器被配置成执 行如权利要求1 ‑14中任一项所述的方法。 20.一种存储指令的计算机可读存储介质， 所述指令当被计算机执行时， 使所述计算机 执行如权利要求1 ‑14中任一项所述的方法。权　利　要　求　书 2/2 页 3 CN 114493856 A 3