Nebula Exchange 使用

huangsong2888 · 2022 年3 月 15 日 10:20

这是指我的这个neo4j数据库名配置错了么

你们是根据neo4j在哪找的database

steam · 2022 年3 月 15 日 10:22

你是按照文档来操作的吗，在此之前你创建 schema 了吗？

huangsong2888 · 2022 年3 月 16 日 00:59

是的，nebula那边只差数据了

huangsong2888 · 2022 年3 月 16 日 01:08

为了方便测试，neo4j_application.conf只配了spark、nebula和一个tags

huangsong2888 · 2022 年3 月 16 日 01:16

neo4j那边数据

nebula这边

steam · 2022 年3 月 16 日 02:15

id 映射不对啊，这里应该填写 id 的，，你对着这个文档 https://docs.nebula-graph.com.cn/3.0.1/nebula-exchange/use-exchange/ex-ug-import-from-neo4j/ 来，把定制化的参数改成自己的就好了顺便，人家马赛克一般都是马赛克 ip 的，端口漏出来的

huangsong2888 · 2022 年3 月 16 日 03:01

不得行，还是一直报这个错。
Caused by: org.neo4j.driver.exceptions.ClientException: Database name parameter for selecting database is not supported in Bolt Protocol Version 3. Database name: ‘neo4j’

steam · 2022 年3 月 16 日 03:06

哥，不要自由发挥，按照文档的格式传参好不好，你看文档示例是咋写的。

huangsong2888 · 2022 年3 月 16 日 03:15

不是这个得原因，文档得那种执行不了的，我这边可没有id属性，获取id得id(n)。

steam · 2022 年3 月 16 日 03:17

你没有指定的一个列做 vid？

huangsong2888 · 2022 年3 月 16 日 03:39

neo4j自有id可以用得，这个执行报错我看论坛隔壁帖子像是不兼容
Exception in thread “main” org.apache.spark.SparkException: Job aborted due to stage failure: Task 0 in stage 0.0 failed 1 times, most recent failure: Lost task 0.0 in stage 0.0 (TID 0, localhost, executor driver): org.neo4j.driver.exceptions.ClientException: Database name parameter for selecting database is not supported in Bolt Protocol Version 3. Database name: ‘graph.db’

但是nebula要求版本和我的版本
https://discuss-cdn.nebula-graph.com.cn/uploads/default/original/2X/6/690d0025cb6d864c251b10cb239d465ffe183d8d.png
我自己用的是这个
E:\neo4j-community-3.5.28\conf

darionyaphet · 2022 年3 月 16 日 08:03

看上去可能是neo4J connector的版本不匹配的问题

huangsong2888 · 2022 年3 月 16 日 08:08

是说的这个么，我安装了这个版本还是这个错

huangsong2888 · 2022 年3 月 16 日 08:11

以及neo4j这边才用的默认数据库，没啥改动的话database:这个是graph.db还是neo4j呢

darionyaphet · 2022 年3 月 16 日 08:13

看下 nebula exchange 的neo4J 版本吧

huangsong2888 · 2022 年3 月 16 日 08:14

版本是正确的嘞

darionyaphet · 2022 年3 月 16 日 08:20

neo4J 版本好像是 2.4.5-M1的

github.com

vesoft-inc/nebula-exchange/blob/v2.6/nebula-exchange/pom.xml#L33

    
      
              <spark.version>2.4.4</spark.version>
              <spark-csv.version>1.5.0</spark-csv.version>
              <scalatest.version>3.2.0</scalatest.version>
              <rocksdb.version>6.7.3</rocksdb.version>
              <config.version>1.4.0</config.version>
              <scala-logging.version>3.9.2</scala-logging.version>
              <scala-xml.version>2.11.0-M4</scala-xml.version>
              <scopt.version>3.7.1</scopt.version>
              <nebula.version>2.6.2</nebula.version>
              <s2.version>1.0.0</s2.version>
              <neo.version>2.4.5-M1</neo.version>
              <gremlin.version>3.4.6</gremlin.version>
              <janusgraph.version>0.5.0</janusgraph.version>
              <pulsar.version>2.4.5</pulsar.version>
              <commons-codec.version>1.14</commons-codec.version>
              <hadoop.version>2.6.1</hadoop.version>
              <hbase.version>1.2.0</hbase.version>
          </properties>
          
          
<build>
              <testSourceDirectory>src/test</testSourceDirectory>

huangsong2888 · 2022 年3 月 16 日 08:28

我用的

要求的

我感觉可能是spark版本不对，我先试试。

darionyaphet · 2022 年3 月 16 日 08:29

但抛出异常的位置是 neo4j driver

huangsong2888 · 2022 年3 月 16 日 08:31

那你这个是对应的nebula2.5.0版本的么