Générer un appel REST à l'aide d'enregistrements d'entrée - Cloud

Guide des connecteurs des applications Talend Cloud

author
Talend Documentation Team
EnrichVersion
Cloud
EnrichProdName
Talend Cloud
task
Administration et monitoring > Gestion des connexions
Création et développement > Création de Pipelines
EnrichPlatform
Talend Pipeline Designer

Ce scénario a pour objectif de vous aider à configurer et à utiliser des connecteurs dans un pipeline. Ce scénario doit être adapté en fonction de votre environnement et de votre cas d'utilisation.

Procédure

  1. Cliquez sur Connections > ADD CONNECTION.
  2. Dans le panneau qui s'ouvre, donnez un nom à votre connexion, ainsi qu'une description, si nécessaire.

    Exemple

    REST destination
  3. Sélectionnez votre moteur dans la liste Engine.
    Remarque : Si aucun Remote Engine Gen2 n'a été créé depuis Talend Cloud Management Console ou s'il existe mais semble indisponible, ce qui signifie qu'il n'est pas en cours de fonctionnement, vous ne pourrez pas sélectionner de type de connexion (Connection type) dans la liste ou sauvegarder la nouvelle connexion. Les types de connexion disponibles dépendent du moteur sélectionné.
  4. Sélectionnez le type de connexion à créer.
    Sélectionnez REST.
  5. Renseignez les propriétés de la connexion et l'URL du serveur REST à appeler, comme décrit dans Propriétés REST. Vérifiez la connexion et cliquez sur ADD DATASET. Dans cet exemple, le service d'API https://requestinspector.com est utilisé pour poster un enregistrement avec des paramètres de requête spécifiques.
  6. Dans le panneau Add a new dataset, nommez votre jeu de données.

    Exemple

    Request Inspector API
  7. Renseignez les propriétés requises afin de vous connecter au service :
    1. Dans le champ Type, sélectionnez Batch.
    2. Dans le champ Resource, saisissez inspect/talend-doc/dataset/{/entity}/{/id} (où talend-doc est le nom de l'endpoint précédemment créé sur https://requestinspector.com/).
    3. Dans la liste HTTP Method, sélectionnez POST.
    4. Dans le champ Answer body format, sélectionnez TEXT.
    5. Activez l'option Set header et saisissez header1 dans le champ Name, ainsi que header/{/val_head1} dans le champ Value.
    6. Activez l'option Set URL parameters et saisissez q dans le champ Name, ainsi que query_{/q} dans le champ Value.
    7. Activez l'option Set path parameters et saisissez entity dans le champ Name, ainsi que {/entity/type} dans le champ Value. Ajoutez un paramètre de chemin et saisissez id dans le champ Name, ainsi que {/entity/book/id} dans le champ Value.
    8. Activez l'option Define body et sélectionnez Json dans la liste Body type, puis saisissez ceci dans le champ Json :
      {
      book:{
      "name": "${/entity/book/title}",
      "price": ${/entity/book/price}
      }
      }
  8. Cliquez sur VALIDATE pour sauvegarder votre jeu de données.
  9. Ajoutez un jeu de données Test utilisé comme source dans votre pipeline afin de poster un faux enregistrement dans la destination de l'API REST. Renseignez les propriétés de connexion comme décrit dans Tester les propriétés de la connexion et renseignez les propriétés du jeu de données comme suit :
    1. Nommez le jeu de données Fake record.
    2. Sélectionnez JSON dans la liste format.
    3. Saisissez le code suivant dans le champ values :
      {
      "q": 12345,
      "val_head1": "head1",
      "entity":{
      "type": "book",
      "book": {
      "id": "A321A32A13A2",
      "title": "Twenty Thousand Leagues Under the Sea",
      "price": 5.60
      }
      }
      }
  10. Cliquez sur ADD PIPELINE dans la page Pipelines. Votre nouveau pipeline s’ouvre.
  11. Donnez-lui un nom significatif.

    Exemple

    Generate a REST call using input records
  12. Cliquez sur ADD SOURCE et sélectionnez votre jeu de données source, Fake record dans le panneau qui s'ouvre.
  13. Cliquez sur l'élément ADD DESTINATION dans le pipeline pour ouvrir le panneau vous permettant de sélectionner le jeu de données REST de sortie, qui vous permet de poster l'enregistrement à l'URL définie dans l'API REST https://requestinspector.com/.
    Remarque : Le connecteur REST envoie une requête pour chaque enregistrement reçu. Si vous avez 10 enregistrements, 10 requêtes REST sont générées.
  14. Cliquez sur SAVE pour sauvegarder votre configuration.
  15. Dans la barre d'outils en haut de Talend Cloud Pipeline Designer, sélectionnez votre profil d'exécution dans la liste (pour plus d'informations, consultez Run profiles).
  16. Cliquez sur l'icône d'exécution pour exécuter votre pipeline.

Résultats

Votre pipeline est en cours d'exécution. Le faux enregistrement a été posté sur le service d'API REST selon les paramètres d'URL définis dans la configuration du jeu de données REST.

Vous pouvez ensuite vérifier le résultat de l'appel de l'API REST et constater que les paramètres de requête, l'en-tête et le corps de l'enregistrement JSON ont été reçus dans le dashboard https://requestinspector.com/ :