子图抽取方法和装置.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN114139022A(43)申请公布日2022.03.04(21)申请号202210114037.1(22)申请日2022.01.30(71)申请人支付宝（杭州）信息技术有限公司地址310000浙江省杭州市西湖区西溪路556号8层B段801-11(72)发明人周强潘臻轩(74)专利代理机构北京亿腾知识产权代理事务所(普通合伙)11309代理人孙欣欣周良玉(51)Int.Cl.G06F16/901(2019.01)G06F9/50(2006.01)权利要求书2页说明书7页附图4页(54)发明名称子图抽取方法和装置(57)摘要本说明书实施例提供一种子图抽取方法和装置，方法包括：从指定数据源，获取当前时间周期相对于上一时间周期的增量数据；根据所述增量数据，得到关系网络图的增量图数据，其中包括若干新增节点；以各新增节点为根节点，对所述关系网络图执行子图抽取任务；在所述子图抽取任务执行过程中，一旦检测到子节点数目达到预设阈值的目标节点，根据该目标节点的子节点数目分配目标计算资源，利用所述目标计算资源执行以该目标节点为起点的子抽取任务。能够满足对计算规模和实时性两方面的需求。CN114139022ACN114139022A权利要求书1/2页1.一种子图抽取方法，所述方法包括：从指定数据源，获取当前时间周期相对于上一时间周期的增量数据；根据所述增量数据，得到关系网络图的增量图数据，其中包括若干新增节点；以各新增节点为根节点，对所述关系网络图执行子图抽取任务；在所述子图抽取任务执行过程中，一旦检测到子节点数目达到预设阈值的目标节点，根据该目标节点的子节点数目分配目标计算资源，利用所述目标计算资源执行以该目标节点为起点的子抽取任务。2.如权利要求1所述的方法，其中，所述关系网络图包括节点和连接边，所述增量图数据还包括新增连接边、新增节点属性信息、新增边属性信息中的一项或多项。3.如权利要求1所述的方法，其中，所述以各新增节点为根节点，对所述关系网络图执行子图抽取任务，包括：从所述各新增节点中选择满足预设条件的第一新增节点作为根节点；根据该根节点的子节点数目分配初始计算资源，利用所述初始计算资源对所述关系网络图执行以该根节点为起点的子图抽取任务。4.如权利要求3所述的方法，其中，所述子图抽取任务用于从所述关系网络图中的根节点出发逐层抽取子节点构建子图；所述初始计算资源为与所述根节点的直接相连的子节点数目相关数目的并发资源。5.如权利要求4所述的方法，其中，所述目标计算资源为与该目标节点的直接相连的子节点数目相关数目的并发资源。6.如权利要求1所述的方法，其中，所述方法还包括：调用actor方法远程提交异步请求，所述异步请求用于请求执行所述子图抽取任务或所述子抽取任务；接收返回的Object，根据Object获取所述子图抽取任务或所述子抽取任务的执行结果。7.如权利要求1所述的方法，其中，所述子图抽取任务抽取的子图的度至少为2。8.如权利要求1所述的方法，其中，所述子图抽取任务基于所述增量图数据和历史图数据而执行；所述方法还包括：根据所述增量图数据，更新所述历史图数据。9.如权利要求1所述的方法，其中，所述关系网络图为有向无环图。10.如权利要求1所述的方法，其中，所述子图抽取任务包括多轮迭代运算，所述子抽取任务在多轮迭代运算的任一轮迭代运算中触发。11.一种子图抽取装置，所述装置包括：获取单元，用于从指定数据源，获取当前时间周期相对于上一时间周期的增量数据；时序计算单元，用于根据所述获取单元获取的增量数据，得到关系网络图的增量图数据，其中包括若干新增节点；子图抽取单元，用于以所述时序计算单元得到的各新增节点为根节点，对所述关系网络图执行子图抽取任务；在所述子图抽取任务执行过程中，一旦检测到子节点数目达到预设阈值的目标节点，根据该目标节点的子节点数目分配目标计算资源，利用所述目标计算资源执行以该目标节点为起点的子抽取任务。2CN114139022A权利要求书2/2页12.如权利要求11所述的装置，其中，所述关系网络图包括节点和连接边，所述增量图数据还包括新增连接边、新增节点属性信息、新增边属性信息中的一项或多项。13.如权利要求11所述的装置，其中，所述子图抽取单元包括：选择子单元，用于从所述各新增节点中选择满足预设条件的第一新增节点作为根节点；资源分配子单元，用于根据该选择子单元选择的根节点的子节点数目分配初始计算资源，利用所述初始计算资源对所述关系网络图执行以该根节点为起点的子图抽取任务。14.如权利要求13所述的装置，其中，所述子图抽取任务用于从所述关系网络图中的根节点出发逐层抽取子节点构建子图；所述初始计算资源为与所述根节点的直接相连的子节点数目相关数目的并发资源