Configurer le deuxième sous-Job - Cloud - 8.0

Neo4j

Version
Cloud
8.0
Language
Français
Product
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 Real-Time Big Data Platform
Module
Studio Talend
Content
Création et développement > Systèmes tiers > Composants NoSQL > Composants Neo4j
Gouvernance de données > Systèmes tiers > Composants NoSQL > Composants Neo4j
Qualité et préparation de données > Systèmes tiers > Composants NoSQL > Composants Neo4j
Last publication date
2024-02-21

Procédure

  1. Double-cliquez sur le tFixedFlowInput_1 pour ouvrir sa vue Basic settings et procédez comme suit :
    1. Ouvrez l'éditeur du schéma en cliquant sur le bouton […] près de Edit schema et ajoutez les deux colonnes suivantes dans l'éditeur du schéma : name, de type String et gender de type String.
    2. Dans le champ Number of rows, saisissez 5.
    3. Sélectionnez Use Inline Content(delimited file) et saisissez le contenu suivant dans le champ Content.
      Jane;f
      John;m
      Marry;
    4. Laissez les valeurs par défaut des autres options.

    Ce composant génère 15 enregistrements. Chacun de ces enregistrements contient deux champs : name et gender (facultatif).

  2. Double-cliquez sur le tMap_1 pour ouvrir son éditeur de mapping et procédez comme suit :
    1. Ajoutez trois lignes dans la table out1. Leur colonne Column est respectivement seq, lastname et age. Leur Type est respectivement Integer, String et Integer.
      Vous pouvez ajouter une ligne dans la table en cliquant sur le bouton + qui se trouve sous la table.
    2. Mappez la colonne name de la section row1 à la colonne name de la section out1.
      Vous pouvez mapper une colonne en glissant-déposant la colonne source de la section row1 au champ Expression de la colonne cible de la section out1.
    3. Mappez la colonne gender de la section row1 à la colonne gender de la section out1.
    4. Saisissez Numeric.sequence("s1",0,1) dans le champ Expression de la colonne seq.
    5. Saisissez TalendDataGenerator.getLastName() dans le champ Expression de la colonne lastname.
    6. Saisissez Numeric.random(25,99) dans le champ Expression de la colonne age.
    7. Cliquez sur OK pour fermer l'éditeur de mapping.

    Ce composant reçoit les informations relatives au nom et au genre depuis le tFixedFlowInput_1 et ajoute les informations supplémentaires pour créer des nœuds dans la base de données Neo4jv4, y compris le numéro de séquence, lastname et age.

  3. Double-cliquez sur le tNeo4jv4Output_1 pour ouvrir sa vue Basic settings et procédez comme suit :
    1. Cochez la case Use an existing connection et sélectionnez le composant tNeo4jv4Connection_1 dans la liste déroulante Component List.
    2. Cliquez sur le bouton Sync columns pour vous assurer que le schéma du composant a bien les mêmes colonnes que celui du tMap_1.
    3. Sélectionnez Send data as list et saisissez rows dans Data list name.
      Cette étape indique de traiter les données d'entrée comme une liste et d'attribuer un nom à cette liste (rows), pour pouvoir référencer la liste.
    4. Saisissez les clauses suivantes dans le champ Query.
      UNWIND $rows as row
      MERGE (p:Person:UpdateMe {id: row.seq} )
      SET p.name = row.name, p.lastName = row.lastname, p.age = row.age, p.gender = row.gender
    5. Laissez les valeurs par défaut des autres options.

    Ce composant crée des nœuds et configure les propriétés des nœuds utilisant les données reçues. Pour plus d'informations concernant la clause UNWIND, consultez UNWIND (en anglais). Pour plus d'informations concernant la clause MERGE, consultez MERGE (en anglais).