Scénario : Utiliser les fonctions MongoDB pour créer une collection et y écrire des données - 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 crée la collection blog et y écrit des données à l'aide des fonctions MongoDB.

Relier les composants

  1. Déposez, de la Palette dans l'espace de modélisation graphique, un composant tMongoDBConnection, un tFixedFlowInput, un tMongoDBRow, un tMongoDBClose, un tMongoDBInput et un tLogRow.

  2. Renommez le tFixedFlowInput en blog_post_data, le tMongoDBRow en write_data_to_collection, le tMongoDBInput en read_data_from_collection et le tLogRow en show_data_from_collection.

  3. Reliez le tMongoDBConnection au tFixedFlowInput à l'aide d'un lien OnSubjobOk.

  4. Reliez le tFixedFlowInput au tMongoDBRow à l'aide d'un lien Row > Main.

  5. Connectez le tFixedFlowInput au tMongoDBInput en utilisant un lien OnSubjobOk.

  6. Reliez le composant tMongoDBInput au tMongoDBClose à l'aide d'un lien OnSubjobOk.

  7. Reliez le tMongoDBInput au composant tLogRow à l'aide d'un lien Row > Main.

Configurer les composants

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

  2. Dans la liste DB Version, sélectionnez la version de MongoDB que vous utilisez.

  3. Dans les champs Server et Port, saisissez le nom du serveur et le numéro du port, respectivement.

    Dans le champ Database, saisissez le nom de la base de données MongoDB.

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

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

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

    Andy;Open Source Outlook;Open Source,Talend;Talend, the leader of the open source world...
    Andy;Data Integration Overview;Data Integration,Talend;Talend, the leading player in the DI field...
    Andy;ELT Overview;ELT,Talend;Talend, the big name in the ELT circle...
  5. Double-cliquez sur le tMongoDBRow pour ouvrir sa vue Basic settings.

    Cochez la case Use existing connection.

    Dans le champ Function, saisissez la fonction MongoDB pour créer la collection blog et y insérer des données :

    "function(author,title,keywords,contents){
    return db.blog.save(
    {author:author,title:title,keywords:keywords,contents:contents}
    );
    
    }"
  6. Cliquez sur le bouton [...] à côté de Edit schema pour ouvrir l'éditeur du schéma.

  7. Cliquez quatre fois sur le bouton [+] pour ajouter quatre colonnes, à droite. Nommez-les respectivement author, title, keywords et contents, toutes de type String.

    Cliquez sur le bouton afin de copier toutes les colonnes vers la table d'entrée.

    Cliquez sur OK pour fermer l'éditeur.

  8. Dans la table Parameters value, cliquez quatre fois sur le bouton [+] pour ajouter quatre lignes. Saisissez les valeurs en séquence : row1.author, row1.title, row1.keywords et row1.contents. Les données de row1 sont transférées aux paramètres définis dans la fonction.

  9. Double-cliquez sur le tMongoDBInput pour ouvrir sa vue Basic settings.

    Cochez la case Use existing connection.

    Dans le champ Collection, saisissez le nom de la collection, blog.

  10. Cliquez sur le bouton [...] à côté du champ Edit schema pour ouvrir l'éditeur du schéma.

  11. Cliquez quatre fois sur le bouton [+] pour ajouter quatre colonnes. Nommez-les author, title, keywords et contents et configurez leur type à String.

    Cliquez sur OK pour fermer l'éditeur.

  12. Double-cliquez sur le tLogRow pour ouvrir sa vue Basic settings.

    Dans la zone Mode, sélectionnez Table (print values in cells of a table), pour un meilleur affichage.

Exécuter le Job

  1. Appuyez sur les touches Ctrl+S pour sauvegarder le Job.

  2. Appuyez sur la touche F6 pour exécuter le Job.