2017-08-04 9 views
-1

このCSVは、すでにETLを作成し、OrientDBにインポートしました:OrientDBインポートグラフにファイル - ETL

userlist.csv

ID,NAME 
1,SATOSHI 
2,TONA 
3,MIKI 
4,YUJI 
5,OTA 

しかし、私はどのように知りませんエッジを作るこのCSVをインポートするETLを作成します。

relation.csv

FROM_ID,TO_ID,WEIGHT 
1,2,4 
1,3,4 
1,5,3 
2,5,3 
2,3,5 
... 

FROM_IDTO_IDuserlist.csvIDを示しています。 WEIGHTはオプションです。

ETLを正しく書き込む方法を教えてください。

答えて

0

これを試してみてください:

{ 
    "source" : { 
    "file": { "path": "your_path/relation.csv" } 
    }, 
    "extractor" : { 
    "csv": {} 
    }, 
    "transformers": [ 
     { "command": { "command": "CREATE EDGE E FROM (SELECT FROM userlist-class where id = ${input.FROM_ID}) TO (SELECT FROM userlist-class where id = ${input.TO_ID}) set weight=${input.WEIGHT}"} } 
    ], 
    "loader" : { 
    "orientdb": { 
     "dbURL": "plocal:your-path/databases/db-name", 
     "dbUser": "your-user", 
     "dbPassword": "your-pwd", 
     "serverUser": "your-server-user", 
     "serverPassword": "your-server-pwd", 
     "dbType": "graph", 
     "classes": [{"name": "userlist-class-name", "extends":"V"}] 
    } 
    } 
} 

UPDATE

{ 
    "source" : { 
    "file": { "path": "C:/Users/Sorint.Lab/Desktop/Orient/Community/orientdb-community-2.2.24/config/relation.csv" } 
    }, 
    "extractor" : { 
    "csv": {} 
    }, 
    "transformers": [ 
     { "command": { "command": "CREATE EDGE USER_RELATION_FRIEND FROM (SELECT FROM userList where id = ${input.FROM_ID}) TO (SELECT FROM userList where id = ${input.TO_ID}) set weight=${input.WEIGHT}"} } 
    ], 
    "loader" : { 
    "orientdb": { 
     "dbURL": "plocal:C:/Users/Sorint.Lab/Desktop/Orient/Community/orientdb-community-2.2.24/databases/stack45504136", 
     "dbUser": "admin", 
     "dbPassword": "admin", 
     "serverUser": "root", 
     "serverPassword": "root", 
     "dbType": "graph", 
     "classes": [ 
      {"name": "userList", "extends":"V"}, 
      {"name": "USER_RELATION_FRIEND", "extends":"E"} 
      ] 
    } 
    } 
} 

はそれが私はそれを試してみましたが、次のエラーを受け取った

よろしく

+0

に役立ちます願っています。 ** ERROR例外=エラーの解析クエリ: からエッジUSER_RELATION_FRIENDをCREATE SET重量= ^ "" 行1で "" CREATE遭遇(ID = 2がUSER_INFO FROM SELECT)TO(ID = USER_INFO FROM SELECT) 、列1 ** 他に何かできますか? –

+0

USER_RELATION_FRIENDクラスは既に存在しますか? –

+0

いいえ、存在しません。私はこのETLで作ろうと考えていました。 –

関連する問題