データインポートの設定 - 7.3

Neo4j

EnrichVersion
Cloud
7.3
EnrichProdName
Talend Big Data
Talend Big Data Platform
Talend Data Fabric
Talend Data Integration
Talend Data Management Platform
Talend Data Services Platform
Talend ESB
Talend MDM Platform
Talend Open Studio for Big Data
Talend Real-Time Big Data Platform
EnrichPlatform
Talend Studio
task
ジョブデザインと開発 > サードパーティーシステム > NoSQL Components > Neo4j
データガバナンス > サードパーティーシステム > NoSQL Components > Neo4j
データクオリティとプレパレーション > サードパーティーシステム > NoSQL Components > Neo4j

手順

  1. tFileInputDelimitedコンポーネントをダブルクリックして、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開きます。
  2. [File name/Stream] (ファイル名/ストリーム)フィールドで、読み込む従業員データが保存されているCSVファイルへのパスを指定します。
    このサンプルに使用している入力CSVファイルは、次のとおりです。
    employeeID;employeeName;age;hireDate;salary;managerID
    1;Rutherford Roosevelt;38;06-10-2008;13336.58;m5
    2;Warren Adams;43;05-22-2008;11626.68;m6
    3;Andrew Roosevelt;55;04-01-2007;10052.95;m4
    4;Herbert Quincy;54;06-14-2007;10694.71;m6
    5;Woodrow Polk;33;08-14-2007;13751.50;m4
    6;Theodore Johnson;47;01-26-2008;12426.87;m6
    7;Benjamin Adams;32;02-25-2008;10438.65;m4
    8;Woodrow Harrison;51;10-11-2008;11188.27;m5
    9;George Truman;40;04-28-2008;14254.49;m5
    10;Harry Jackson;38;04-01-2008;12798.78;m6
  3. [Header] (ヘッダー)フィールドで、ヘッダー行としてスキップする行数を指定します。このサンプルでは、CSVファイルの最初の行がヘッダー行です。
  4. [Edit schema] (スキーマの編集)の横にある[...]ボタンをクリックして[Schema] (スキーマ)ダイアログボックスを開き、入力ファイルの構造をベースに入力スキーマを定義します。このサンプルでは、入力スキーマは次の6つのカラムで構成されています: employeeID (整数)、employeeName (文字列)、age (整数)、hireDate (日付)、salary (倍数)、およびmanagerID (文字列)。
    終了したら[OK]をクリックして[Schema] (スキーマ)ダイアログボックスを閉じ、スキーマを次のコンポーネントにプロパゲートします。
  5. tNeo4jRowコンポーネントをダブルクリックして、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開きます。
  6. [Use an existing connection] (既存の接続を使用する)チェックボックスをオンにし、tNeo4jConnectionコンポーネントによって開かれたNeo4jデータベース接続を再利用します。このコンポーネントは、このサンプルで使用している唯一の接続コンポーネントです。
  7. コンポーネントで実行するCypherクエリーを[Query] (クエリー)フィールドに入力します。
    このサンプルでは、入力フローからのデータを保存するために、次のクエリーを入力して、ラベルがEmployeesで6つのプロパティがあるノードを作成します。
    • ID。変数パラメーターidの値を取ります。

    • Name。変数パラメーターnameの値を取ります。

    • Age。変数パラメーターageの値を取ります。

    • HireDate。変数パラメーターhire_dateの値を取ります。

    • Salary。変数パラメーターsalaryの値を取ります。

    • ManagerID。変数パラメーターmanager_idの値を取ります。

    "CREATE (n:Employees{ID:{id}, Name:{name}, Age:{age}, HireDate:{hire_date}, Salary:{salary}, ManagerID:{manager_id}})"
  8. [Parameters] (パラメーター)テーブルの[Parameter] (パラメーター)フィールドに、Cypherクエリーに従って変数パラメーターを入力し、[Parameter value] (パラメーター値)リストフィールドから選択することで、それぞれを入力スキーマカラムにマッピングします。