Platform For AI:Variables globales

Procedimiento

1. Configure una variable global.

   Abra un pipeline existente, haga clic en un área en blanco del lienzo y luego cree una variable global en el panel derecho.

   Para hacer referencia a una variable global, use el formato ${variable_name}. El nombre de la variable debe tener entre 1 y 20 caracteres, comenzar con una letra y contener únicamente letras, guiones bajos y números. Cuando utilice una variable global para programación sin conexión, deberá definir un parámetro de programación con el mismo nombre en DataWorks. El valor que configure en PAI Designer solo aplica a las ejecuciones de experimentos en línea.

2. En el campo de parámetro donde desee usar la variable global, introduzca ${variable_name}.

Ejemplo 1: pipeline en línea

Este ejemplo muestra cómo establecer la variable global para1 para cambiar el nombre de la columna de tabla status a ifHealth y hacer referencia a ella en un script SQL.

1. Create a pipeline.

   Después de crear el pipeline, conserve únicamente los dos primeros nodos y elimine los demás.

2. Haga clic en un área en blanco del lienzo y cree una variable global en el panel derecho.

   Establezca el nombre de la variable global como para1 y su valor como ifHealth.

3. Use la variable global.

   Modifique el componente SQL Script para hacer referencia a la variable mediante ${para1}.

   En el editor SQL del componente SQL Script-1, use ${para1} como alias de la columna de salida al final de la instrucción SELECT. En la cláusula FROM, use ${t1} para hacer referencia al origen de entrada del componente Read Table-1. Además, seleccione la casilla de verificación Automatically add CREATE TABLE statement. Cuando esta opción está seleccionada, la última instrucción debe ser una instrucción SELECT.

4. Ejecute el pipeline.

   Una vez finalizada la ejecución, haga clic con el botón secundario en el componente SQL Script y seleccione View Data > Output of SQL Script. El nombre de la columna status cambia a ifHealth.

Ejemplo 2: programación sin conexión de DataWorks

Este ejemplo muestra cómo usar la variable global gDate para filtrar datos de una fecha específica en un pipeline. A continuación, se configura un parámetro de programación equivalente en DataWorks para ejecutar el pipeline como un trabajo programado.

1. Cree una tabla de datos de prueba.

   En este ejemplo, cree una tabla llamada dwtest en la consola de MaxCompute. Para obtener más información, consulte SQL Reference.

   La tabla dwtest tiene cuatro columnas: t1 (numérica, valores de ejemplo: 1.0, 0.0, 1.2, 0.1), t2 (numérica, valores de ejemplo: 1.1, 1.0, 0.0, 0.1), label (cadena, valores de ejemplo: A, B, C, D, E, F) y ds (partición de fecha, valores de ejemplo: 20190519, 20190520). La tabla contiene 10 filas de datos de prueba.

2. Create a pipeline y configure una variable global.

   1. Haga clic en un área en blanco del lienzo y cree una variable global llamada gDate en el panel derecho.

      Establezca el valor de la variable como 20190520.

   2. Configure los componentes del pipeline.

      

      • Read Table: establezca Table Name como la tabla dwtest.

      • SQL Script: use la variable global gDate en la consulta.

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

3. Ejecute el pipeline.

   Una vez finalizada la ejecución, haga clic con el botón secundario en el componente SQL Script y seleccione View Data > Output of SQL Script. Los datos de salida se filtran según el valor de la variable global gDate.

   En los resultados de la consulta, el valor de la columna ds es 20190520, que coincide con el valor de la variable global gDate. Esto confirma que la variable global se pasó correctamente.

4. En la esquina superior izquierda del lienzo, haga clic en Periodic Scheduling y luego en Create Scheduling Node. Esta acción lo redirige a DataWorks para configurar la programación sin conexión. En el cuadro de diálogo Create Node, especifique un nombre de nodo y haga clic en Confirm.

5. Seleccione el experimento de PAI Designer y luego haga clic en Properties en el panel derecho. Para obtener más información sobre la configuración, consulte node scheduling configuration.

   Para este ejemplo, configure los siguientes parámetros y deje los demás con sus valores predeterminados:

   • Scheduling Parameters: agregue un parámetro de programación llamado gDate y establezca su valor como $bizdate.

   • Schedule: para la propiedad de reejecución, especifique que el nodo pueda volver a ejecutarse sin importar el resultado de la ejecución anterior.

   • Dependencies: establezca la dependencia ascendente como el nodo raíz del espacio de trabajo.

6. Haga clic en los íconos y de la barra de herramientas. Siga las instrucciones en pantalla para guardar y enviar el nodo.

7. En la parte superior de la página, haga clic en Operation Center para consultar el estado de ejecución y los registros de operación de la tarea.

   También puede rellenar datos y ejecutar pipelines de prueba. Para obtener más información, consulte manage auto-triggered tasks.

Documentos relacionados

• Create a Pipeline

• node scheduling configuration

• manage auto-triggered tasks