我使用海王星的图形数据库,通过python进行gremlin查询,将地址存储在数据库中。大多数查询执行良好,但一旦我尝试以下查询neptune将返回一个内部失败异常:
g.V(address).outE('isPartOf').inV().
dedup().as_('groupNode').
inE('isPartOf').outV().dedup().as_('children').
addE('isPartOf').to(group).
select('groupNode').drop().
fold().
coalesce(__.unfold(),
g.V(address).addE('isPartOf').to(group)).next()
每个地址都有可能属于一个组。当地址已经分配给一个组时,我会尝试将分配给该组的所有地址分配给新组,同时删除旧组。如果地址还没有分配给一个组,我只想立即将地址分配给新组。在
如果我自己尝试这个查询,一切都会完美地执行(尽管它有点慢)。但是,一旦我尝试在更多address上并行执行此查询,该查询将失败,并出现以下错误:
^{pr2}$据我所知,并行执行不应该是问题,因为每个查询都只是在数据库中排队(正是因为这个原因,我试图创建一个同时执行整个任务的查询)。在
任何糟糕英语的借口,它不是我的母语
对于任何其他在这里寻找更新的人来说,操作可以通过将.next()替换为.iterate()来解决问题。为了更好地理解查询和数据,需要进行一些后续工作,但是OP已经放弃了这个项目,转而使用另一个解决方案。在
相关问题 更多 >
编程相关推荐