При попытке загрузить данные с помощью DSE graphloader я получаю сообщение об ошибке DSE Graph не настроен для обработки запросов

Я использую DSE Graphloader для загрузки данных из CSV-файла в DSE Graph.

Я сделал следующие шаги для загрузки данных:

Создал график:

system.graph('followTopic').create()

Установите псевдоним:

:remote config alias g followTopic.g

Создайте следующую схему:

schema.propertyKey("id").Text().single().create()
schema.propertyKey("follower").Text().single().create()
schema.propertyKey("name").Text().single().create()
schema.propertyKey("type").Text().single().create()
schema.propertyKey("followed").Text().single().create()
schema.propertyKey("timestamp").Timestamp().single().create()
schema.vertexLabel("record").partitionKey("id").create()
schema.vertexLabel("user").properties("name").create()`

Файл сопоставлений:

// CONFIGURATION

// Configures the data loader to create the schema
config create_schema: false, load_new: true, load_threads: 3

// DATA INPUT
// Define the data input source (a file which can be specified via command    line arguments)
// inputfiledir is the directory for the input files

inputfiledir = '/home/adminuser/data/'
followTopic = File.csv(inputfiledir + "follow.csv").delimiter(',')

//Specifies what data source to load using which mapper (as defined inline)

load(followTopic).asVertices {
   label "record"
   key "id"
}

Я использовал следующий CSV-файл:

id,follower,followed,type,timestamp
1,@20cburns,topic_/best-friend,topic,5/7/2016 11:03:42 PM +00:00
2,@68,topic_/tears-fall,topic,5/3/2016 2:20:01 AM +00:00
3,@abba,topic_/best-friend,topic,6/15/2016 4:08:24 PM +00:00
…

Затем при запуске команды graphloader я получаю указанную ниже ошибку -

./graphloader ../followTopinMapping.groovy -filename ../follow.csv -graph followTopic -address localhost

Сообщение об ошибке исключения:

2016-08-22 14:18:00 ERROR DataLoaderImpl:519 - Graph driver attempts   exceeded for this operation, logging failure, but no records are present (may have been a schema operation)
com.datastax.dsegraphloader.exception.TemporaryException:      com.datastax.driver.core.exceptions.InvalidQueryException: DSE Graph not    configured to process queries
at    com.datastax.dsegraphloader.impl.loader.driver.DseGraphDriverImpl.executeGraphQuery(DseGraphDriverImpl.java:71)
at  com.datastax.dsegraphloader.impl.loader.driver.DseGraphDriverImpl.executeGraphQuery(DseGraphDriverImpl.java:87)
at com.datastax.dsegraphloader.impl.loader.driver.DseGraphDriverImpl.getSchema(DseGraphDriverImpl.java:128)
at com.datastax.dsegraphloader.impl.loader.driver.SafeGraphDriver.lambda$tryGetSchema$14(SafeGraphDriver.java:94)
at com.datastax.dsegraphloader.impl.loader.DataLoaderImpl.execute(DataLoaderImpl.java:194)
at com.datastax.dsegraphloader.impl.loader.DataLoaderBuilder.execute(DataLoaderBuilder.java:101)
at com.datastax.dsegraphloader.cli.Executable.execute(Executable.java:69)
at com.datastax.dsegraphloader.cli.Executable.main(Executable.java:163)

Относительно сообщения об ошибке "DSE Graph не настроен для обработки запросов" что мне нужно сделать, чтобы настроить загрузчик DSE Graph для загрузки данных в DSE Graph?


datastax-enterprise datastax-startup
person Virendra    schedule 22.08.2016    source источник

Ответы (1)


arrow_upward
2
arrow_downward

Получил помощь от ребят из DataStax, чтобы заставить это работать.

На самом деле некоторые настройки были перепутаны в кластере, поэтому мы просто создали новый кластер, а затем просто сделали одну настройку, чтобы включить службу DSE Graph на узлах этого кластера в файле /etc/default/dse-

GRAPH_ENABLED=1

После этого обновил схему как -

schema.propertyKey("id").Text().single().create()
schema.propertyKey("follower").Text().single().create()
schema.propertyKey("name").Text().single().create()
schema.propertyKey("type").Text().single().create()
schema.propertyKey("followed").Text().single().create()
schema.propertyKey("timestamp").Timestamp().single().create()
schema.vertexLabel("record").partitionKey("id").properties("follower", "name", "type", "followed", "timestamp").create()

Также в отношении TimeStamp должно быть числовое значение, чтобы его можно было успешно загрузить через DSE Graphloader.

После этих изменений я могу успешно загрузить данные через DSE Graphloader.

person Virendra    schedule 23.08.2016