Em fluxos de trabalho de dados, o código da tarefa (como SQL) frequentemente precisa mudar dinamicamente conforme o horário de agendamento para processar diferentes partições. Para evitar modificações manuais no código, use parâmetros de agendamento. Ao definir placeholders no código, o sistema os substitui automaticamente por valores dinâmicos, como o timestamp de dados e o horário de agendamento, durante a execução da tarefa. Isso permite uma execução automatizada e parametrizada do fluxo de trabalho.
Processo principal de configuração
Para usar parâmetros de agendamento, defina-os e atribua valores a eles no painel Scheduling. Após o código passar pelos testes no DataStudio, envie-o para o Operation Center. O sistema agenda a tarefa automaticamente e substitui os valores dos parâmetros dinamicamente conforme a lógica de atribuição definida.
|
Etapa |
Ação |
Objetivo |
|
1. Definir um parâmetro |
No código do nó, defina um ou mais parâmetros usando o formato |
Reservar um placeholder para um valor dinâmico. |
|
2. Configure o parâmetro |
No painel do nó, atribua um valor à variável presente no código. |
Associar o placeholder |
|
3. Testar |
Use o recurso Perform Smoke Testing para simular um timestamp de dados específico e verifique se o parâmetro foi substituído e se o código executa corretamente. |
Garantir que a configuração esteja correta no ambiente de desenvolvimento. |
|
4. Implantar e verificar |
Implante o nó no ambiente de produção e confirme a configuração final dos parâmetros no Operation Center. |
Assegurar que os parâmetros da tarefa de produção funcionem conforme o esperado. |
Procedimento
1. Definir parâmetros
Clique em duas vezes no nó desejado, como um ODPS SQL node, para abrir o editor de nós.
-
No código de um nó ODPS SQL ou em outros nós baseados em SQL, defina um nome de parâmetro usando a sintaxe
${param}. A DataWorks recomenda o uso de nomes descritivos para facilitar a referência e o gerenciamento.Sintaxe dos parâmetros de agendamento:
Tipo
Sintaxe
Aplicabilidade
Observações
Formato geral
${parameter_name}Aplica-se à maioria dos tipos de nó, como ODPS SQL e nós de sincronização de dados.
Este é o formato mais comum.
Formato especial
Varia conforme o tipo de nó e não usa o formato
${...}.PyODPS e Shell
Para mais informações, consulte Configuration examples for scheduling parameters of different node types.
-- Example: Define a variable named pt_date for partition filtering. SELECT * FROM my_table WHERE ds = '${pt_date}'; No painel à direita, clique em Scheduling para acessar a seção Scheduling Parameter.
Configure os parâmetros de agendamento conforme descrito na próxima seção.
2. Configurar parâmetros
Defina parâmetros de agendamento tanto em Visual definition quanto em Define by expression. Alterne entre esses modos clicando em Define by expression no canto superior direito da lista de parâmetros. O modo padrão é Visual definition.
-
Configurar parâmetros
Modo visual
Clique em Scheduling no painel à direita para abrir o painel de configuração de parâmetros de agendamento.
-
Adicionar um parâmetro
Clique em Scheduling à direita do nó e adicione parâmetros na seção Scheduling Parameter. Há duas formas de adicionar parâmetros:
Clique em Add Parameter e insira manualmente um nome e um valor. O nome do parâmetro deve ser idêntico ao nome da variável definida no código.
Clique em Load Parameters in Code. O DataWorks analisa automaticamente as variáveis no seu código, como
${pt_date}, e as preenche na lista de parâmetros. Basta inserir um valor para cada parâmetro.
-
Atribuir um valor
Valores podem ser parâmetros integrados, variáveis de tempo personalizadas ou constantes.
Clique em na caixa de entrada. Uma lista suspensa exibirá expressões de parâmetros comuns para seleção direta. Também é possível inserir manualmente uma expressão personalizada ou uma variável integrada.
Insira um valor conforme suas necessidades de negócio. Para mais detalhes sobre os formatos de valor suportados, consulte Supported formats of scheduling parameters.
Modo de expressão
Clique em Define by expression para alternar para o Modo de expressão. Use este modo caso prefira configurar parâmetros por meio de expressões.
No Modo de expressão, separe múltiplos parâmetros com espaços.
-
Ao adicionar, exclua ou modifique parâmetros de agendamento em Define by expression, o DataWorks valida a sintaxe da expressão. Se a sintaxe for inválida, a configuração do parâmetro falhará.
Por exemplo, o DataWorks aplica regras como não permitir espaços em ambos os lados do sinal de igual (=).
-
-
Visualize parâmetros
Após definir os parâmetros, clique em Preview Scheduling Parameters para ver como eles serão resolvidos nas próximas instâncias com base em um timestamp de dados especificado. Isso ajuda a testar se as definições estão corretas. É possível ajustar o timestamp de dados e o número de instâncias para visualização.
Alguns nós, como os de sincronização em lote, possuem um parâmetro padrão ${bizdate}. Esse parâmetro recebe automaticamente o valor $bizdate. Substitua o parâmetro bizdate por um nome personalizado no seu código. O nome ${bizdate} em si não tem significado especial e é tratado como qualquer outro parâmetro personalizado.
3. Teste de fumaça
Após atribuir valores aos parâmetros de agendamento, use o recurso de teste de fumaça. Ele permite definir um timestamp de dados e simular a execução da tarefa, ajudando a verifique se o código roda e se os parâmetros são substituídos conforme o esperado. Caso os resultados não correspondam ao esperado, ajuste a configuração prontamente para evitar problemas nas execuções agendadas.
O teste de fumaça gera instâncias, o que incorre em custos. Para mais informações sobre preços de instâncias, consulte Billing of serverless resource groups .
-
Envie o código do nó.
Configure o scheduling time e o scheduling dependencies.
-
Clique em no ícone Salvar
. Depois que o código e as configurações forem salvos, clique em no ícone Enviar
para enviar o código e a configuração mais recentes para o Operation Center. O recurso de teste de fumaça só estará disponível no ambiente de desenvolvimento após o envio do nó.NotaSe o teste de fumaça não estiver executando o código ou os parâmetros mais recentes, envie o nó novamente.
-
Execute o teste de fumaça.
Clique em no ícone
Smoke Testing na barra de ferramentas. Na caixa de diálogo Perform Smoke Testing, selecione um timestamp de dados e clique em OK para iniciar o teste. -
Visualize os logs do teste de fumaça.
-
Na janela Smoke Testing Records que aparece, localize o registro mais recente e clique em View Log.
O log exibe o status de execução e os detalhes do nó. A linha de resultados de substituição de parâmetros mostra os valores reais de cada parâmetro de agendamento, permitindo confirme se a substituição ocorreu corretamente.
-
Verifique a saída dos parâmetros nos logs para confirme se os valores estão corretos.
NotaSe você fechar a janela acidentalmente, reabra-a clicando em no ícone
Smoke Testing Logs na barra de ferramentas.
-
Os recursos Run
e Advanced Run
exigem a atribuição manual de constantes às variáveis no código. Portanto, eles não servem para verifique se os parâmetros de agendamento foram configurados corretamente.
4. Implantar e verificar
Após a verificação no ambiente de desenvolvimento, implante a tarefa no Operation Center para execução agendada em produção. Após a implantação, verifique os parâmetros de agendamento no ambiente de produção para evitar erros de execução.
Se os parâmetros de agendamento de uma tarefa acionada automaticamente não estiverem configurados conforme o esperado, ou se você não encontrar a tarefa no Operation Center, certifique-se de que a tarefa foi implantada com sucesso. Para mais informações sobre como implantar uma tarefa, consulte Deploy a task.
-
Verifique as definições dos parâmetros.
Acesse o Operation Center, alterne para a região e o workspace desejados e navegue até a página . Na lista de tarefas, clique em no nome da tarefa e verifique os parâmetros de execução no painel Attribute para garantir que estejam corretos.
-
Realize o teste de fumaça no Operation Center.
Também é possível usar o teste de fumaça no Operation Center para confirme se uma tarefa implantada substitui os parâmetros e executa o código conforme o esperado no ambiente de produção. Para mais informações, consulte Run a test and view the test instance.
ImportanteObserve que o teste de fumaça executa sobre dados reais de produção. Proceda com cautela para evitar corromper dados no seu banco de dados de produção.
Na caixa de diálogo Smoke Testing, insira um Smoke Test Name, selecione o timestamp de dados alvo em Select Data Timestamp, ative opcionalmente a Advanced Configuration para personalizar os parâmetros de execução da tarefa e, em seguida, clique em OK para iniciar o teste.
-
Observe os resultados reais do agendamento.
Depois que a tarefa for agendada automaticamente, verifique se os parâmetros foram substituídos corretamente consultando os parâmetros de uma instância acionada automaticamente em Auto Triggered Instances.
Na lista Auto Triggered Instances, localize a instância da tarefa desejada e clique em no nome da instância. No painel Properties à direita, visualize o campo Execution Parameters para confirme se cada parâmetro foi substituído pelos valores reais de data e hora.
Exemplo completo de configuração
Este exemplo usa um nó ODPS SQL para demonstrar como usar o recurso Perform smoke test in development environment no ambiente de desenvolvimento, testando se os parâmetros de agendamento configurados funcionam conforme o esperado. Após a implantação da tarefa, você também verificará a configuração dos parâmetros de agendamento no Operation Center.
Para informações sobre como configurar parâmetros de agendamento para diferentes tipos de nó, consulte Configuration examples for scheduling parameters of different node types.
-
Edite o código do nó e configure os parâmetros de agendamento.
A figura abaixo mostra o código e as configurações de parâmetros de agendamento do nó ODPS SQL.

