Platform For AI:Variables globales

Procédure

1. Configurez une variable globale.

   Ouvrez un pipeline existant, cliquez sur une zone vide du canevas, puis créez une variable globale dans le volet de droite.

   Pour référencer une variable globale, utilisez le format ${nom_variable}. Le nom de la variable doit comporter entre 1 et 20 caractères, commencer par une lettre et contenir uniquement des lettres, des traits de soulignement et des chiffres. Pour utiliser une variable globale dans la planification hors ligne, vous devez définir un paramètre de planification portant le même nom dans DataWorks. La valeur configurée dans PAI Designer s'applique uniquement aux exécutions d'expériences en ligne.

2. Dans le champ de paramètre où vous souhaitez utiliser la variable globale, saisissez ${nom_variable}.

Exemple 1 : Pipeline en ligne

Cet exemple montre comment définir une variable globale para1 pour renommer la colonne de table status en ifHealth et la référencer dans un script SQL.

1. Créer un pipeline.

   Après avoir créé le pipeline, conservez uniquement les deux premiers nœuds et supprimez les autres.

2. Cliquez sur une zone vide du canevas et créez une variable globale dans le volet de droite.

   Définissez le nom de la variable globale sur para1 et sa valeur sur ifHealth.

3. Utilisez la variable globale.

   Modifiez le composant SQL Script pour référencer la variable à l'aide de ${para1}.

   Dans l'éditeur SQL du composant SQL Script-1, utilisez ${para1} comme alias de colonne de sortie à la fin de l'instruction SELECT. Dans la clause FROM, utilisez ${t1} pour référencer la source d'entrée du composant Read Table-1. Cochez également la case Automatically add CREATE TABLE statement. Lorsque cette option est sélectionnée, la dernière instruction doit être une instruction SELECT.

4. Exécutez le pipeline.

   Une fois l'exécution terminée, cliquez avec le bouton droit sur le composant SQL Script et sélectionnez View Data > Output of SQL Script. Le nom de la colonne status devient ifHealth.

Exemple 2 : Planification hors ligne DataWorks

Cet exemple montre comment utiliser la variable globale gDate pour filtrer les données d'une date spécifique dans un pipeline. Vous configurez ensuite un paramètre de planification correspondant dans DataWorks pour exécuter le pipeline en tant que tâche planifiée.

1. Créez une table de données de test.

   Dans cet exemple, créez une table nommée dwtest dans la console MaxCompute. Pour plus d'informations, consultez la rubrique Référence SQL.

   La table dwtest comporte quatre colonnes : t1 (numérique, exemples de valeurs : 1,0, 0,0, 1,2, 0,1), t2 (numérique, exemples de valeurs : 1,1, 1,0, 0,0, 0,1), label (chaîne, exemples de valeurs : A, B, C, D, E, F) et ds (partition de date, exemples de valeurs : 20190519, 20190520). La table contient 10 lignes de données de test.

2. Créer un pipeline et configurer une variable globale.

   1. Cliquez sur une zone vide du canevas et créez une variable globale nommée gDate dans le volet de droite.

      Définissez la valeur de la variable sur 20190520.

   2. Configurez les composants du pipeline.

      

      • Read Table : définissez Table Name sur la table dwtest.

      • SQL Script : utilisez la variable globale gDate dans la requête.

        select * from ${t1} where ds=${gDate}

3. Exécutez le pipeline.

   Une fois l'exécution terminée, cliquez avec le bouton droit sur le composant SQL Script et sélectionnez View Data > Output of SQL Script. Les données de sortie sont filtrées en fonction de la valeur de la variable globale gDate.

   Dans les résultats de la requête, la valeur de la colonne ds est 20190520, ce qui correspond à la valeur de la variable globale gDate. Cela confirme que la variable globale a bien été transmise.

4. Dans le coin supérieur gauche du canevas, cliquez sur Periodic Scheduling puis sur Create Scheduling Node. Vous êtes redirigé vers DataWorks pour configurer la planification hors ligne. Dans la boîte de dialogue Create Node, spécifiez un nom de nœud et cliquez sur Confirm.

5. Sélectionnez l'expérience PAI Designer, puis cliquez sur Properties dans le volet de droite. Pour plus d'informations sur la configuration, consultez la rubrique configuration de la planification des nœuds.

   Pour cet exemple, configurez les paramètres suivants et laissez les autres paramètres avec leurs valeurs par défaut :

   • Scheduling Parameters : ajoutez un paramètre de planification nommé gDate et définissez sa valeur sur $bizdate.

   • Schedule : pour la propriété de réexécution, spécifiez que le nœud peut être réexécuté quel que soit le résultat de l'exécution précédente.

   • Dependencies : définissez la dépendance amont sur le nœud racine de l'espace de travail.

6. Cliquez sur les icônes et dans la barre d'outils. Suivez les instructions à l'écran pour enregistrer et soumettre le nœud.

7. En haut de la page, cliquez sur Operation Center pour afficher l'état d'exécution et les journaux d'opération de la tâche.

   Vous pouvez également remplir les données historiques et exécuter des pipelines d'essai. Pour plus d'informations, consultez la rubrique gérer les tâches déclenchées automatiquement.

Documents connexes

• Créer un pipeline

• configuration de la planification des nœuds

• gérer les tâches déclenchées automatiquement