La plupart des types de nœuds, y compris les nœuds SQL et les nœuds de synchronisation par lots, utilisent la même méthode pour définir et référencer les paramètres de planification. Deux types de nœuds fonctionnent différemment : les nœuds PyODPS récupèrent les paramètres via un objet dictionnaire au lieu d'un remplacement de chaîne, et les nœuds Shell généraux utilisent des variables positionnelles plutôt que nommées. Cette rubrique fournit des exemples de configuration pour chaque type de nœud.
Nœuds SQL et nœuds de synchronisation par lots
Les nœuds SQL (tels que ODPS SQL) et les nœuds de synchronisation par lots utilisent la même méthode pour configurer les paramètres de planification. Cette méthode s'applique également à la plupart des autres types de nœuds. Cette rubrique utilise un nœud ODPS SQL comme exemple pour montrer comment attribuer des valeurs aux variables intégrées et aux paramètres personnalisés, puis les référencer dans le code.
Certains nœuds peuvent ne pas prendre en charge les paramètres de planification. Pour savoir si un type de nœud spécifique prend en charge les paramètres de planification, consultez la documentation correspondante.
Attribuez des valeurs aux paramètres dans la zone d'affectation des paramètres, puis référencez les variables intégrées var1 et var3, les paramètres personnalisés var2 et var4, ainsi que la constante var5 dans la zone de code. Les exemples suivants illustrent ces affectations :
Attribuez la date métier à la variable intégrée var1 :
var1=$bizdateAttribuez l'heure planifiée à la variable intégrée var3 :
var3=$cyctimeAttribuez la date métier au paramètre personnalisé var2 :
var2=${yyyymmdd}Attribuez l'heure planifiée au paramètre personnalisé var4 :
var4=$[yyyymmddhh24:mi:ss]Attribuez la constante abc à var5 :
var5=abc
Pour obtenir une heure relative basée sur l'heure planifiée (par exemple, l'heure précédente ou il y a N minutes), appliquez des calculs de décalage au paramètre d'heure planifiée ($[...]) : utilisez N/24 pour les décalages horaires et N/24/60 pour les décalages en minutes, où N représente le nombre d'heures ou de minutes de décalage. Les décalages horaires et en minutes sont pris en charge uniquement pour l'heure planifiée. La date métier (${...}) ne prend pas en charge ces décalages. Les exemples suivants illustrent l'obtention de l'heure précédente :
Obtenez l'heure précédente de l'heure planifiée (horodatage complet au format yyyymmddhh24miss) :
$[yyyymmddhh24miss-1/24]Obtenez uniquement l'heure précédente (format 24 heures) :
$[hh24-1/24]Obtenez l'heure, la minute et la seconde de l'heure précédente :
$[hh24miss-1/24]Obtenez la date au format yyyymmdd pour l'heure précédente :
$[yyyymmdd-1/24]Obtenez la date du jour précédent et de l'heure précédente :
$[yyyymmdd-1-1/24]Obtenez l'heure planifiée moins 15 minutes :
$[yyyymmddhh24miss-15/24/60]
Les calculs de décalage horaire et en minutes peuvent entraîner des changements de jour. Pour la liste complète des formats d'affectation pris en charge et des informations sur la gestion des changements de jour, consultez Formats de paramètres de planification pris en charge.
Nœuds PyODPS
Pour prévenir l'injection de code, les nœuds PyODPS ne prennent pas en charge la définition de variables utilisant directement la syntaxe de remplacement de chaîne ${param_name} dans le code. Avant d'exécuter le code, récupérez les paramètres de planification depuis la variable globale args, qui est de type dict (objet dictionnaire). La méthode d'affectation des paramètres est identique à celle des autres types de nœuds.
Dans l'éditeur de code d'un nœud PyODPS, utilisez le dictionnaire args pour référencer les paramètres de planification (tels que args['var1'], args['var2'] et args['var3']), et utilisez print pour afficher les valeurs des paramètres. Dans le panneau Scheduling Configuration situé à droite, attribuez des valeurs à ces paramètres dans la section Scheduling Parameters.
Attribuez des valeurs aux paramètres dans la zone d'affectation des paramètres, puis référencez le paramètre intégré var1 et les paramètres personnalisés var2 et var3 dans la zone de code. Après l'ajout de l'objet dictionnaire, les paramètres deviennent args['var1'], args['var2'] et args['var3']. Les exemples suivants illustrent ces affectations :
Attribuez la date métier au paramètre intégré var1 :
var1=$bizdateAttribuez la date métier au paramètre personnalisé var2 :
var2=${yyyymmdd}Attribuez la date métier au paramètre personnalisé var3 :
var3=$[yyyymmdd]
Exemple de configuration pour un nœud Shell général
Les variables des nœuds Shell généraux ne peuvent pas avoir de noms personnalisés. Elles doivent être nommées $1, $2, $3, etc. (numérotées séquentiellement par ordre croissant). Lorsque le nombre de paramètres dépasse 10, utilisez la syntaxe ${10} pour déclarer la variable.
Pour le 10e paramètre et les suivants dans un nœud Shell, utilisez le format ${10} pour les référencer (par exemple, echo ${10}).
Attribuez des valeurs aux paramètres dans la zone d'affectation des paramètres, puis référencez le paramètre intégré $1 et les paramètres personnalisés $2 et $3 dans la zone de code. Les exemples suivants illustrent ces affectations :
Les nœuds Shell généraux prennent uniquement en charge l'affectation de paramètres basée sur des expressions. Séparez plusieurs affectations de paramètres par des espaces. Les valeurs correspondent aux paramètres dans l'ordre de leur définition. Par exemple, le premier paramètre défini dans le nœud Shell est $1, donc la première valeur dans la zone d'affectation des paramètres ($bizdate) est attribuée à $1.
Attribuez la date métier au paramètre intégré $1 :
$bizdateAttribuez la date métier au paramètre personnalisé $2 :
${yyyymmdd}Attribuez l'heure planifiée au paramètre personnalisé $3 :
$[yyyymmdd]
Pour plus de formats d'affectation pris en charge pour les paramètres de planification, consultez Formats de paramètres de planification pris en charge. Pour le workflow complet de configuration et d'utilisation des paramètres de planification, consultez Configurer et utiliser les paramètres de planification.
Exemple de synchronisation par lots
Pour des scénarios typiques d'utilisation des paramètres de planification dans Data Integration, consultez Utiliser les paramètres de planification dans les tâches de synchronisation par lots.