-
Defina variáveis no código.
-- Assign values by using built-in parameters SELECT '${var1}'; SELECT '${var2}'; -- Assign values by using custom parameters SELECT '${var3}'; SELECT '${var4}'; -- Assign a constant SELECT '${var5}'; -
Atribua valores às variáveis.
No painel , atribua valores às variáveis (Área 2). Para mais informações sobre formatos de valor, consulte Supported formats of scheduling parameters.
var1=$bizdate: Atribui o timestamp de dados no formatoyyyymmdd.var2=$cyctime: Atribui o horário de execução agendado no formatoyyyymmddhh24miss.var3=${yyyymmdd}: Atribui o timestamp de dados no formatoyyyymmdd.var4=$[yyyymmddhh24miss]: Atribui o horário de execução agendado no formatoyyyymmddhh24miss.var5=Hangzhou: Atribui a constanteHangzhouavar5.
-
Opcional: Configure o horário de agendamento.
Configure o nó ODPS SQL para executar em um agendamento horário (Área 3).
NotaA configuração de um agendamento baseado em tempo é opcional, conforme sua necessidade. Este exemplo demonstra como configurar um agendamento horário.
Hora de início:
16:00Hora de término:
23:59Intervalo:
1hora
Para mais informações sobre a configuração de agendamentos baseados em tempo, consulte Configure time properties.
-
Defina a dependência de agendamento.
Configure uma dependência de agendamento para o nó. Para mais informações, consulte Configure scheduling dependencies. Neste exemplo, o nó raiz é usado como dependência upstream para este nó.
-
Na barra de ferramentas superior da página do editor de nós, clique em no ícone
e, em seguida, no ícone
para salve e envie a configuração do nó ODPS SQL.-
Realize o teste de fumaça no ambiente de desenvolvimento.
-
Clique em no ícone
. Na caixa de diálogo Smoke Testing in Development Environment, configure o timestamp de dados para simular o agendamento do nó.O timestamp de dados é configurado da seguinte forma:
Data Timestamp:
2025-10-16Start Time:
16:00End Time:
17:00
Como a tarefa ODPS SQL está agendada para executar horariamente, ela gerará duas instâncias às
16:00e às17:00em2025-10-17.NotaO timestamp de dados geralmente corresponde ao dia anterior à execução. Portanto, a execução real da tarefa ocorre em
2025-10-17.Os valores esperados para a instância das
16:00são:var1=20251016var2=20251017160000var3=20251016var4=20251017160000
Os valores esperados para a instância das
17:00são:var1=20251016var2=20251017170000var3=20251016var4=20251017170000
Clique em OK. O nó começa a executar nos horários especificados.
-
Após a conclusão da execução, clique em no ícone
para visualize os logs do teste de fumaça.As duas instâncias geradas para o nó executaram com sucesso e os resultados estão conforme o esperado.
A janela View Smoke Testing Records exibe dois registros de instância com timestamp de dados
2025-10-16, ambos com status Succeeded. Clique em View Log para ver os logs detalhados da execução.No log de execução da instância das
16:00, os resultados da substituição de parâmetros sãovar1=20251016 var2=20251017160000 var3=20251016 var4=20251017160000 var5=Hangzhou, conforme o esperado.No log de execução da instância das
17:00, os resultados da substituição de parâmetros sãovar1=20251016 var2=20251017170000 var3=20251016 var4=20251017170000 var5=Hangzhou, também conforme o esperado.
-
Se o seu workspace estiver no modo padrão, implante o nó no ambiente de produção. Na página do editor de nós ODPS SQL, clique em Deploy no canto superior direito para implantar o nó. Para mais informações, consulte Deploy a task.
-
Acesse o Operation Center para confirme a configuração dos parâmetros de agendamento do nó.
Na barra de menu superior do DataStudio, clique em Operation Center no canto superior direito.
-
Na página , pesquise pelo nó desejado.
NotaO nó só estará visível nesta página após ser implantado com sucesso.
-
Clique em no nome do nó desejado e visualize os Execution Parameters no painel Attribute.
Neste exemplo, os parâmetros de execução do nó são
var1=$bizdate var2=$cyctime var3=${yyyymmdd} var4=$[yyyymmddhh24miss]. -
Observe a substituição real de parâmetros em uma instância em execução. Após a geração de uma instância agendada, acesse a página Auto Triggered Instances, pesquise pelo nome da tarefa, clique em no nome da instância e visualize os Execution Parameters no painel Attribute.
Neste exemplo, os parâmetros de execução são resolvidos como
var1=20251016 var2=20251017160000 var3=20251016 var4=20251017160000.