Configurer les composants - 7.3

Aggregate (Agrégation) (Mediation)

Version
7.3
Language
Français (France)
Product
Talend Data Fabric
Talend Data Services Platform
Talend ESB
Talend MDM Platform
Talend Open Studio for ESB
Talend Real-Time Big Data Platform
Module
Studio Talend
Content
Création et développement > Systèmes tiers > Composants Routing (Médiation) > Composants d'agrégation (Médiation)
Gouvernance de données > Systèmes tiers > Composants Routing (Médiation) > Composants d'agrégation (Médiation)
Qualité et préparation de données > Systèmes tiers > Composants Routing (Médiation) > Composants d'agrégation (Médiation)

Procédure

  1. Double-cliquez sur le cFile nommé File_source, pour afficher sa vue Basic settings dans l'onglet Component.
  2. Dans le champ Path, parcourez votre système ou saisissez le chemin d'accès au fichier d'entrée et laissez les autres champs tels qu'ils sont.
    Dans ce scénario, quatre fichiers texte se trouvent dans le répertoire spécifié : a.txt, b.txt, c.txt et d.txt. Ils contiennent respectivement la phrase suivante This is a! , This is b! , This is c! et This is d! .
  3. Double-cliquez sur le composant cAggregate nommé Aggregator, pour afficher sa vue Basic settings dans l'onglet Component.
  4. Dans le champ Language, sélectionnez Constant ou Simple comme langage d'expression.
    Dans le champ Expression, saisissez l'expression "getBody(String.class)" pour récupérer le corps du message.
    Dans le champ Strategy, saisissez le nom du bean Java AggregateBody que vous avez créé.
    Cochez la case Number of messages et saisissez 2 dans le champ.
  5. Double-cliquez sur le composant cProcessor nommé Monitor_before pour afficher sa vue Basic settings dans l'onglet Component.
  6. Dans le champ Code, personnalisez le code comme suit, afin que la console de la vue Run affiche le contenu du message avant que l'opération d'agrégation soit effectuée :
    System.out.println("Before aggregation: "+
    exchange.getIn().getBody(String.class));
  7. De la même façon, configurez le composant cProcessor nommé Monitor_after afin que la console de la vue Run affiche le contenu du message après l'opération d'agrégation :
    System.out.println("After aggregation: "+
    exchange.getIn().getBody(String.class));
  8. Appuyez sur les touches Ctrl+S pour sauvegarder votre Route.