计算密集型Cypher查询的扩展

Question

作为我之前问题的后续，我想找到深度为4的两个给定节点之间存在的所有30条路径。效果如下：

start startnode = node(1), endnode(1000)
match startnode-[r:rel_Type*1..4]->endnode
return r
limit 30;

我的数据库包含大约5万个节点和2万个关系。

不出所料，这个查询的计算时间非常大；我甚至在message.log文件中得到了以下GC消息：GC Monitor: Application threads blocked for an additional 14813ms [total block time: 182.589s]。此错误不断发生，并在不确定的时间段内阻塞所有线程。因此，我正在寻找一种方法，通过优化查询来降低服务器上该查询的计算压力。

我可以使用任何扩展来帮助优化此查询吗

Answer 1

试试这个：

https://github.com/wfreeman/findpaths

您可以这样查询扩展：

/findpathslen/1/1000/4/30

它将为您提供一个json响应，其中包含找到的路径。希望这对你有所帮助。

它的核心就在这里，使用内置的图形算法来找到一定长度的路径：

@GET
@Path("/findpathslen/{id1}/{id2}/{len}/{count}")
@Produces(Array("application/json"))
def fof(@PathParam("id1") id1:Long, @PathParam("id2") id2:Long, @PathParam("len") len:Int, @PathParam("count") count:Int, @Context db:GraphDatabaseService) = {
  val node1 = db.getNodeById(id1)
  val node2 = db.getNodeById(id2)
  val pathFinder = GraphAlgoFactory.pathsWithLength(Traversal.pathExpanderForAllTypes(Direction.OUTGOING), len) 
  val pathIterator = pathFinder.findAllPaths(node1,node2).asScala
  val jsonMap = pathIterator.take(count).map(p => obj(p))
  Response.ok(compact(render(decompose(jsonMap))), MediaType.APPLICATION_JSON).build()
}