2017-08-29 2 views
0

Bonjour: J'utilise JanusGraph par exemple DynamoDB de https://github.com/awslabs/dynamodb-janusgraph-storage-backendJanusGraph exceptions backend DynamoDB lors de la validation des données à la base de données

Aussi, je me connecte à l'aide JanusGraph Spark - Scala - Gremlin cadre Scala. Tout fonctionne quand j'ai utilisé Cassandra comme backend, mais quand je passe à DynamoDB, je commence à recevoir des erreurs d'exception.

Mon ressemble à ceci conf

val conf = new BaseConfiguration 


conf.setProperty("gremlin.graph","org.janusgraph.core.JanusGraphFactory") 

conf.setProperty("storage.write-time","1 ms") 

conf.setProperty("storage.read-time","1 ms") 
conf.setProperty("storage.backend","com.amazon.janusgraph.diskstorage.dynamodb.DynamoDBStoreManager") 
conf.setProperty("storage.dynamodb.client.signing-region","us-east-1") 
conf.setProperty("storage.dynamodb.client.endpoint","http://127.0.0.1:8000") 
val graph = JanusGraphFactory.open(conf) 

Je peux connecter DynamoDB très bien, mais quand je commence à insérer des données, que je rencontrerai des exceptions back-end.

Ci-dessous est une partie de l'erreur journal

erreur org.janusgraph.graphdb.database.StandardJanusGraph - Impossible commit transaction [1] en raison d'une exception de stockage dans le système-commit org.janusgraph.core. JanusGraphException: Impossible d'exécuter l'opération en raison de l'exception backend à org.janusgraph.diskstorage.util.BackendOperation.execute (BackendOperation.java:57) à org.janusgraph.diskstorage.keycolumnvalue.cache.CacheTransaction.persist (CacheTransaction.java: 95) à org.janusgraph.diskstorage.keycolumnvalue.cache.CacheTransaction.flushInternal (CacheTransaction.java:143) à org.janusgraph.diskstorage.keycolumnvalue.cache.CacheTransaction.commit (CacheTransaction.java:200) à org.janusgraph.diskstorage.BackendTransaction.commit (BackendTransaction.java:150) à org.janusgraph.graphdb.database. StandardJanusGraph.commit (StandardJanusGraph.java:703) à org.janusgraph.graphdb.transaction.StandardJanusGraphTx.commit (StandardJanusGraphTx.java:1363) à org.janusgraph.graphdb.tinkerpop.JanusGraphBlueprintsGraph $ GraphTransaction.doCommit (JanusGraphBlueprintsGraph.java: 272) à org.apache.tinkerpop.gremlin.structure.util.AbstractTransaction.commit (AbstractTransaction.java:105) à $ line81. $ Lire $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ anonfun 1 $ anonfun $ appliquer $ 1.appliquer (: 84) à $ line81. $ Read $ $ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ anonfun $ 1 $$ anonfun $ appliquer $ 1.apply (: 80)

Une idée de ce qui se passe ici. Je suis assez nouveau à DynamoDB. Cela fonctionnait bien à Cassandra

Répondre

0

Pourquoi savez-vous que vous êtes connecté? Je pense que vous devez fournir des informations d'identification dans votre config. Par exemple:

conf.setProperty("storage.dynamodb.client.credentials.class-name", "com.amazonaws.auth.BasicAWSCredentials") 
conf.setProperty("storage.dynamodb.client.credentials.constructor-args", "ACCESS_KEY,SECRET_KEY")