Todos os produtos
Search
Central de documentação

DataWorks:Apêndice: Recursos do DAG

Última atualização: Jun 27, 2026

O grafo acíclico direcionado (DAG) no Operation Center visualiza as dependências upstream e downstream dos seus nós. Ele também oferece recursos como agregação de nós, análise upstream e análise downstream para melhorar a eficiência operacional. Este tópico descreve os recursos da visualização de DAG.

Limitações

Os recursos de agregação de nós, análise upstream e análise downstream na visualização de DAG estão disponíveis apenas no DataWorks Professional Edition ou superior. Para obter mais informações sobre como atualizar sua edição, consulte Edições e faturamento.

Recursos do DAG

Clique em DAG ao lado de um nó para abrir sua visualização de DAG. A interface do DAG possui uma tela central que exibe o grafo de nós, uma lista de nós à esquerda para seleção e controles para recursos como agregação de nós, análise upstream e análise downstream na parte superior. É possível realizar as seguintes operações na visualização de DAG. Este tópico usa uma instância acionada automaticamente como exemplo.

  • Agregação de nós

    Se uma instância acionada automaticamente tiver muitos nós ou níveis de dependência, agrupe os nós por dimensões como status do nó, workspace, proprietário ou prioridade para visualizar a contagem de nós de uma dimensão específica. Isso ajuda a entender a distribuição dos nós e gerencie a execução com mais eficácia. Os exemplos a seguir mostram a exibição quando os nós estão como Not Aggregate e quando estão aggregated by priority.

    Nota

    A agregação de nós por status só é possível no DAG de uma instância. Uma instância pode ser acionada automaticamente, de backfill de dados ou de teste.

    • Sem agregação, cada nó aparece individualmente no DAG. Cada nó exibe seu nome e tipo, como virtual node, ODPS SQL ou batch synchronization. As linhas entre os nós indicam dependências. Uma mensagem na parte inferior indica que a visualização atual contém 10 nós em 8 níveis de dependência.

    • Com os nós agregados por prioridade, a exibição é a seguinte. É possível ver rapidamente que o nó atual possui 6 nós filhos com prioridade 1. O DAG agregado mostra o caminho de dependência, começando por fanyi_test_root (nó virtual) no topo, passando por User Behavior Analysis Case Description (nó virtual), table_ddl_ods_raw_log_d (ODPS SQL), dois grupos agregados contendo dois nós cada, depois dws_user_info_all_di (ODPS SQL), ads_user_info_1d (ODPS SQL) e finalmente User Behavior Analysis Result Query (ODPS SQL). Setas entre os nós indicam dependências de agendamento. O painel esquerdo lista todos os nomes das tarefas, permitindo selecione nós por meio de caixas de seleção.

  • Análise upstream

    Caso um nó esteja pendente por muito tempo, execute uma análise upstream. Essa funcionalidade revela os nós upstream bloqueadores, permitindo localizar e resolver erros de execução rapidamente para melhorar a eficiência.

    Nota
    • O recurso de análise upstream está disponível apenas no DAG de uma instância. Uma instância pode ser acionada automaticamente, de backfill de dados ou de teste.

    • A Upstream Analysis aplica-se somente a nós que não estão em execução. São exibidos no máximo seis níveis. Para visualizar mais níveis, clique em Continue Analysis no canto superior esquerdo.

    • Essa análise ajuda a encontrar rapidamente os nós ancestrais dos quais o nó atual depende, mas que não foram executados com êxito. Esses nós podem estar nos estados Running, Failed, Pending (Time), Pending (Resource) ou Frozen. Nós ancestrais nesses estados bloqueiam a execução downstream.

    Se um nó de exemplo não for executado por um longo período, selecione-o e clique em Upstream Analysis no canto superior esquerdo. O resultado da análise mostra que o nó upstream bloqueador é o nó old_work_root. Com esse resultado, localize rapidamente o nó bloqueador e trate quaisquer erros relacionados.

    Nota

    Próximas etapas:

    • Após localizar a instância chave, filtre por uma dimensão de agregação para visualizar o workspace ou o proprietário da instância chave que afeta a saída de dados do nó atual. Isso melhora a eficiência operacional.

    • Depois de identificar a instância bloqueadora, clique com o botão direito nela e selecione Run Diagnostics para analisar rapidamente o motivo da falha na execução. Para obter mais informações, consulte Diagnóstico inteligente.

    Nos resultados da análise upstream, old_work_root é um nó virtual, e seu nó dependente downstream é o nó sd do tipo ODPS SQL.

  • Análise downstream

    Por padrão, a visualização de DAG exibe três níveis: o nó atual, seus nós ancestrais imediatos (um nível acima) e seus nós descendentes imediatos (um nível abaixo). Quando uma instância acionada automaticamente possui muitos nós ou níveis, pode ser difícil visualizar todo o escopo de impacto. Utilize o recurso de análise downstream para filtrar por critérios como status do nó, workspace, proprietário ou prioridade. Isso facilita a contagem do número de nós em diferentes níveis ou o total de nós em todos os níveis para uma dimensão específica.

    Nota
    • Visualização mesclada ou em camadas no estado agregado: Ao clique em Downstream Analysis, os nós são agregados por proprietário por padrão, e o sistema calcula o número total de nós para essa dimensão em todos os níveis.

    • Visualização agrupada sem agregação: Se houver mais de 10 nós downstream, eles serão exibidos em grupos por padrão. Essa visualização proporciona uma compreensão mais intuitiva do impacto comercial dos nós.

    • Visualização desagrupada: Na visualização não agregada, clique em Ungroup para expandir os nós agrupados. Isso permite visualizar as relações upstream e downstream de todos os nós.

    • A visualização Layer para uma Downstream Analysis mostra no máximo seis níveis. Para visualizar mais níveis, clique em Continue Analysis no canto superior esquerdo.

    O exemplo a seguir mostra os resultados da execução de uma Downstream Analysis no nó tag:

    • Visualização mesclada: Mescla os nós downstream analisados com base na dimensão de agregação atual. Em um estado não agregado, os nós downstream são exibidos em grupos. Neste exemplo, o método Merge é utilizado e os nós estão aggregated by workspace. Todos os nós downstream são mesclados em uma única camada, mostrando o número de nós pertencentes a diferentes workspaces. Após clique em no botão Merged na visualização de DAG, o resultado da análise downstream para o nó tag é exibido no modo mesclado. Os sete nós downstream aparecem em grupos agregados, com cada grupo contendo um número diferente de nós descendentes. A barra de status na parte inferior indica que 42 nós e 5 níveis estão sendo exibidos atualmente.

    • Visualização em camadas: Exibe os nós downstream analisados por nível de dependência com base na dimensão de agregação atual. Neste exemplo, o método Layer é usado e os nós estão aggregated by workspace, mostrando o número de nós em diferentes workspaces em diferentes níveis. Após selecione a visualização DAG e clique em no botão Layered, os nós downstream são organizados de cima para baixo por nível. Cada nível mostra o número de nós que contém, e a parte inferior da página exibe o número total de nós e níveis mostrados (por exemplo, "42 nodes and 5 levels are displayed").

  • Estilos de exibição do DAG

    Clique em nos ícones de função no canto superior direito da visualização de DAG para ajustar seu estilo de exibição. Por exemplo, utilize Toggle Full Screen View ou Fit Screen.

    Os exemplos a seguir mostram o DAG para os nós downstream de um nó nas visualizações Ungroup e Group.

    • DAG Ungroup: Esta visualização ajuda a compreender claramente as relações upstream e downstream de todos os nós. No modo desagrupado, cada nó downstream é exibido como um cartão individual organizado por nível de dependência, mostrando um total de 15 nós e 2 níveis. Clique em no ícone Snapshot na barra de ferramentas lateral direita para salve o DAG atual como uma imagem.

    • DAG Group: Esta visualização exibe os nós downstream de maneira ordenada, com cinco nós por linha, facilitando a visualização rápida do número total de nós downstream.

    • DAG Ungroup: Esta visualização ajuda a compreender claramente as relações upstream e downstream de todos os nós. No modo desagrupado, cada nó downstream é exibido como um cartão individual organizado por nível de dependência, mostrando um total de 15 nós e 2 níveis. Clique em no ícone Snapshot na barra de ferramentas lateral direita para salve o DAG atual como uma imagem.

    • DAG Group: Esta visualização exibe os nós downstream de maneira ordenada, com cinco nós por linha, facilitando a visualização rápida do número total de nós downstream.

  • DAG Ungroup: Esta visualização ajuda a compreender claramente as relações upstream e downstream de todos os nós. No modo desagrupado, cada nó downstream é exibido como um cartão individual organizado por nível de dependência, mostrando um total de 15 nós e 2 níveis. Clique em no ícone Snapshot na barra de ferramentas lateral direita para salve o DAG atual como uma imagem.

  • DAG Group: Esta visualização exibe os nós downstream de maneira ordenada, com cinco nós por linha, facilitando a visualização rápida do número total de nós downstream.

  • O DAG mostra as dependências upstream e downstream entre os nós. Uma linha sólida indica uma dependência do mesmo ciclo, e uma linha tracejada indica uma dependência entre ciclos. Também é possível clique em com o botão direito em um nó para realizar operações.

    Ações

    Descrição

    Show ancestor nodes/Show descendant nodes

    O Operation Center recolhe automaticamente workflows com três ou mais nós. Use esta opção para expandir todos os níveis ancestrais e descendentes.

    View Runtime Log

    Visualize o log de execução da instância atual, que pode estar no estado Running, Succeeded ou Failed.

    Nota
    • Para um grupo de recursos compartilhado para agendamento, as instâncias são retidas por um mês e os logs por uma semana.

    • Para um grupo de recursos exclusivo para agendamento, instâncias e logs são retidos por um mês.

    Run Diagnostics

    O Operation Center do DataWorks fornece um recurso de diagnóstico de execução para ajudar a obter informações de ponta a ponta sobre a execução do nó e localizar problemas rapidamente. Para obter mais informações, consulte Diagnóstico Inteligente.

    View Code

    Visualize o código da instância atual.

    Edit Node

    Abre o nó no DataStudio para edição.

    View Lineage

    Visualize a linhagem de dados da instância atual.

    More

    Clique em para visualizar informações sobre o nó atual, como Property, Context, Runtime Log, Operation Log e Code.

    Terminate

    É possível parar apenas instâncias que estão no estado Pending ou Running. Após essa operação, o estado da instância muda para Failed.

    Rerun

    Executa um nó novamente. Uma reexecução bem-sucedida aciona seus nós downstream. Isso é frequentemente usado para execuções com falha ou perdidas.

    Nota

    Somente nós no estado Not Running, Successful ou Failed podem ser reexecutados.

    Rerun Descendent Nodes

    Reexecuta um nó e seus nós downstream. Selecione os nós a serem reexecutados. Após a execução bem-sucedida de um nó selecionado, ele pode acionar o agendamento de seus nós downstream que ainda não foram executados. Esta operação é frequentemente usada para correção de dados.

    Nota

    Selecione apenas nós nos status Not Running, Complete e Failed. Se você selecione um nó em qualquer outro status, a página exibirá a mensagem The selected nodes include nodes that do not meet the running conditions, e o envio da execução será desabilitado.

    Set to Successful

    Altera o status de uma instância com falha para Succeeded e aciona seus nós downstream. Isso é normalmente usado para recuperação de falhas.

    Nota

    Defina o status como Succeeded apenas para um nó no estado Failed. Não é possível definir o status como Succeeded para um workflow.

    Resume

    Se um nó falhar ao executar, retome-o. Este recurso é suportado apenas para nós MaxCompute.

    Nota

    Se você adquiriu um grupo de recursos exclusivo para agendamento antes de janeiro de 2021 e precisa atualizar, primeiro clique em no link do aplicativo para entrar no grupo de chat "Alibaba Cloud Big Data & AI Platform". Em seguida, escaneie o código QR a seguir para entrar no grupo DingTalk do produto DataWorks para suporte pré-vendas e pós-vendas. Você pode mencionar o robô inteligente para obter assistência ou entrar em contato diretamente com a equipe de plantão durante o horário de suporte.技术支持二维码

    Emergency Operations

    Operações para a instância atual em situações urgentes. As operações de emergência são efetivas apenas para a execução atual do nó.

    Delete Dependencies: Remove as dependências do nó para a execução atual. Isso é útil se um nó upstream necessário tiver falhado.

    Freeze

    Congelar uma instância acionada automaticamente aplica-se apenas à sua execução atual. Uma instância acionada automaticamente congelada não é agendada automaticamente e não processa dados. Ela também impede que seus nós downstream sejam agendados automaticamente.

    Cenário: Se você agendar um nó para executar a cada hora, 24 instâncias serão geradas para o dia. Se uma dessas instâncias horárias não precisar ser executada, escolha congelar essa instância. Congelar uma instância horária não afeta a execução de outras instâncias. Após a conclusão da operação de congelamento, visualize o registro correspondente de Freeze instance scheduling na aba Operation Log do nó, que inclui o horário da operação, o operador e os detalhes.

    Unfreeze

    Descongela uma instância que está em estado congelado.

    • Se a instância ainda não foi executada, ela será executada automaticamente após a conclusão da execução de seus nós upstream.

    • Se todos os nós upstream terminaram a execução, o nó é imediatamente definido como Failed. Reexecute-o manualmente para que ele funcione normalmente.

    Nota

    A operação de descongelamento afeta apenas a instância atual. Se a tarefa periódica do nó estiver congelada, as instâncias subsequentes ainda serão criadas em estado congelado.

  • Clique em em uma instância e um painel de detalhes da instância aparecerá no canto inferior direito da página. Clique em Show Details no painel para visualizar os detalhes de uma única instância. O exemplo a seguir usa uma instância acionada automaticamente.

    Aba

    Descrição

    Property

    Nesta aba, visualize as propriedades de agendamento da tarefa no ambiente de produção. Para obter mais informações sobre os parâmetros, consulte Configurar propriedades de agendamento.

    • Relação entre um ID de nó e um ID de instância:

      Um ID de nó identifica todas as instâncias desse nó para o dia (por exemplo, todas as execuções horárias). Um ID de instância identifica exclusivamente uma única execução.

    • Compreendendo o status da tarefa: O status da tarefa está relacionado à sua execução. Se uma tarefa estiver em um estado como Not Run, Pending (Time), Pending (Resource) ou Frozen, use Run Diagnostics para identificar rapidamente o problema.

    • Tempo gasto aguardando recursos: Quando uma tarefa passa muito tempo aguardando recursos, utilize o recurso Run Diagnostics para identificar quais outras tarefas estão consumindo recursos durante sua execução, ajudando a encontrar e investigar rapidamente tarefas anormais.

    • Tempo de execução excessivo: Se o tempo de execução de uma tarefa for significativamente maior do que sua média histórica, trate-a com base nos cenários a seguir.

      • Para tarefas que não são de sincronização, consulte o responsável pelo mecanismo correspondente.

      • Para uma tarefa de sincronização em lote, um determinado estágio da tarefa pode estar executando lentamente ou aguardando recursos por muito tempo. Para obter mais informações, consulte FAQ sobre sincronização em lote.

    • Monitoramento de regras: Visualize as regras de monitoramento associadas à instância atual. Clique em Create à direita para criar rapidamente uma regra de monitoramento para o status de execução da tarefa. Para obter mais informações, consulte Gerenciar regras.

      Nota

      Visualize apenas os detalhes das regras para monitorar o status de execução da tarefa. Regras de monitoramento de qualidade de dados não são exibidas aqui.

    • Monitoramento de linha de base: Visualize as linhas de base associadas à instância atual. Clique em Create à direita para criar rapidamente uma linha de base. Para obter mais informações, consulte Gerenciar linhas de base.

    Runtime Log

    Utilizado para visualizar o processo detalhado de execução da tarefa.

    Operation Log

    Utilizado para visualizar os registros de operação de uma tarefa ou instância, incluindo o horário, o operador e a operação específica.

    Code

    Utilizado para visualizar o código mais recente da tarefa atual no ambiente de produção. Se o código estiver incorreto, verifique se a versão mais recente foi implantada com êxito. Para obter mais informações, consulte Implantar tarefas.