Dans un flux de données, le code des tâches (SQL, par exemple) doit souvent varier dynamiquement selon l'heure de planification pour traiter différentes partitions de données. Pour éviter toute modification manuelle du code, utilisez les paramètres de planification. En définissant des espaces réservés dans votre code, le système les remplace automatiquement par des valeurs dynamiques, telles que l'horodatage des données et l'heure de planification, lors de l'exécution d'une tâche. Cette approche permet une exécution automatisée et paramétrée du flux de travail.
Processus de configuration principal
Pour utiliser les paramètres de planification, définissez-les et attribuez-leur des valeurs dans la section Scheduling. Une fois le code validé par les tests dans DataStudio, soumettez-le, avec ses paramètres de planification, au Operation Center. Le système planifie alors automatiquement la tâche et remplace dynamiquement les valeurs des paramètres selon la logique d'affectation définie.
|
Étape |
Action |
Objectif |
|
1. Définir un paramètre |
Dans le code du nœud, définissez un ou plusieurs paramètres en utilisant le format |
Réserver un espace réservé pour une valeur dynamique. |
|
2. Configurer le paramètre |
Dans le volet du nœud, attribuez une valeur à la variable présente dans le code. |
Associer l'espace réservé |
|
3. Tester |
Utilisez la fonctionnalité Perform Smoke Testing pour simuler un horodatage de données spécifique, vérifier le remplacement des paramètres et valider l'exécution correcte du code. |
S'assurer que la configuration est correcte dans l'environnement de développement. |
|
4. Déployer et vérifier |
Déployez le nœud dans l'environnement de production et confirmez la configuration finale des paramètres dans Operation Center. |
S'assurer que les paramètres de la tâche de production fonctionnent comme prévu. |
Procédure
1. Définir les paramètres
Double-cliquez sur le nœud cible, par exemple un nœud ODPS SQL, pour ouvrir l'éditeur de nœud.
-
Dans le code d'un nœud ODPS SQL ou d'autres nœuds basés sur SQL, définissez un nom de paramètre en utilisant la syntaxe
${param}. DataWorks recommande d'utiliser un nom de paramètre descriptif pour faciliter sa référence et sa gestion.Syntaxe des paramètres de planification :
Type
Syntaxe
Applicabilité
Remarques
Format général
${parameter_name}S'applique à la plupart des types de nœuds, tels que les nœuds ODPS SQL et les nœuds de synchronisation de données.
Il s'agit du format le plus courant.
Format spécial
Varie selon le type de nœud et n'utilise pas le format
${...}.PyODPS et Shell
Pour plus d'informations, consultez Exemples de configuration des paramètres de planification pour différents types de nœuds.
-- Example: Define a variable named pt_date for partition filtering. SELECT * FROM my_table WHERE ds = '${pt_date}'; Dans le volet de droite, cliquez sur Scheduling pour accéder à la section Scheduling Parameter.
Configurez les paramètres de planification comme décrit dans la section suivante.
2. Configurer les paramètres
Vous pouvez définir les paramètres de planification en mode Visual definition ou Define by expression. Basculez entre ces modes en cliquant sur Define by expression dans le coin supérieur droit de la liste des paramètres. Le mode Visual definition est activé par défaut.
-
Configurer les paramètres
Mode visuel
Cliquez sur Scheduling dans le volet de droite pour ouvrir le panneau de configuration des paramètres de planification.
-
Ajouter un paramètre
Cliquez sur Scheduling à droite du nœud et ajoutez des paramètres dans la section Scheduling Parameter. Vous pouvez ajouter des paramètres de l'une des deux manières suivantes.
Cliquez sur Add Parameter et saisissez manuellement un nom et une valeur. Le nom du paramètre doit être identique au nom de la variable défini dans le code.
Cliquez sur Load Parameters in Code. DataWorks analyse automatiquement les variables de votre code, telles que
${pt_date}, et les renseigne dans la liste des paramètres. Il vous suffit de saisir une valeur pour chaque paramètre.
-
Attribuer une valeur
Vous pouvez attribuer des paramètres intégrés, des variables de temps personnalisées ou des constantes comme valeurs.
Cliquez sur la zone de saisie. Une liste déroulante apparaît avec des expressions de paramètres couramment utilisées que vous pouvez sélectionner directement. Vous pouvez également saisir manuellement une expression personnalisée ou une variable intégrée.
Saisissez une valeur en fonction de vos besoins métier. Pour plus d'informations sur les formats de valeur pris en charge, consultez Formats pris en charge des paramètres de planification.
Mode expression
Cliquez sur Define by expression pour passer en mode Expression. Utilisez ce mode si vous préférez configurer les paramètres avec des expressions.
En mode Expression, séparez plusieurs paramètres par des espaces.
-
Lorsque vous ajoutez, supprimez ou modifiez des paramètres de planification dans Define by expression, DataWorks valide la syntaxe de l'expression. Si la syntaxe n'est pas valide, le paramètre ne peut pas être configuré.
Par exemple, DataWorks applique des règles, telles que l'interdiction des espaces de part et d'autre du signe égal (=).
-
-
Aperçu des paramètres
Après avoir défini les paramètres, cliquez sur Preview Scheduling Parameters pour voir comment les paramètres seront résolus pour les instances à venir en fonction d'un horodatage de données spécifié. Cela vous aide à tester la validité des définitions. Vous pouvez ajuster l'horodatage des données et le nombre d'instances à afficher en aperçu.
Certains nœuds, tels que les nœuds de synchronisation par lots, disposent d'un paramètre ${bizdate} par défaut. Ce paramètre reçoit automatiquement la valeur $bizdate. Vous pouvez remplacer le paramètre bizdate par un nom personnalisé dans votre code. Le nom ${bizdate} lui-même n'a aucune signification particulière et est traité de la même manière que tout autre paramètre personnalisé.
3. Test de fumée
Après avoir attribué des valeurs aux paramètres de planification, utilisez la fonctionnalité de test de fumée. Elle vous permet de définir un horodatage de données et de simuler l'exécution de la tâche, afin de vérifier que le code s'exécute correctement et que les paramètres de planification sont remplacés comme prévu. Si les résultats ne sont pas conformes aux attentes, ajustez rapidement la configuration pour éviter des problèmes lors des exécutions planifiées.
Les tests de fumée génèrent des instances, ce qui entraîne des frais. Pour plus d'informations sur la tarification des instances, consultez Facturation des groupes de ressources serverless .
-
Validez le code du nœud.
Configurez l'heure de planification et les dépendances de planification.
-
Cliquez sur l'icône Enregistrer

