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

Guide des connecteurs des applications Talend Cloud

Version
Cloud
Language
Français
Product
Talend Cloud
Module
Talend Data Inventory
Talend Data Preparation
Talend Pipeline Designer
Content
Administration et monitoring > Gestion des connexions
Création et développement > Création de Pipelines
Last publication date
2024-03-21

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 (Connexions) > Add connection (Ajouter une connexion).
  2. Dans le panneau qui s'ouvre, sélectionnez le type de connexion à créer.

    Exemple

    REST destination
  3. Sélectionnez votre moteur dans la liste Engine.
    Remarque :
    • Il est recommandé d'utiliser Moteur distant Gen2 plutôt que Moteur Cloud pour le design pour un traitement avancé des données.
    • Si aucun Moteur distant Gen2 n'a été créé depuis Talend 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 (Ajouter un jeu de données). 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, 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 (Valider) 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 (Ajouter un 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 (Sauvegarder) pour sauvegarder votre configuration.
  15. Dans la barre d'outils en haut de Talend Cloud Pipeline Designer, cliquez sur le bouton Run (Exécuter) pour ouvrir le panneau vous permettant de sélectionner votre profil d'exécution.
  16. Sélectionnez dans la liste votre profil d'exécution (pour plus d'informations, consultez Profils d'exécution), puis cliquez sur Run (Exécuter) 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/ :