neo4j-spark-skill
便于构建并行化的大规模图数据接入与导出管道,适合数据工程场景。
需要在集群中安装 connector 并有对 Neo4j 的网络/写入权限。
使用 Neo4j Connector 在 Spark/Databricks 与 Neo4j 之间高效读写数据。
在 Spark/Databricks 和 Neo4j 之间高效搬数据:把 Neo4j 的 nodes/relationships 读成 DataFrame,或把 DataFrame 写回 Neo4j。适合做大图并行读取、Delta Lake → Neo4j 的数据管道,或在 Databricks 上运行 PySpark/Scala 时接入数据库。重点是教你怎么配置 SparkSession、按 label/Cypher/relationship scan 读数据、用 SaveMode 和 node.keys 做 MERGE、以及做 partition/batch 调优和凭据管理。
▸ 展开 SKILL.md 英文原文
Use when reading from or writing to Neo4j with Apache Spark or Databricks using the Neo4j Connector for Apache Spark (org.neo4j:neo4j-connector-apache-spark). Covers SparkSession setup, DataFrame reads via labels/Cypher/relationship scan, DataFrame writes with SaveMode, node.keys for MERGE, relationship write mapping, partition and batch tuning, PySpark and Scala examples, Databricks cluster config, Databricks secrets for credentials, Delta Lake to Neo4j pipelines. Does NOT handle Cypher authoring — use neo4j-cypher-skill. Does NOT handle the Python bolt driver — use neo4j-driver-python-skill. Does NOT handle GDS algorithms — use neo4j-gds-skill.
帮我安装这个 skill:https://raw.githubusercontent.com/neo4j-contrib/neo4j-skills/main/neo4j-spark-skill/SKILL.mdcurl -fsSL "https://raw.githubusercontent.com/neo4j-contrib/neo4j-skills/main/neo4j-spark-skill/SKILL.md"# Neo4j Connector for Apache Spark ## When to Use - Reading Neo4j nodes/relationships into Spark DataFrames - Writing Spark DataFrames to Neo4j as nodes or relationships - Databricks notebooks connecting to Neo4j - Delta Lake → Neo4j ingestion pipelines - Partitioned parallel reads from large Neo4j graphs ## When NOT to Use - **Python bolt driver / execute_query** → `neo4j-driver-python-skill` - **Cypher query writing** → `neo4j-cypher-skill` - **GDS graph algorithms** → `neo4j-gds-skill` - **Spring Boot + Neo4j** → `neo4j-spring-data-skill` --- ## Version Matrix | Connector | Spark | Scala | Databricks Runtime | Neo4j | |-----------|-------|-------|--------------------|-------| | 5.4