. Une fois le code et les configurations enregistrés, cliquez sur l'icône Valider 
pour envoyer le dernier code et la configuration vers Operation Center. Vous ne pouvez utiliser la fonctionnalité de test de fumée dans l'environnement de développement qu'après avoir validé le nœud.RemarqueSi vous constatez que le test de fumée n'exécute pas le dernier code ou les derniers paramètres, validez à nouveau le nœud.
-
Exécutez le test de fumée.
Cliquez sur l'icône Test de fumée

dans la barre d'outils. Dans la boîte de dialogue Perform Smoke Testing, sélectionnez un horodatage de données et cliquez sur OK pour démarrer le test. -
Consultez les journaux du test de fumée.
-
Dans la fenêtre Smoke Testing Records qui s'affiche, recherchez le dernier enregistrement et cliquez sur View Log.
Le journal affiche l'état et les détails d'exécution du nœud. La ligne des résultats de remplacement des paramètres montre les valeurs réelles de chaque paramètre de planification, ce qui vous permet de confirmer leur remplacement correct.
-
Vérifiez la sortie des paramètres dans les journaux pour confirmer que les valeurs sont correctes.
RemarqueSi vous fermez accidentellement la fenêtre, vous pouvez la rouvrir en cliquant sur l'icône Journaux du test de fumée

