Загрузить спарк-графу из сервиса dtabricks в neo4j db в облаке - PullRequest
0 голосов
/ 26 июня 2018

я использую сервис databricks через мою лазурную подписку. Я также развернул neo4j DB через Azure. я пытаюсь загрузить neo4j db из объекта graphframe, который я построил на платформе databricks.

Я скачал разъем spark - neo4j и попытался запустить следующий код:

   %scala
   import org.neo4j.spark._ 
   import org.graphframes._ 
   import org.graphframes.GraphFrame

%python
   import pandas as pd
   from pyspark.sql.types import *
   from pyspark.sql import SQLContext
   from graphframes import *

#### create graphframe
   vertex=[ ("a", "Alice", 34),
     ("b", "Bob", 36),
     ("c", "Charlie", 30)]
   labelsV=["id", "name", "age"]

   v=pd.DataFrame.from_records(vertex,columns=labelsV)

## Convert into Spark DataFrame
   vertex = spark.createDataFrame(v)


   Edges=[  ("a", "b", "friend"),
     ("b", "c", ""),
     ("c", "b", "follow")]
   labelsE=["src", "dst", "relationship"]
   e=pd.DataFrame.from_records(Edges,columns=labelsE)
## Convert into Spark DataFrame
   Edges = spark.createDataFrame(e)

1006 *

Я не понимаю, как настроить хост neo4j из сервиса databricks. я попробовал:

%scala
   dbms.connector.http.enabled=true
   dbms.connector.http.listen_address="<url>"

я получил следующую ошибку:

command-2039977334603380:47: error: not found: value dbms
val $ires14 = dbms.connector.http.enabled

что я делаю не так? Тпй

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...