2017-08-29 4 views
0

こんにちはにデータをコミットするとき:私はまたhttps://github.com/awslabs/dynamodb-janusgraph-storage-backendJanusGraph DynamoDBのバックエンド例外はデータベース

からDynamoDBの例でJanusGraphを使用しています、私は、Sparkを使ってJanusGraphに接続しています - スカラ - グレムリンScalaのフレームワーク。私はCassandraをバックエンドとして使用するとすべてのことが機能しますが、DynamoDBの使用に切り替えると、バックエンド例外エラーが発生します。

私のconfが、私はDynamoDBの罰金を接続することができ、この

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) 

のように見えますが、私は、データを挿入するために起動したとき、私は、バックエンドの例外に遭遇します。以下は

は、エラーログ

ERROR org.janusgraph.graphdb.database.StandardJanusGraphの一部である - によるシステム・コミット org.janusgraph.coreの中に格納例外に[1]、トランザクションをコミットできませんでした。 JanusGraphException:バックエンド例外のためオペレーションを実行できませんでした at org.janusgraph.diskstorage.util.BackendOperation.execute(BackendOperation.java:57) at org.janusgraph.diskstorage.keycolumnvalue.cache.CacheTransaction.persist(CacheTransaction.java: 95) at org.janusgraph.diskstorage.keycolumnvalue.cache.CacheTransaction.flushInternal(CacheTransaction.java:143) at org.janusgraph.diskstorage.keycolumnvalue.cache.CacheTransaction.commit(CacheTransaction.java:200) at org.janusgraph.diskstorage.BackendTransaction.commit(BackendTransaction.java:150) at org.janusgraph.graphdb.database。 org.janusgraph.graphdb.transaction.StandardJanusGraphTx.commit(StandardJanusGraphTx.java:1363)org.janusgraph.graphdb.tinkerpop.JanusGraphBlueprintsGraph $ GraphTransaction.doCommitで (JanusGraphBlueprintsGraph.javaでStandardJanusGraph.commit(StandardJanusGraph.java:703) : 272) at org.apache.tinkerpop.gremlin.structure.util.AbstractTransaction.commit(AbstractTransaction.java:105) at $ line81。$ read $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ anonfun $ 1 $$ anonfun $を適用する$ 1.apply( :84) at $ line81。$ read $ $ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ iw $$ anonfun $ 1 $$ anonfun $ apply $ 1.apply(:80)

ここで何が起こっているか考えてみてください。私はDynamoDBの新機能です。これはカッサンドラでうまくいきました

答えて

0

なぜあなたは接続されていることをご存知ですか?私はあなたの設定に資格情報を提供しなければならないと思います。例:

conf.setProperty("storage.dynamodb.client.credentials.class-name", "com.amazonaws.auth.BasicAWSCredentials") 
conf.setProperty("storage.dynamodb.client.credentials.constructor-args", "ACCESS_KEY,SECRET_KEY") 
関連する問題