py2neo调用gds.alpha.allShortestPaths.stream出现IndexError索引越界错误

这个IndexError和Cypher逻辑本身无关，是py2neo默认的Bolt连接超时阈值低于你查询的执行时长导致的：

• 你的无向全最短路径查询在当前业务图上执行需要80秒，而py2neo默认的连接读取超时为60秒，超时后底层连接被强制断开，返回空的二进制消息包，py2neo解析空包时就触发了索引越界。
• 有向查询、小规模图场景下执行时间短于60秒，不会触发断连；Neo4j浏览器本身超时阈值更高，所以可以正常拿到结果。

1. 延长py2neo的连接超时配置 #

初始化Graph实例时显式指定超时参数，将阈值调整到大于查询耗时的数值，比如设置为120秒：

from py2neo import Graph
graph = Graph("你的Neo4j连接地址", auth=("用户名", "密码"),
              max_connection_lifetime=120,
              recv_timeout=120)

2. 先创建GDS命名图投影再执行算法 #

你当前用的是匿名图投影，每次查询都要先加载图数据，会额外增加耗时。先显式创建GDS命名图再跑算法可以缩短执行时长，同时直接指定关系为无向属性，比自定义无向relationshipQuery效率更高：

# 第一步：创建命名图投影，直接指定COAUTHORS关系为无向
create_graph_cypher = """
CALL gds.graph.project(
    'coauthor-graph',
    'AUTHOR',
    {COAUTHORS: {orientation: 'UNDIRECTED'}}
)
"""
graph.run(create_graph_cypher)

# 第二步：基于命名图执行全最短路径算法
query_cypher = """
CALL gds.alpha.allShortestPaths.stream('coauthor-graph')
YIELD sourceNodeId, targetNodeId, distance
RETURN sourceNodeId, targetNodeId, distance
"""
r = graph.run(query_cypher)

3. 改用Neo4j官方Python驱动 #

如果py2neo的超时配置仍不生效，可以替换为Neo4j官方Python驱动，超时配置更灵活：

from neo4j import GraphDatabase
# 初始化驱动配置超时
driver = GraphDatabase.driver("bolt://你的实例地址:7687", auth=("用户名", "密码"),
                              connection_acquisition_timeout=120,
                              max_connection_lifetime=120)
# 执行查询
with driver.session() as session:
    result = session.run(query_cypher)
    for record in result:
        # 自行处理结果
        pass

内容的提问来源于stack exchange，提问作者L.Stefan