DataWorks:Assignment node

Étape 1 : Configurer le nœud d'assignation

1. Connectez-vous à la console DataWorks. Dans le volet de navigation de gauche, cliquez sur Data Development & O&M > Data Development.

2. Dans votre flux de travail, créez et ouvrez un nœud d'assignation. Sur la page de configuration, sélectionnez ODPS SQL comme langage et rédigez votre requête.

   select * from xc_dpe_e2.xc_rpt_user_info_d where dt='20191008' limit 10;

3. (Facultatif) Cliquez sur Properties dans le volet droit et sélectionnez l'onglet Input and Output Parameters pour confirmer que DataWorks a automatiquement créé un paramètre de sortie nommé outputs.

Étape 2 : Configurer le nœud Shell

1. Créez un nœud Shell. Dans le canevas du flux de travail, faites glisser une connexion du nœud d'assignation vers le nœud Shell pour le définir comme nœud en aval.

2. Sur la page de configuration du nœud Shell, cliquez sur Properties dans le volet droit et sélectionnez l'onglet Input and Output Parameters.

3. Dans la section Input Parameters, cliquez sur Create.

4. Dans la boîte de dialogue, sélectionnez le paramètre outputs du nœud d'assignation et définissez un nom pour le paramètre d'entrée du nœud actuel, par exemple param.

   Cette étape crée une dépendance entre le nœud Shell et le nœud d'assignation.

5. Référencez la valeur dans le script du nœud Shell à l'aide de la syntaxe ${param} :

   ${param} , ${param[0]} et ${param[0][1]} utilisent la syntaxe des variables DataWorks, et non le Shell standard. DataWorks remplace statiquement ces espaces réservés par des valeurs réelles avant de soumettre le script pour exécution.

   echo '${param}';
   echo 'First row: '${param[0]};
   echo 'Second field of the first row: '${param[0][1]};

Étape 3 : Exécuter et vérifier

Ouvrez le flux métier et cliquez sur Run dans la barre d'outils pour exécuter le flux de travail. La sortie attendue est similaire à ce qui suit :

Full result set: value1,value2
value3,value4
First row: value1,value2
Second field of the first row: value2

Pour effectuer un test dans un environnement planifié, validez le nœud dans l'environnement de développement, accédez à Operation Center et utilisez le remplissage des données pour valider l'exécution.

Transmettre un résultat ODPS SQL

Le résultat d'une instruction SQL SELECT est transmis sous forme de tableau bidimensionnel.

Nœud d'assignation

select * from xc_dpe_e2.xc_rpt_user_info_d where dt='20191008' limit 2;

Nœud Shell (paramètre d'entrée param mappé sur outputs)

# Full 2D array
echo "Full result set: ${param}"

# First row (1D array)
echo "First row: ${param[0]}"

# Second field of the first row
echo "Second field of the first row: ${param[0][1]}"

Sortie attendue

Full result set: value1,value2
value3,value4
First row: value1,value2
Second field of the first row: value2

Transmettre une sortie Python 2

La sortie de la dernière instruction print est divisée par des virgules et transmise sous forme de tableau unidimensionnel.

Nœud d'assignation

print "hello,dataworks";

Nœud Shell (paramètre d'entrée param mappé sur outputs)

# Full 1D array
echo "Full result set: ${param}"

# Elements by index
echo "First element: ${param[0]}"
echo "Second element: ${param[1]}"

Sortie attendue

Full result set: "hello","dataworks"
First element: hello
Second element: dataworks

Transmettre une sortie Shell

La sortie de la dernière instruction echo est divisée par des virgules et transmise sous forme de tableau unidimensionnel.

Nœud d'assignation

echo "hello,dataworks";

Nœud Shell (paramètre d'entrée param mappé sur outputs)

# Full 1D array
echo "Full result set: ${param}"

# Elements by index
echo "First element: ${param[0]}"
echo "Second element: ${param[1]}"

Sortie attendue

Full result set: "hello","dataworks"
First element: hello
Second element: dataworks