Python脚本上传含函数的CSV至Neo4j创建关系失败求助

你的问题核心很清楚：当前的Cypher语句只是加载了CSV数据并返回行内容，完全没有创建关系的逻辑——这就是为什么没有任何关系被生成的原因。下面我会一步步给你可行的解决方案，包括批量Cypher处理和Python逐行处理两种方式。

一、先确认你的CSV结构 #

首先要保证CSV包含创建关系的关键信息，比如：

• 起始节点的唯一标识（比如start_node_id）
• 结束节点的唯一标识（比如end_node_id）
• 关系类型（可选，也可以在Cypher里固定死）
• 关系属性（比如rel_since，可选）

举个CSV示例：

start_node_id,end_node_id,rel_type,rel_since
1,2,FRIENDS_WITH,2020
3,1,WORKS_WITH,2018

二、批量Cypher创建关系（推荐） #

用LOAD CSV配合MATCH定位节点，再用MERGE或CREATE生成关系：

• MERGE：避免重复创建同一对节点的同类型关系（适合需要去重的场景）
• CREATE：不管是否存在，都会生成新关系（适合允许重复关系的场景）

Python中执行批量Cypher的代码 #

from neo4j import GraphDatabase

# 初始化Neo4j驱动
driver = GraphDatabase.driver("bolt://localhost:7687", auth=("neo4j", "你的密码"))

with driver.session() as session:
    # 替换成你的节点标签、匹配属性、关系类型和属性
    result = session.run("""
        LOAD CSV WITH HEADERS FROM 'file:///New_Relationships.csv' AS row
        MATCH (a:Person {id: toInteger(row.start_node_id)})  # 注意类型转换，若ID是数字需转成整数
        MATCH (b:Person {id: toInteger(row.end_node_id)})
        MERGE (a)-[r:${rel_type} {since: row.rel_since}]->(b)  # 关系类型可固定或从CSV读取
        RETURN count(r) AS created_relationships
    """, rel_type="FRIENDS_WITH")  # 若关系类型固定，可直接写在Cypher里，去掉参数

    # 获取创建的关系数量
    summary = result.consume()
    print(f"成功创建 {summary.counters.relationships_created} 条关系")

driver.close()

三、Python逐行读取CSV创建关系 #

如果你之前尝试逐行处理但失败，大概率是参数传递或节点匹配出了问题。下面是完整的逐行处理代码：

import csv
from neo4j import GraphDatabase

driver = GraphDatabase.driver("bolt://localhost:7687", auth=("neo4j", "你的密码"))

with driver.session() as session:
    # 读取本地CSV（无需放到Neo4j的import目录）
    with open("New_Relationships.csv", "r", encoding="utf-8") as csv_file:
        reader = csv.DictReader(csv_file)
        for row in reader:
            # 转换数据类型（比如把字符串ID转成整数）
            start_id = int(row["start_node_id"])
            end_id = int(row["end_node_id"])
            rel_since = row["rel_since"]
            
            # 执行Cypher创建关系
            session.run("""
                MATCH (a:Person {id: $start_id})
                MATCH (b:Person {id: $end_id})
                MERGE (a)-[r:FRIENDS_WITH {since: $rel_since}]->(b)
            """, start_id=start_id, end_id=end_id, rel_since=rel_since)

print("关系创建完成")
driver.close()

四、关键注意事项 #

• CSV文件位置：如果用LOAD CSV的file:///路径，需要把CSV放到Neo4j的import目录；或者修改Neo4j配置文件，允许加载外部路径的文件。
• 节点匹配准确性：必须用节点的唯一标识（比如主键ID）来匹配，否则可能匹配到错误节点，或者找不到节点导致关系创建失败。
• 大文件优化：如果CSV数据量很大（比如上万行），推荐用APOC的apoc.periodic.iterate批量处理，避免内存溢出：

  CALL apoc.periodic.iterate(
    "LOAD CSV WITH HEADERS FROM 'file:///New_Relationships.csv' AS row RETURN row",
    "MATCH (a:Person {id: toInteger(row.start_node_id)}) MATCH (b:Person {id: toInteger(row.end_node_id)}) MERGE (a)-[r:FRIENDS_WITH {since: row.rel_since}]->(b)",
    {batchSize: 1000, iterateList: true}
  )
  

• 类型转换：如果节点ID是数字类型，一定要用toInteger()把CSV里的字符串转成整数，否则会匹配失败。

内容的提问来源于stack exchange，提问作者TeeKay