按需将 Neo4J 加载到内存中以进行繁重的计算

Question

如何按需将 Neo4J 加载到内存中？

在我长期运行的工作的不同阶段，我将节点和关系与 Neo4J 保持一致。所以 Neo4J 应该在磁盘上，因为它可能会消耗太多的内存，而且我不知道我什么时候会对它运行读取查询。

但在某些时候（仅一次）我会想对我的 Neo4J 服务器运行非常繁重的读取查询，它的性能非常差（小时）。作为一种解决方案，我想将所有 Neo4J 加载到 RAM 以获得更好的性能。

什么是最好的选择？我应该使用运行盘还是有更好的解决方案？

附言

使用[r:LINK_REL_1*2] 查询工作得很快，[r:LINK_REL_1*3] 工作 17 秒，[r:LINK_REL_1*4] 工作超过 5 分钟，甚至不知道多少，因为我有 5 分钟超时。但我需要[r:LINK_REL_1*2..4] 查询才能在合理的时间内执行。

我的繁重查询说明

PROFILE
MATCH path = (start:COLUMN)-[r:LINK_REL_1*2]->(col:COLUMN) 
WHERE start.ENTITY_ID = '385' 
WITH path UNWIND NODES(path) AS col
WITH path, 
COLLECT(DISTINCT col.DATABASE_ID) as distinctDBs
WHERE LENGTH(path) + 1 = SIZE(distinctDBs)
RETURN path

更新了带有解释的查询（在测试中获得了相同的性能）

PROFILE
MATCH (start:COLUMN)
WHERE start.ENTITY_ID = '385' 
MATCH path = (start)-[r:LINK_REL_1*2]->(col:COLUMN)
WITH path, REDUCE(dbs = [], col IN NODES(path) | 
  CASE WHEN col.DATABASE_ID in dbs 
       THEN dbs 
       ELSE dbs + col.DATABASE_ID END) as distinctDbs
WHERE LENGTH(path) + 1 = SIZE(distinctDbs)
RETURN path

Answer 1

APOC 程序有apoc.warmup.run()，它可能会将大部分 Neo4j 放入缓存中。看看这是否会有所作为。

Answer 2

您似乎正在尝试创建一个查询，其中路径仅包含 :Persons from distinct countries。是这样吗？

如果是这样，我认为我们可以找到一个更好的查询，无需挂起即可执行此操作。

首先，让我们尝试一下容易实现的目标，看看避免 UNWIND 是否能有所作为。

PROFILE 或 EXPLAIN 查询，看看是否有任何数字与原始查询相比有显着差异。

MATCH (start:PERSON)
WHERE start.ID = '385' 
MATCH path = (start)-[r:FRIENDSHIP_REL*2..5]->(person:PERSON)
WITH path, REDUCE(countries = [], person IN NODES(path) | 
  CASE WHEN person.country in countries 
       THEN countries 
       ELSE countries + person.COUNTRY_ID END) as distinctCountries
WHERE LENGTH(path) + 1 = SIZE(distinctCountries)
RETURN path