Platform For AI:Variáveis globais

Procedimento

1. Configure uma variável global.

   Abra um pipeline existente, clique em uma área em branco da tela e crie uma variável global no painel à direita.

   Para referenciar uma variável global, use o formato ${variable_name}. O nome da variável deve ter entre 1 e 20 caracteres, começar com uma letra e conter apenas letras, sublinhados e números. Ao usar uma variável global para agendamento offline, defina um parâmetro de agendamento com o mesmo nome no DataWorks. O valor configurado no PAI Designer aplica-se apenas a execuções de experimentos online.

2. No campo de parâmetro onde deseja usar a variável global, insira ${variable_name}.

Exemplo 1: Pipeline online

Este exemplo demonstra como definir uma variável global para1 para renomear a coluna da tabela status para ifHealth e referenciá-la em um script SQL.

1. Crie um pipeline.

   Após criar o pipeline, mantenha apenas os dois primeiros nós e exclua os demais.

2. Clique em uma área em branco da tela e crie uma variável global no painel à direita.

   Defina o nome da variável global como para1 e seu valor como ifHealth.

3. Utilize a variável global.

   Modifique o componente SQL Script para referenciar a variável usando ${para1}.

   No editor SQL do componente SQL Script-1, use ${para1} como alias da coluna de saída ao final da instrução SELECT. Na cláusula FROM, utilize ${t1} para referenciar a source de entrada do componente Read Table-1. Além disso, marque a caixa de seleção Automatically add CREATE TABLE statement. Quando essa opção estiver selecionada, a última instrução deve ser obrigatoriamente um SELECT.

4. Execute o pipeline.

   Após a conclusão da execução, clique com o botão direito no componente SQL Script e selecione View Data > Output of SQL Script. O nome da coluna status será alterado para ifHealth.

Exemplo 2: Agendamento offline do DataWorks

Neste cenário, a variável global gDate filtra dados de uma data específica no pipeline. Em seguida, configura-se um parâmetro de agendamento correspondente no DataWorks para executar o pipeline como um job agendado.

1. Crie uma tabela de dados de teste.

   Neste exemplo, crie uma tabela chamada dwtest no console do MaxCompute. Para mais informações, consulte SQL Reference.

   A tabela dwtest possui quatro colunas: t1 (numérica, valores de exemplo: 1.0, 0.0, 1.2, 0.1), t2 (numérica, valores de exemplo: 1.1, 1.0, 0.0, 0.1), label (string, valores de exemplo: A, B, C, D, E, F) e ds (partição de data, valores de exemplo: 20190519, 20190520). A tabela contém 10 linhas de dados de teste.

2. Crie um pipeline e configure uma variável global.

   1. Clique em uma área em branco da tela e crie uma variável global chamada gDate no painel à direita.

      Defina o valor da variável como 20190520.

   2. Configure os componentes do pipeline.

      

      • Read Table: Defina Table Name como a tabela dwtest.

      • SQL Script: Utilize a variável global gDate na consulta.

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

3. Execute o pipeline.

   Após a conclusão da execução, clique com o botão direito no componente SQL Script e selecione View Data > Output of SQL Script. Os dados de saída serão filtrados com base no valor da variável global gDate.

   Nos resultados da consulta, o valor na coluna ds é 20190520, correspondendo ao valor da variável global gDate. Isso confirma que a variável global foi transmitida com sucesso.

4. No canto superior esquerdo da tela, clique em Periodic Scheduling e, em seguida, clique em Create Scheduling Node. Você será redirecionado para o DataWorks para configurar o agendamento offline. Na caixa de diálogo Create Node, especifique um nome para o nó e clique em Confirm.

5. Selecione o experimento do PAI Designer e clique em Properties no painel à direita. Para mais detalhes sobre a configuração, consulte node scheduling configuration.

   Para este exemplo, configure os seguintes parâmetros e mantenha os demais com as definições padrão:

   • Scheduling Parameters: Adicione um parâmetro de agendamento chamado gDate e defina seu valor como $bizdate.

   • Schedule: Na propriedade de reexecução, especifique que o nó pode ser reexecutado independentemente do resultado da execução anterior.

   • Dependencies: Defina a dependência upstream como o nó raiz do workspace.

6. Clique nos ícones e na barra de ferramentas. Siga as instruções na tela para salvar e enviar o nó.

7. Na parte superior da página, clique em Operation Center para visualizar o status de execução e os logs operacionais da tarefa.

   Também é possível realizar backfill de dados e executar pipelines de teste. Para mais informações, consulte gerencie tarefas acionadas automaticamente.

Documentos relacionados

• Crie um Pipeline

• node scheduling configuration

• gerencie tarefas acionadas automaticamente