SchedulerX:Gestion des tâches

Créer une tâche

1. Connectez-vous à la console SchedulerX.

2. Connectez-vous à la console EDAS.

3. Dans le volet de navigation de gauche, cliquez sur Task Scheduling.

4. Dans la barre de navigation supérieure, sélectionnez une région.

5. Dans le volet de navigation de gauche, sélectionnez task management.

6. Dans le volet de navigation de gauche, sélectionnez task management.

7. Sur la page , sélectionnez le namespace puis cliquez sur Create Task. Dans l'assistant Basic Configuration, configurez les paramètres de la tâche, puis cliquez sur Next.

   Le tableau suivant décrit les paramètres de configuration de base.

   Paramètre	Description
   Name	Nom personnalisé attribué à la tâche.
   Description	Brève description facilitant la recherche et la gestion de la tâche.
   Application ID	Groupe d'applications auquel appartient la tâche. Vous pouvez sélectionner un groupe d'applications dans la liste déroulante.
   Job Type	Langage de programmation utilisé pour implémenter la tâche. Les types pris en charge incluent Java, XXL-JOB, SpringSchedule, Golang, script task, Http et DataWorks. Si vous choisissez script task, vous devez également sélectionner un langage de script (shell, python ou go) et rédiger le script de la tâche dans l'éditeur.
   Class full path	Remarque Ce paramètre n'est disponible que si vous définissez le Job type sur Java. Chemin complet du JobProcessor, par exemple xxx.xxx.xxx.HelloProcessor.
   Execution Mode	Mode d'exécution de la tâche. Les modes suivants sont pris en charge : Standalone : Exécute la tâche sur un worker sélectionné aléatoirement. broadcast run : Lance la tâche simultanément sur tous les workers disponibles et attend leur achèvement. Visual MapReduce : Modèle Map offrant une liste visuelle de sous-tâches. Il est possible d'exécuter jusqu'à 300 sous-tâches. L'édition Professional prend en charge jusqu'à 1 000 sous-tâches et permet de les rechercher par mot-clé métier. MapReduce : Modèle MapReduce standard permettant l'exécution parallèle d'un grand nombre de sous-tâches. Seules les informations récapitulatives des sous-tâches peuvent être consultées. Ce mode est recommandé pour 1 000 000 de sous-tâches ou moins. shard run : Similaire au modèle elastic-job. Configurez les paramètres de sharding pour répartir uniformément les shards entre plusieurs workers afin de les exécuter. Ce mode prend en charge plusieurs langages de programmation. Remarque Les paramètres des réglages avancés varient selon le Execution Mode sélectionné.
   Job Parameters	Chaîne arbitraire récupérable depuis le contexte lors de l'exécution.

   Le tableau ci-dessous présente les paramètres de configuration avancée.

   Paramètre	Mode d'exécution applicable	Description	Valeur par défaut
   Tentatives de nouvelle exécution en cas d'échec	Général	Nombre de nouvelles tentatives automatiques si la tâche échoue. Remarque Une tâche échoue si son worker redémarre. Utilisez ce paramètre pour relancer immédiatement la tâche.	0
   Intervalle entre les tentatives en cas d'échec	Général	Délai entre deux tentatives. Unité : secondes.	30
   Concurrence des tâches	Général	Nombre d'instances concurrentes autorisées pour la tâche. Une valeur de 1 indique que les instances de la tâche ne peuvent pas s'exécuter simultanément.	1
   Politique de nettoyage	Général	Politique de nettoyage appliquée à l'historique d'exécution des tâches.	Conserver les N derniers enregistrements
   Nombre d'enregistrements à conserver	Général	Quantité d'enregistrements d'exécution historiques à conserver.	300
   Concurrence des sous-tâches par worker	Visual MapReduce MapReduce shard run	Dans un modèle distribué, ce paramètre définit le nombre de sous-tâches qu'un seul worker peut traiter simultanément. Augmentez cette valeur pour accélérer l'exécution. Si les services ou bases de données en aval ne supportent pas la charge, réduisez cette valeur.	5
   Tentatives de nouvelle exécution des sous-tâches en cas d'échec	Visual MapReduce MapReduce shard run	Dans un modèle distribué, ce paramètre indique le nombre de fois qu'une sous-tâche est automatiquement relancée après un échec.	0
   Intervalle entre les tentatives des sous-tâches en cas d'échec	Visual MapReduce MapReduce shard run	Dans un modèle distribué, ce paramètre spécifie l'intervalle entre les tentatives automatiques pour une sous-tâche ayant échoué. Unité : secondes.	0
   Politique de basculement des sous-tâches	Visual MapReduce MapReduce shard run	Détermine si les sous-tâches doivent être redistribuées à d'autres workers lorsque le worker exécutant passe hors ligne. Si vous activez cette fonctionnalité, les sous-tâches risquent d'être exécutées plusieurs fois lors d'un basculement. Assurez-vous que votre code est idempotent. Remarque Cette fonctionnalité nécessite la version 1.8.13 ou ultérieure du worker.
   Participation du nœud maître à l'exécution	Visual MapReduce MapReduce shard run	Indique si le nœud maître exécute également des sous-tâches. Au moins deux workers en ligne sont requis. Nous recommandons de désactiver ce paramètre lorsque le nombre de sous-tâches est très élevé. Remarque Cette fonctionnalité nécessite la version 1.8.13 ou ultérieure du worker.
   Mode de distribution des sous-tâches	Visual MapReduce MapReduce shard run	push model : Les sous-tâches sont réparties équitablement entre chaque worker. pull model : Chaque worker récupère les sous-tâches, ce qui évite l'effet du « worker le plus lent ». Toutes les sous-tâches sont mises en cache sur le nœud maître durant ce processus, augmentant ainsi la pression mémoire. Ce mode est recommandé pour 10 000 sous-tâches ou moins.	push model
   Stratégie de distribution	Visual MapReduce MapReduce	Stratégie utilisée pour distribuer les sous-tâches. Par défaut, elles sont attribuées aux workers selon un principe de tourniquet (round-robin). Round-robin strategy : Répartit uniformément les sous-tâches entre chaque worker. Cette stratégie convient aux scénarios où chaque sous-tâche nécessite approximativement le même temps de traitement. Load-optimal strategy : Le nœud maître détecte dynamiquement la charge de chaque worker. Privilégiez cette stratégie lorsque les temps de traitement varient considérablement d'une sous-tâche à l'autre ou d'un worker à l'autre. Remarque Cette fonctionnalité nécessite la version 1.10.14 ou ultérieure du worker.
   Taux de distribution	Visual MapReduce MapReduce	Vitesse à laquelle les sous-tâches sont distribuées. Spécifiez le nombre de sous-tâches distribuées par seconde ou par minute.
   Nombre de sous-tâches par extraction (modèle pull uniquement)	Visual MapReduce MapReduce shard run	Nombre de sous-tâches qu'un worker extrait du nœud maître en une seule requête.	5
   Capacité de la file d'attente des sous-tâches (modèle pull uniquement)	Visual MapReduce MapReduce shard run	Taille de la file d'attente de cache des sous-tâches sur un worker.	10
   Concurrence globale des sous-tâches (modèle pull uniquement)	Visual MapReduce MapReduce shard run	Le modèle pull prend en charge une limite de concurrence globale pour les sous-tâches, utilisable pour limiter le débit.	1 000

