No DataWorks, use um nó do AnalyticDB for PostgreSQL para desenvolver tarefas, agendar execuções periódicas e integrá-las a outros tipos de tarefa. Este tópico mostra como desenvolver uma tarefa com esse tipo de nó.
Pré-requisitos
Você vinculou um mecanismo de computação MaxCompute ao workspace do DataWorks.
Um recurso de computação do AnalyticDB for PostgreSQL foi associado ao workspace.
Crie um diretório de projeto. Para mais informações, consulte Diretório do projeto.
Crie um nó do AnalyticDB for PostgreSQL. Para mais detalhes, consulte Criar um nó para um fluxo de trabalho de agendamento.
Contexto
O nó do AnalyticDB for PostgreSQL conecta-se ao Alibaba Cloud AnalyticDB for PostgreSQL. Para mais informações, consulte AnalyticDB for PostgreSQL.
Procedimento
-
Na página de edição do nó do AnalyticDB for PostgreSQL, siga as etapas abaixo para desenvolver a tarefa.
Desenvolver código SQL
Escreva o código da tarefa no editor SQL. Defina variáveis no código usando o formato ${variable_name}. Em seguida, atribua valores a essas variáveis na seção Scheduling Parameters do painel Scheduling Settings, à direita. Assim, você passa parâmetros dinamicamente ao código durante as execuções agendadas. Para saber mais sobre parâmetros de agendamento, consulte Fontes e expressões de parâmetros de agendamento. Exemplo:
CREATE TABLE employees ( id INT PRIMARY KEY, name VARCHAR(100), age INT, department VARCHAR(50) ); INSERT INTO employees (id, name, age, ${var}) VALUES (1, 'Alice', 30, 'HR'), (2, 'Bob', 25, 'Engineering'), (3, 'Charlie', 35, 'Marketing');
NotaNo exemplo, defina o parâmetro ${var} como a coluna
department.O editor de código do nó do AnalyticDB for PostgreSQL aceita a sintaxe padrão do PostgreSQL. Para mais detalhes, consulte Sintaxe SQL.
Executar a tarefa SQL
-
Na seção Debug Configuration, configure Compute Resource e Resource Group.
Em Computing resource, selecione o nome do recurso de computação do AnalyticDB for PostgreSQL registrado no DataWorks.
Em Resource Group, selecione um grupo de recursos de agendamento aprovado no teste de conectividade com o recurso de computação. Para mais informações, consulte Conectividade de rede.
Na barra de ferramentas, clique em na lista suspensa Select a data source, selecione o recurso de computação do AnalyticDB for PostgreSQL criado na caixa de diálogo e clique em Run para executar a tarefa SQL.
Para executar a tarefa do nó regularmente, configure as definições de agendamento conforme suas necessidades de negócio. Para mais informações, consulte Configurar definições de agendamento.
Após configurar a tarefa, implante o nó. Para mais informações, consulte Implantar um nó.
Após a implantação, visualize o status de execução da tarefa agendada no Operation Center. Para mais informações, consulte Visualizar tarefas agendadas.