Cette rubrique décrit les variables utilisées dans l'orchestration des tâches.
Présentation des variables
Les variables sont des valeurs dynamiques au sein d'un flux de tâches. Elles se répartissent en trois catégories : les variables système, les variables temporelles et les variables non temporelles. Référez n'importe quelle variable depuis un nœud à l'aide de la syntaxe ${varName}.
Variables système
Les variables système correspondent à des valeurs prédéfinies, telles que l'identifiant du flux de tâches actuel ou l'heure d'exécution de ce dernier.
Si une variable personnalisée porte le même nom qu'une variable système, sa valeur remplace celle de la variable système. La variable personnalisée est donc prioritaire.
Variables temporelles
-
Variable de flux de tâches (variable globale) : cette variable est calculée en appliquant un décalage temporel à l'horodatage des données. Par défaut, l'horodatage des données correspond à l'heure d'exécution moins un jour. En tant que variable globale, elle est accessible à tous les nœuds du flux de tâches actuel.
RemarqueConfigurez une variable de flux de tâches sur n'importe quel nœud. La configuration est automatiquement synchronisée avec tous les autres nœuds.
-
Variable de nœud : il s'agit d'une variable temporelle créée en appliquant un décalage temporel à la variable intégrée
bizdate(J-1). Sa portée est limitée au nœud dans lequel elle est définie.Par exemple, si la date actuelle est le 22 août 2023 et que vous appliquez un décalage de +1 jour, la valeur de la variable devient le 23 août 2023.
Variables non temporelles
Constante de flux de tâches (variable globale) : il s'agit d'une valeur fixe utilisable dans tous les nœuds du flux de tâches actuel.
-
Variable d'entrée : le système renseigne automatiquement ces variables. Référez-les dans les instructions SQL du nœud actuel via la syntaxe ${var_name} ou utilisez-les comme variables conditionnelles dans un nœud de branche conditionnelle. Les variables d'entrée incluent :
Variable amont : variable de sortie provenant d'un nœud amont.
Variable d'état : pour plus d'informations, consultez Variables d'état.
Variable système : pour plus d'informations, consultez Variables système.
-
Variable de sortie : définissez et assignez une valeur à cette variable directement sur le nœud actuel. Les nœuds aval peuvent ensuite y accéder et la référencer.
Par exemple, si vous configurez une variable de sortie dans un nœud Script, elle pourra être référencée dans les instructions SQL d'un nœud aval.
Variable de sortie d'un nœud SQL à instance unique : utilisez ce type de nœud pour définir un ensemble de résultats issu d'une requête SQL. Cet ensemble forme une matrice bidimensionnelle. Lors de la définition de la variable, extrayez un élément unique ou concaténez toutes les valeurs d'une ligne ou d'une colonne.
-
Variable de sortie de script : si la dernière ligne de la sortie d'un script est un objet JSON au format
{ key1: value1, key2: value2, … }dont les valeurs sont de type String, la tâche de script analyse automatiquement les paires clé-valeur JSON. Une variable nommée key est alors créée, et sa valeur correspond à la valeur associée. Référez cette variable sous la forme${key}.Par exemple, si la dernière ligne du script est
echo {"hello": "world"}, la tâche de script crée une variable nommée hello dont la valeur est world.
Configurer les variables temporelles
|
Paramètre |
Description |
|
Variable name |
Saisissez le nom de la variable personnalisée. Remarque
Pour supprimer une variable configurée, cliquez sur l'icône |
|
Variable rule |
Configurez les règles applicables à la variable temporelle.
Remarque
Une fois la variable temporelle configurée, référez-la dans les instructions SQL via la syntaxe |
.Formats temporels
Le tableau ci-dessous répertorie les spécificateurs de format temporel pris en charge.
|
Spécificateur |
Description |
Exemple d'entrée |
Exemple de sortie |
|
Ère |
|
Gyyyy |
AD 2021 |
|
Année |
|
yyyy |
2021 |
|
Mois |
|
MM |
08 |
|
Semaine |
|
ww |
13 |
|
Jour |
|
D |
360 |
|
Jour de la semaine |
|
e |
1 |
|
AM/PM |
|
a |
AM |
|
Heure |
|
HH |
10 |
|
Minute |
|
m |
27 |
|
Seconde |
|
ss |
08 |
|
Fuseau horaire |
|
z |
UTC+08:00 |
Exemples de formats temporels combinés :
|
Exemple d'entrée |
Exemple de sortie |
|
|
2021-08-12 |
|
|
20210801 |
|
|
11:05:21 |
|
|
20210812 11:05:21 |
Variables système
|
Nom de la variable |
Description |
Exemple |
|
sys.flow.start.timestamp |
L'horodatage de l'heure d'exécution. |
2021-05-24T11:20:07.562+08:00 |
|
sys.flow.start.year |
L'année de l'heure d'exécution. |
2021 |
|
sys.flow.start.month |
Le mois de l'heure d'exécution. |
5 |
|
sys.flow.start.day |
Le jour de l'heure d'exécution. |
24 |
|
sys.flow.start.hour |
L'heure de l'heure d'exécution. |
11 |
|
sys.flow.start.minute |
La minute de l'heure d'exécution. |
20 |
|
sys.flow.start.second |
La seconde de l'heure d'exécution. |
7 |
|
sys.flow.start.milliseconds |
Les millisecondes de l'heure d'exécution. |
562 |
|
sys.flow.start.timezone |
Le fuseau horaire de l'heure d'exécution. |
Asia/Shanghai |
|
sys.flow.biztime |
L'horodatage des données. Par défaut, il correspond à l'heure d'exécution moins un jour. |
1621740007562 |
|
sys.flow.name |
Le nom du flux de tâches. |
dwd_activity_daily_pv |
|
sys.node.name |
Le nom du nœud. |
Single Instance SQL-1 |
Variables d'état
|
Nom de la variable |
Description |
|
all_success |
Toutes les tâches amont ont été exécutées avec succès. |
|
all_failed |
Toutes les tâches amont ont échoué. |
|
one_success |
Au moins une tâche amont a été exécutée avec succès. |
|
one_failed |
Au moins une tâche amont a échoué. |
Utilisez les variables d'état dans un nœud de branche conditionnelle pour contrôler l'exécution des tâches suivantes en fonction d'un statut d'exécution spécifique.