dans la barre d'outils.
-
Les fonctionnalités Exécuter 
et Exécution avancée 
vous obligent à attribuer manuellement des constantes aux variables dans le code. Par conséquent, elles ne peuvent pas servir à vérifier la configuration correcte des paramètres de planification.
4. Déployer et vérifier
Après vérification dans l'environnement de développement, déployez la tâche dans Operation Center pour une exécution planifiée en production. Après le déploiement, vérifiez les paramètres de planification dans l'environnement de production pour éviter les erreurs d'exécution.
Si les paramètres de planification d'une tâche déclenchée automatiquement ne sont pas configurés comme prévu, ou si vous ne trouvez pas la tâche dans Operation Center, assurez-vous que la tâche a bien été déployée. Pour plus d'informations sur le déploiement d'une tâche, consultez Déployer une tâche.
-
Vérifiez les définitions des paramètres.
Accédez à Operation Center, basculez vers la région et l'espace de travail cibles, puis accédez à la page . Dans la liste des tâches, cliquez sur le nom de la tâche et vérifiez les paramètres d'exécution dans le panneau Attribute pour vous assurer qu'ils sont corrects.
-
Effectuez un test de fumée dans Operation Center.
Vous pouvez également utiliser le test de fumée dans Operation Center pour confirmer qu'une tâche déployée remplace les paramètres et exécute le code comme prévu dans l'environnement de production. Pour plus d'informations, consultez Exécuter un test et afficher l'instance de test.
ImportantNotez que le test de fumée s'exécute sur des données de production réelles. Procédez avec prudence pour éviter de corrompre les données de votre base de données de production.
Dans la boîte de dialogue Test de fumée, saisissez un Nom du test de fumée, sélectionnez l'horodatage de données cible dans Sélectionner l'horodatage des données, activez éventuellement Configuration avancée pour personnaliser les paramètres d'exécution de la tâche, puis cliquez sur OK pour démarrer le test.
-
Observez les résultats de planification réels.
Une fois la tâche planifiée automatiquement, vérifiez que les paramètres ont été correctement remplacés en consultant les paramètres d'une instance déclenchée automatiquement dans Auto Triggered Instances.
Dans la liste Instances déclenchées automatiquement, recherchez l'instance de tâche cible et cliquez sur son nom. Dans le panneau Propriétés à droite, affichez le champ Paramètres d'exécution pour confirmer que chaque paramètre a été remplacé par les valeurs de date et d'heure réelles.
Exemple de configuration complet
Cet exemple utilise un nœud ODPS SQL pour montrer comment utiliser la fonctionnalité Perform smoke test in development environment dans l'environnement de développement afin de tester si les paramètres de planification configurés fonctionnent comme prévu. Une fois la tâche déployée, vous vérifierez également sa configuration de paramètres de planification dans Operation Center.
Pour savoir comment configurer les paramètres de planification pour différents types de nœuds, consultez Exemples de configuration des paramètres de planification pour différents types de nœuds.
-
Modifiez le code du nœud et configurez les paramètres de planification.
La figure suivante montre le code et les configurations des paramètres de planification du nœud ODPS SQL.


-
Définissez les variables dans le code.
-- Assign values by using built-in parameters SELECT '${var1}'; SELECT '${var2}'; -- Assign values by using custom parameters SELECT '${var3}'; SELECT '${var4}'; -- Assign a constant SELECT '${var5}'; -
Attribuez des valeurs aux variables.
Dans le volet , attribuez des valeurs aux variables (Zone 2). Pour plus d'informations sur les formats de valeur, consultez Formats pris en charge des paramètres de planification.
var1=$bizdate: Attribue l'horodatage des données au formatyyyymmdd.var2=$cyctime: Attribue l'heure d'exécution planifiée au formatyyyymmddhh24miss.var3=${yyyymmdd}: Attribue l'horodatage des données au formatyyyymmdd.var4=$[yyyymmddhh24miss]: Attribue l'heure d'exécution planifiée au formatyyyymmddhh24miss.var5=Hangzhou: Attribue la constanteHangzhouàvar5.
-
Facultatif : Configurez l'heure de planification.
Configurez le nœud ODPS SQL pour qu'il s'exécute toutes les heures (Zone 3).
RemarqueVous pouvez choisir ou non de configurer une planification basée sur le temps en fonction de vos besoins. Cet exemple montre comment configurer une planification horaire.
Heure de début :
16:00Heure de fin :
23:59Intervalle :
1heure
Pour plus d'informations sur la configuration des planifications basées sur le temps, consultez Configurer les propriétés temporelles.
-
Définissez la dépendance de planification.
Configurez une dépendance de planification pour le nœud. Pour plus d'informations, consultez Configurer les dépendances de planification. Dans cet exemple, le nœud racine sert de dépendance amont pour ce nœud.
-
Dans la barre d'outils supérieure de la page de l'éditeur de nœud, cliquez sur l'icône

