Neo4j "Can't wait on resource" 锁定错误

Neo4j "Can't wait on resource" lock error

我正在使用 Node.js 连接到托管的 GrapheneDB Neo4j 数据库,在尝试添加大约 1,500 条记录时出现以下错误:

LockClient[19] can't wait on resource 
RWLock[NODE(248), hash=1917331445] since => LockClient[19] 
<-[:HELD_BY]- RWLock[INDEX_ENTRY(153122458561043471), hash=1171319680] 
<-[:WAITING_FOR]- LockClient[15] <-[:HELD_BY]- RWLock[NODE(248), hash=1917331445]

生成此代码的代码来自一个路由,该路由获取一个 JSON 对象列表,然后将它们存储在 Neo4j 中。当导入大约 1,500 条记录时,我一直收到此错误。

使用 seraph-model 进行数据库访问并查找记录,如果存在则更新,如果不存在则创建它。

有什么调查建议吗?

看起来您正在同时进行多个大型交易,并触及图表的同一区域。

当 Neo4j 执行写操作时,会在 node/relationship 上获取一个写锁,并在事务关闭时释放。其他试图在已锁定实体上获取写锁的并发事务 运行ning 需要等待 - 否则潘多拉的不一致盒子就会打开。如果锁的所有者是一个相当长的 运行ning 事务,另一个可能 运行 超时 - 这就是上面的错误消息。

因此您可以:

  1. 序列化操作:不要并行写入,而是确保在给定时间只处理一个胖事务
  2. 让事务更小:如果你在单个事务中做的更少,持续时间会更短,其他等待锁的事务也不会超时。

我也遇到过这种情况。我读过的建议解决方法是:

  • 将平行的作品连载(但你失去了平行的好处)
  • 使用某种顺序列出写入查询中的节点,例如对 ID 进行排序(但它会增加写入线程的排序开销)

我决定采用第三种选择:重新尝试 Cypher 操作,直到一切顺利,或者达到最大次数。次,在尝试之间暂停一段随机时间。我的 utility 可以提供帮助。对于 Neo4 驱动程序,org.neo4j.driver.v1.exceptions.TransientException 是您要传递给构造函数的异常。