8. Dans l'assistant Schedule Configuration, définissez les paramètres de planification ainsi que les paramètres de configuration avancée, puis cliquez sur Next.

   Le tableau suivant détaille les paramètres de planification.

   Paramètre	Description
   Time Type	none : Aucune planification. La tâche est généralement déclenchée par un workflow. cron : Déclenchement basé sur une expression CRON. api : Déclenchement via un appel API. fixed_rate : Déclenchement à fréquence fixe. second_delay : Déclenchement après un délai fixe en secondes. onetime : Exécution unique de la tâche. unix cron : Déclenchement basé sur une expression CRON au format UNIX standard.
   Cron Expression (disponible uniquement si Time type est défini sur cron)	Saisissez une expression CRON. Rédigez-la manuellement ou utilisez un outil pour la générer et la valider.
   Fixed frequency (disponible uniquement si Time type est défini sur fixed_rate)	Saisissez un intervalle fixe en secondes. La valeur doit être supérieure ou égale à 60. Par exemple, une valeur de 200 signifie que la tâche est planifiée toutes les 200 secondes.
   Fixed delay (disponible uniquement si Time type est défini sur second_delay)	Saisissez un délai fixe en secondes. La valeur doit être un entier compris entre 1 et 60. Par exemple, une valeur de 5 signifie que la tâche se déclenche après un délai de 5 secondes.
   Scheduling time (disponible uniquement si Time type est défini sur onetime)	Saisissez l'heure précise d'exécution de la tâche, par exemple 2023-7-13 00:00:00.
   unix cron expression (disponible uniquement si Time type est défini sur unix cron)	Saisissez une expression CRON au format UNIX standard.

   Les paramètres de configuration avancée sont décrits dans le tableau ci-après.

   Paramètre	Description
   Time offset	Décalage de l'heure des données par rapport à l'heure planifiée. Cette valeur est récupérable depuis le contexte lors de l'exécution.
   Time Zone	Sélectionnez un fuseau horaire selon vos besoins. Choisissez parmi les pays et régions courants ou utilisez un format GMT standard.

