(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211070242.9 (22)申请日 2022.09.02 (71)申请人 支付宝 （杭州） 信息技 术有限公司 地址 310000 浙江省杭州市西湖区西溪路 556号8层B段801-1 1 (72)发明人 唐坤　易鹏　 (74)专利代理 机构 成都七星天知识产权代理有 限公司 5125 3 专利代理师 袁春晓 (51)Int.Cl. G06F 16/27(2019.01) G06F 16/901(2019.01) (54)发明名称 一种流转图存储及计算方法和系统 (57)摘要 本说明书涉及数字信息领域， 特别涉及一种 流转图存储及计算方法和系统。 其中流转图包括 节点与边， 该方法包括与一个或多个时间周期分 别对应的一轮或多轮处理， 其中一轮处理包括： 基于当前时间周期内新增的流转信息获取当前 子图的图数据分片并存储， 进而与其他计算单元 协同实现对当前子图的分布式存储； 在当前子图 的图数据分片中： 针对某一节点， 从该节点入边 上的源节点获取所述入边对应数据的流转消息 并存储， 所述流转消息包括数据的来源链路。 权利要求书2页 说明书9页 附图4页 CN 115408471 A 2022.11.29 CN 115408471 A 1.一种流转图存储及计算方法， 所述流转图包括节点与边， 其中节点间具有数据流转， 边用于表示数据在节点间的流转方向； 该方法由多个用于 分布式存储所述流转图的计算单 元中的某一个计算单元执行， 其包括与一个或多个时间周期分别对应的一轮或多轮处理， 其中一轮处 理包括： 基于当前时间周期内新增的流转信 息获取当前子图的图数据分片并存储， 进而与其他 计算单元协同实现对当前子图的分布式存 储； 在当前子 图的图数据分片中： 针对某一节点， 从该节点入边上的源节点获取所述入边 对应数据的流 转消息并存 储， 所述流转消息包括数据的来源链路。 2.如权利要求1所述的方法， 还 包括： 在当前子图的图数据分片中： 针对某一节点， 基于该节点出边更新该节点的流转消息， 所述更新进一步包括修改该节点中一条或多 条流转消息对应的数据， 或者删除该节点中的 一条或多条流 转消息。 3.如权利要求2所述的方法， 所述修改该节点中一条或多条流转消息对应的数据， 包 括： 减少该节点中一条或多条流 转消息对应的数据的数额。 4.如权利要求1所述的方法， 还 包括： 在当前子 图的图数据分片中： 针对某一节点， 基于该节点出边生成所述出边对应数据 的流转消息以便所述出边上目的节点获取。 5.如权利要求1所述的方法， 图数据分片包括当前子 图的部分节点以及所述部分节点 的边； 所述基于当前时间周期内的流 转信息获取当前子图的图数据分片并存 储， 包括： 当当前时间周期为首个时间周期时， 基于预设分配策略获得当前子图的图数据分片并 存储； 当当前时间周期不为首个时间周期时， 将当前子图中所述某一个计算单元已存储的节 点的边包含在所述当前子图的图数据分片中； 基于所述预设分片策略确定是否将当前子图 中未被任一计算单 元存储过的节点及其 边包含在所述当前子图的图数据分片中。 6.如权利要求1所述的方法， 边的属性信 息包括数据流转的时间； 所述数据包括资金数 据， 所述节点对应用于存 储资金的账户。 7.一种流转图存储及计算系统， 所述流转图包括节点与边， 其中节点间具有数据流转， 边用于表示数据在节点间的流转方向； 该系统部署于多个用于 分布式存储 所述流转图的计 算单元中的某一个计算单元内， 以执行与一个或多个时间周期分别对应的一轮或多轮处 理； 其包括： 图存储模块， 用于在一轮处理中基于当前时间周期内新增的流转信 息获取当前子图的 图数据分片并存 储， 进而与其他计算单 元协同实现对当前子图的分布式存 储； 图计算模块， 用于在一轮处理中在 当前子图的图数据分片中： 针对某一节点， 从该节点 入边上的源节点 获取所述入边对应数据的流转消息并存储， 所述流转消息包括数据的来源 链路。 8.如权利要求7 所述的系统， 所述图计算模块在一轮处 理中还用于： 在当前子图的图数据分片中： 针对某一节点， 基于该节点出边更新该节点的流转消息， 所述更新进一步包括修改该节点中一条或多 条流转消息对应的数据， 或者删除该节点中的 一条或多条流 转消息。权　利　要　求　书 1/2 页 2 CN 115408471 A 29.如权利要求7所述的系统， 图数据分片包括当前子 图的部分节点以及所述部分节点 的边； 所述图存 储模块在一轮处 理中还用于： 当当前时间周期为首个时间周期时， 基于预设分配策略获得当前子图的图数据分片并 存储； 当当前时间周期不为首个时间周期时， 将当前子图中所述某一个计算单元已存储的节 点的边包含在所述当前子图的图数据分片中； 基于所述预设分片策略确定是否将当前子图 中未被任一计算单 元存储过的节点及其 边包含在所述当前子图的图数据分片中。 10.一种流转图存储及计算装置， 包括处理器， 所述处理器用于执行权利要求1～6 中任 一项所述的流 转图存储及计算方法。权　利　要　求　书 2/2 页 3 CN 115408471 A 3