2017-08-04 2 views
-1

Diese CSV hat bereits eine ETL und importierte sie in Orientdb:Orientdb Import aus einer CSV in einem Graph-Datei - ETL

userlist.csv:

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

aber ich weiß nicht, wie man Erstellen Sie eine ETL, die diese CSV-Datei importiert, die einen Vorteil darstellt.

relation.csv:

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

FROM_ID und TO_ID zeigen die ID von userlist.csv. WEIGHT ist optional.

Bitte unterrichten Sie mich, wie ETL richtig zu schreiben.

Antwort

0

Versuchen Sie folgendes:

{ 
    "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"} 
      ] 
    } 
    } 
} 

Hoffe, dass es

Grüße

+0

hilft ich es versucht, aber erhielt die folgende Störung. ** ERROR Ausnahme = Fehler bei der Analyse Abfrage: CREATE EDGE USER_RELATION_FRIEND FROM (SELECT FROM USER_INFO WHERE ID =) bis (FROM USER_INFO SELECT WHERE ID = 2) SET Gewicht = ^ Encountered "" CREATE "" in Zeile 1 , Spalte 1. ** Gibt es noch etwas, das Sie tun können? –

+0

Ist die Klasse USER_RELATION_FRIEND bereits vorhanden? –

+0

Nein, es existiert nicht. Ich dachte darüber nach, es mit diesem ETL zu machen. –

Verwandte Themen