如何从Spark编写GraphFrames到Neo4j

问题描述

我正在尝试将大量数据从Spark导出到neo4j数据库: 我有很多由该程序创建的GraphFrame,必须存储在Neo4j中,所以我必须为每个图形创建一个新的数据库,然后将数据直接从spark发送到Neo4j数据库。

我试图创建一个CSV文件并将其存储在NEO4J中,但它确实有效,但是就我而言,正如我提到的那样,我正在创建许多图形,这些图形随后必须导出到Neo4j,因此中间CSV文件是对我来说不是一个好的解决方案。

问题: 1-除了CSV解决方案之外,将大数据直接从Spark直接导出到Neo4J的最佳方法是什么? 2-是否有Github存储库或资源可以在其中找到解决此问题的方法?

我正在使用:Spark 2.4.6 / Scala 2.11.8

提前谢谢您(如果我的英语不是最好的话,我感到很抱歉)

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)

相关问答

错误1:Request method ‘DELETE‘ not supported 错误还原:...
错误1:启动docker镜像时报错:Error response from daemon:...
错误1:private field ‘xxx‘ is never assigned 按Alt...
报错如下,通过源不能下载,最后警告pip需升级版本 Requirem...