9. Dans l'assistant Notification Configuration, configurez les paramètres d'alerte et les contacts, puis cliquez sur Finish.

   Les paramètres d'alerte comprennent les commutateurs Timeout Alert, Timeout (en secondes), Kill on Timeout, Success Notification, Failure Alert, Consecutive Failures et No Available Worker Alert. Pour le Notification channel and contact, vous avez le choix entre Application group contact ou Custom.

   Pour le Notification channel and contact, sélectionnez Application group contact ou Custom.

   • Application group contact

     Tous les contacts du groupe d'applications reçoivent les notifications.

   • Custom

     Spécifiez un Contact Group ou un Contact individuel pour recevoir les notifications.

     • Contact Group

       Tous les contacts du groupe sélectionné reçoivent les notifications. Pour plus d'informations sur la création d'un groupe de contacts, consultez Créer un contact de notification ou un groupe de contacts.

     • Contact

       1. Ajoutez les contacts destinataires des notifications. Plusieurs contacts peuvent être ajoutés. Après avoir cliqué sur Add contact, cliquez sur Go to create contact.

       Dans la section Notification channel and contact, sélectionnez Custom, cochez la case webhook pour le Notification channel, puis choisissez Contact pour le Notification contact. Si la liste déroulante des contacts affiche No options, aucun contact n'est disponible.

       2. Sur la page qui s'affiche, cliquez sur Create Contact et saisissez les informations du contact.

       Les informations de contact incluent le Name (obligatoire), le Phone number, l'Email, le webhook et le Contact group.

10. Retournez à la page task management pour vérifier que la tâche a bien été créée et configurée.

    Remarque

    Par défaut, les tâches sont activées dès leur création. Désactivez-les puis réactivez-les selon vos besoins. Pour plus d'informations, consultez Activer et désactiver une tâche planifiée.

Modifier une tâche

1. Sur la page Task Management, localisez la tâche et cliquez sur Edit dans la colonne Actions.

2. Dans le panneau Edit, configurez les paramètres de base, de planification et d'alerte.

   Remarque

   L'Application ID et le type de tâche ne peuvent pas être modifiés. Les autres paramètres se configurent comme lors de la création d'une tâche.

Exécuter une tâche

Sur la page Task Management, cliquez sur Run Once dans la colonne Actions pour lancer la tâche.

Activer et désactiver des tâches

Dupliquer une tâche

Sur la page Task Management, choisissez More > Copy dans la colonne Actions de la tâche. Modifiez ensuite la configuration de la nouvelle tâche selon vos besoins.

Rejouer une tâche

La relecture d'une tâche permet de rétrocharger des données pour une période passée. Cela s'avère utile lorsque vos exigences métier évoluent, par exemple lors de l'ajout d'un nouveau champ dans une base de données ou pour corriger les données du mois précédent.

Si les données d'une exécution précédente comportent des erreurs ou sont manquantes, relancez la tâche avec des paramètres spécifiques pour retraiter les données de cette période.

1. Connectez-vous à la console SchedulerX.

2. Sur la page Task Management, localisez la tâche, cliquez sur More dans la colonne Actions, puis cliquez sur Rebrush task.

3. Dans le panneau Rebrush task, définissez la Start and end date ainsi que la Data time, puis cliquez sur OK.

   • Start and end date : Plage de dates pour laquelle vous souhaitez réexécuter la tâche.

   • Data time : Heure de la journée utilisée comme heure logique des données pour chaque jour de la plage spécifiée.

   Prenons l'exemple de la configuration suivante :

   • L'heure actuelle est 10:00:00 le 1er janvier 2019.

   • La Start and end date s'étend du 1er octobre 2018 au 7 octobre 2018. Cette plage couvre la période allant du 1er octobre 2018 à 00:00:00 jusqu'au 7 octobre 2018 à 23:59:59.

   • La Data time est fixée à 11:11:11.

   Dans ce scénario, la tâche est réexécutée sept fois, générant ainsi sept nouvelles instances.

   N/S	Heure de planification	Heure des données
   1	2019.1.1 10:00:00	2018.10.1 11:11:11
   2	2019.1.1 10:00:00	2018.10.2 11:11:11
   3	2019.1.1 10:00:00	2018.10.3 11:11:11
   4	2019.1.1 10:00:00	2018.10.4 11:11:11
   5	2019.1.1 10:00:00	2018.10.5 11:11:11
   6	2019.1.1 10:00:00	2018.10.6 11:11:11
   7	2019.1.1 10:00:00	2018.10.7 11:11:11

Historiques d'exécution et d'opération

• Pour consulter les historiques d'exécution, accédez à la page Task Management, localisez la tâche, puis cliquez sur More > Historical records dans la colonne Actions.

• Pour consulter les historiques d'opération, accédez à la page Task Management, localisez la tâche, puis cliquez sur More > Operation Record dans la colonne Actions. Sur la page Operation Record, filtrez les enregistrements par Type et Task ID. Le tableau affiche le Task ID, l'Operation Time, l'Operation Type, l'Operator et les Extensions. Pour afficher les détails d'un enregistrement, cliquez sur View dans la colonne Operation.

Supprimer une tâche

1. Sur la page Task Management, localisez la tâche à supprimer, puis choisissez More > Delete dans la colonne Actions.

2. Dans la boîte de dialogue de confirmation, cliquez sur Confirm.

Importer ou exporter des tâches

1. Sur la page Task Management, sélectionnez une application de l'édition Professional.

2. Cliquez sur Import Jobs ou Export Tasks.