Scénario : Insérer des documents dans un bucket de données dans la base de données Couchbase - 6.1

Composants Talend Guide de référence

EnrichVersion
6.1
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 Open Studio for Data Integration
Talend Open Studio for Data Quality
Talend Open Studio for ESB
Talend Open Studio for MDM
Talend Real-Time Big Data Platform
task
Création et développement
Gouvernance de données
Qualité et préparation de données
EnrichPlatform
Studio Talend

Ce scénario insère trois posts de blog dans un bucket de données dans la base de données Couchbase. Les enregistrements source sont des données plates et sont donc dans des données JSON avant stockage dans la base de données Couchbase, en tant que documents. Notez que les valeurs du champ de données source title, sélectionné en tant que Key dans l'onglet Basic settings du tCouchbaseOutput, sont utilisées en tant qu'IDs du document dans la base de données Couchbase.

Relier les composants

  1. Déposez un tCouchbaseConnection, un tFixedFlowInput, un tCouchbaseOutput et un tCouchbaseClose dans l'espace de modélisation.

  2. Reliez le tCouchbaseConnection au tFixedFlowInput à l'aide d'un lien OnSubjobOk.

  3. Reliez le tFixedFlowInput au tCouchbaseOutput à l'aide d'un lien Row > Main.

  4. Reliez le tFixedFlowInput au tCouchbaseClose à l'aide d'un lien OnSubjobOk.

Configurer les composants

  1. Double-cliquez sur le tCouchbaseConnection pour ouvrir sa vue Basic settings.

  2. Dans le champ Data Bucket, saisissez le nom du bucket de données dans la base de données Couchbase.

    Dans le champ Password, saisissez le mot de passe pour accéder au bucket de données.

    Dans la table URIs, cliquez sur le bouton [+] pour ajouter autant de lignes que nécessaire, dans lesquelles vous pouvez saisir les URIs des nœuds du serveur Couchbase.

  3. Double-cliquez sur le tFixedFlowInput pour ouvrir sa vue Basic settings.

    Sélectionnez Use Inline Content (delimited file) dans la zone Mode.

    Dans le champ Content, saisissez les données à écrire dans la base de données Couchbase, par exemple :

    1;Andy;Integration at any scale;Talend, the leader of the DI space...
    2;Andy;Data Integration Overview;Talend, the leading player in the DI field...
    3;Andy;ELT Overview;Talend, the big name in the ELT circle...
  4. Cliquez sur le bouton Edit schema pour ouvrir l'éditeur de schéma.

  5. Cliquez quatre fois sur le bouton [+] pour ajouter quatre colonnes, respectivement nommées id, author, title et contents, toutes de type String.

    Cliquez sur OK pour valider la configuration et fermer l'éditeur.

  6. Cliquez sur le tCouchbaseOutput pour ouvrir sa vue Basic settings.

  7. Cochez la case Use existing connection afin de réutiliser la connexion.

  8. Dans la liste Key, sélectionnez le champ title dont les valeurs seront utilisées comme IDs des documents insérés dans la base de données Couchbase.

  9. Cochez la case Generate JSON Document et cliquez sur le bouton Configure JSON Tree pour ouvrir l'éditeur de mapping JSON.

  10. Appuyez sur la touche Maj pour sélectionner tous les champs dans la zone Linker source et déposez-les dans le nœud rootTag de la zone Link target.

  11. Dans la boîte de dialogue qui s'ouvre, sélectionnez Create as sub-element of target node.

    Cliquez sur OK afin de valider la configuration et fermer la boîte de dialogue.

  12. Cliquez-droit sur le nœud id de la zone Link target et sélectionnez Set as Loop Element dans le menu contextuel.

    Cliquez sur OK pour valider la configuration et fermer l'éditeur.

Exécuter le Job

  1. Appuyez sur F6 pour sauvegarder le Job et l'exécuter.

  2. Ouvrez votre Console Web Couchbase. Vous pouvez voir les documents stockés dans le bucket de données blog :

    Comme affiché ci-dessus, les enregistrements source sont sauvegardés dans la base de données Couchbase sous forme de documents JSON.