Accéder au contenu principal Passer au contenu complémentaire

Exécuter un Job dans Talend Administration Center

Dans la page Job Conductor de Talend Administration Center, vous définissez une tâche d'exécution pour regrouper les phases de génération de script, de déploiement et d'exécution de vos Jobs MapReduce et Spark Batch.

Avant de commencer

  • Le cluster Databricks à utiliser a été correctement configuré et est en cours de fonctionnement.

  • Vous avez créé les Jobs de cas d'utilisation décrits dans les sections précédentes et les avez exécutés avec succès depuis le Studio Talend.

Procédure

  1. Connectez-vous à Talend Administration Center avec le compte créé dans Configurer votre premier utilisateur et premier projet.
  2. Dans la vue Menu de Talend Administration Center, cliquez sur Job Conductor pour afficher la page Job Conductor.
  3. Dans la barre d'outils de la page Job Conductor, cliquez sur Add > Normal Task de la barre d'outils pour afficher le formulaire Execution task.
  4. Dans le champ Label, saisissez le nom que vous souhaitez donner à la tâche à déclencher. Par exemple, getting_started.
  5. Cliquez sur l'icône pour ouvrir un filtre de Job afin de chercher le Job à exécuter depuis le Job Conductor et sélectionnez-le dans le filtre en utilisant sa dernière version (Latest).

    Il peut être, par exemple, le Job Spark Batch décrit dans Fusionner les informations relatives aux films et aux cinéastes à l'aide d'un Job Apache Spark Batch.

    Une fois que vous avez sélectionné le Job, les champs Project, Branch, Name, Version et Context sont automatiquement complétés par les informations relatives au Job sélectionné.

  6. Cochez la case Regenerate Job on change pour regénérer le Job sélectionné avant le déploiement et l'exécution de la tâche chaque fois qu'une modification est effectuée sur le Job.

    Notez que si vous avez sélectionné la dernière version du Job (Latest version), lorsqu'une nouvelle version du Job est créée dans le Studio Talend, ce Job sera regénéré même si vous n'avez pas coché l'option Regenerate Job on change.

  7. Sélectionnez le serveur sur lequel la tâche doit être déployée.

    Dans ce scénario, le serveur est le service Talend Runtime configuré dans Connecter Talend Runtime Container à Talend Administration Center.

  8. Cliquez sur Save pour valider la configuration.

    La nouvelle tâche est ajoutée à la liste des tâches.

  9. Dans la page Job Conductor, cliquez sur la tâche getting_started pour la sélectionner et dans la barre d'outils, cliquez sur Generate pour permettre à la tâche de rechercher le script de Job approprié dans le projet approprié depuis le Repository du Studio Talend et de générer le code.

    Une fois la génération terminée, le statut de la tâche indique Ready to deploy (prêt à déployer), ce qui signifie que le code généré est maintenant prêt à être déployé sur le serveur d'exécution.

  10. Cliquez sur Deploy pour déployer le Job sur le serveur d'exécution.

    Une fois le déploiement terminé, le statut indique Ready to run (prêt à être exécuté). Cela signifie que le serveur a bien reçu le Job et est maintenant prêt à l'exécuter.

  11. Cliquez sur Run pour exécuter le Job.

    Une fois l'exécution terminée, le statut indique de nouveau Ready to run (prêt à être exécuté), ce qui signifie que le Job peut être de nouveau exécuté si nécessaire.

    Vérifiez la colonne Error Status si la tâche ne s'est pas exécutée correctement, ainsi que le log de la tâche pour les informations sur l'exécution du Job.

    Cela fait, vous pouvez vérifier, par exemple dans Microsoft Azure Storage Explorer, que la sortie a été écrite dans un système de stockage ADLS.

Cette page vous a-t-elle aidé ?

Si vous rencontrez des problèmes sur cette page ou dans son contenu – une faute de frappe, une étape manquante ou une erreur technique – faites-le-nous savoir.

Laissez vos commentaires ici