puis sur l'icône 
pour enregistrer et valider la configuration du nœud ODPS SQL.-
Effectuez un test de fumée dans l'environnement de développement.
-
Cliquez sur l'icône

. Dans la boîte de dialogue Smoke Testing in Development Environment, configurez l'horodatage des données pour simuler la planification du nœud.L'horodatage des données est configuré comme suit :
Horodatage des données :
2025-10-16Heure de début :
16:00Heure de fin :
17:00
Étant donné que la tâche ODPS SQL est planifiée pour s'exécuter toutes les heures, elle générera deux instances à
16:00et17:00le2025-10-17.RemarqueL'horodatage des données correspond généralement à la veille de l'exécution. Par conséquent, l'heure d'exécution réelle de la tâche est le
2025-10-17.Les valeurs attendues pour l'instance de
16:00sont :var1=20251016var2=20251017160000var3=20251016var4=20251017160000
Les valeurs attendues pour l'instance de
17:00sont :var1=20251016var2=20251017170000var3=20251016var4=20251017170000
Cliquez sur OK. Le nœud commence à s'exécuter aux heures spécifiées.
-
Une fois l'exécution terminée, cliquez sur l'icône

pour afficher les journaux du test de fumée.Les deux instances générées pour le nœud s'exécutent avec succès et les résultats sont conformes aux attentes.
La fenêtre Afficher les enregistrements du test de fumée affiche deux enregistrements d'instance avec un horodatage de données de
2025-10-16et tous deux dans l'état Réussi. Cliquez sur Afficher le journal pour consulter les journaux d'exécution détaillés.Dans le journal d'exécution de l'instance de
16:00, les résultats de remplacement des paramètres sontvar1=20251016 var2=20251017160000 var3=20251016 var4=20251017160000 var5=Hangzhou, ce qui est conforme aux attentes.Dans le journal d'exécution de l'instance de
17:00, les résultats de remplacement des paramètres sontvar1=20251016 var2=20251017170000 var3=20251016 var4=20251017170000 var5=Hangzhou, ce qui est également conforme aux attentes.
-
Si votre espace de travail est en mode standard, vous devez déployer le nœud dans l'environnement de production. Sur la page de l'éditeur de nœud ODPS SQL, cliquez sur Deploy dans le coin supérieur droit pour déployer le nœud. Pour plus d'informations, consultez Déployer une tâche.
-
Accédez à Operation Center pour confirmer la configuration des paramètres de planification du nœud.
Dans la barre de menu supérieure de DataStudio, cliquez sur Operation Center dans le coin supérieur droit.
-
Sur la page , recherchez le nœud cible.
RemarqueVous ne pouvez trouver le nœud sur cette page qu'après son déploiement réussi.
-
Cliquez sur le nom du nœud cible et affichez les Execution Parameters dans le panneau Attribute.
Dans cet exemple, les paramètres d'exécution du nœud sont
var1=$bizdate var2=$cyctime var3=${yyyymmdd} var4=$[yyyymmddhh24miss]. -
Observez le remplacement réel des paramètres dans une instance en cours d'exécution. Une fois qu'une instance planifiée est générée, accédez à la page Auto Triggered Instances, recherchez le nom de la tâche, cliquez sur le nom de l'instance et affichez les Execution Parameters dans le panneau Attribute.
Dans cet exemple, les paramètres d'exécution sont résolus comme suit :
var1=20251016 var2=20251017160000 var3=20251016 var4=20251017160000.