JSONデータの読み込み
DSE Graph Loaderを使用してJSONデータを読み込む方法。
JSONデータのデータ・マッピング・スクリプトを説明とともに示します。完全なスクリプトは、ページの最後にあります。
手順
- 必要に応じて、マッピング・スクリプトに構成を追加します。
-
読み込み対象のデータのサンプルは以下のようになります。
SAMPLE INPUT // author.jsonファイル用: {"author_name":"Julia Child","gender":"F"} // book.jsonファイル用: {"name":"The Art of French Cooking, Vol. 1","year":"1961","ISBN":"none"} // authorBook.jsonファイル用: {"name":"The Art of French Cooking, Vol. 1","author":"Julia Child"}
プロパティ・キー
name
は、authorBook
ファイルの頂点ラベルauthor
およびbook
の両方に使用されるため、変数aname
およびbname
は著者名および書名にそれぞれ使用されます。これらの変数は、author
頂点とbook
頂点間の辺を作成するためのマッピング・ロジックで使用されます。 -
データ入力ファイルを指定します。変数
inputfiledir
は、入力ファイルのディレクトリーを指定します。識別された各ファイルは、読み込みに使用されます。// DATA INPUT // データ入力ソース(コマンドライン引数で指定可能なファイル)を定義します // inputfiledirは入力ファイルのディレクトリーです inputfiledir = '/tmp/CSV/' authorInput = File.json(inputfiledir + 'author.json') bookInput = File.json(inputfiledir + 'book.json') authorBookInput = File.json(inputfiledir + 'authorBook.json')
-
各行で、ファイルは
json
ファイルとして指定され、ファイル名が指定され、デリミターが設定されます。File.json
のJSON形式は、行あたり1つのJSONオブジェクトです。マップauthorInput
が作成され、データの処理に使用されます。このマップは、transformsを使用して読み込む前に操作できます。authorInput = File.json(inputfiledir + 'author.json')
- マッピング・スクリプトの本文を作成します。マッピング・スクリプトのこの部分は、ファイル形式にかかわらず同じです。
-
ドライ・ランとしてJSON読み込みにDSE Graph Loaderを実行するには、以下のコマンドを使用します。
graphloader authorBookMappingJSON.groovy -graph testJSON -address localhost -dryrun true
テスト目的の場合、
graphloader
の実行前に、指定されたグラフが存在する必要はありません。ただし、実稼働用途では、graphloader
を使用する前にグラフとスキーマを作成する必要があります。 -
完全な読み込みスクリプトは以下のとおりです。
/* SAMPLE INPUT author:{"name":"Julia Child","gender":"F"} book :{"name":"The Art of French Cooking, Vol. 1","year":"1961","ISBN":"none"} authorBook:{"bname":"The Art of French Cooking, Vol. 1","aname":"Julia Child"} */ // CONFIGURATION // スキーマを作成するようにデータ・ローダーを構成します config create_schema:true, load_new:true, load_threads: 3 // DATA INPUT // データ入力ソース(コマンドライン引数で指定可能なファイル)を定義します // inputfiledirはコマンドラインで指定された入力ファイルのディレクトリーです // as the "-filename" option inputfiledir = '/tmp/JSON/' authorInput = File.json(inputfiledir + 'author.json') bookInput = File.json(inputfiledir + 'book.json') authorBookInput = File.json(inputfiledir + 'authorBook.json') //(定義済みインラインとして)いずれかのマッパーを使用して読み込むデータ・ソースを指定します load(authorInput).asVertices { label "author" key "name" } load(bookInput).asVertices { label "book" key "name" } load(authorBookInput).asEdges { label "authored" outV "aname", { label "author" key "name" } inV "bname", { label "book" key "name" } }