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.
NotaA 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.
NotaO 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.NotaPró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.
NotaVisualizaçã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
|
|
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.
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.
|
|
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. |
