DataWorks:Instâncias acionadas automaticamente

Modo de pesquisa inteligente

Com a pesquisa inteligente, basta digitar uma consulta e o sistema a interpreta automaticamente para filtrar as instâncias desejadas.

1. Realize uma pesquisa inteligente.

   Clique no botão Intelligent Search na caixa de filtros. Na caixa de diálogo exibida, insira sua consulta, como Sort by instance type, e pressione Enter. O sistema exibirá automaticamente as instâncias correspondentes.

2. Salve uma nova visualização.

   Para reutilizar os critérios da sua pesquisa inteligente, clique em Unsaved View > Save as New View na barra de pesquisa. Na caixa de diálogo Save View, insira um View Name personalizado e clique em Save. Posteriormente, localize e utilize essa nova visualização na barra de pesquisa de visualizações.

   Nota

   Se não desejar mais utilizar essa visualização, encontre seu nome na barra de pesquisa. Passe o mouse sobre o nome, clique no ícone ... à direita e selecione Modify ou Delete.

3. Desative a pesquisa inteligente.

   Para realizar uma busca precisa usando condições de filtro, pressione a tecla Esc ou clique no botão Disable Intelligent Search na barra de ações da instância para sair do modo de pesquisa inteligente.

Modo de condições de filtro

Utilize condições de filtro para localizar com precisão as instâncias acionadas automaticamente necessárias.

1. Filtragem simples.

   Na barra de ferramentas, selecione múltiplos critérios de filtro, como Search by task name, task ID, or instance ID, Scheduling Resource Group, Alerts Reported Within Last 24 Hours ou In Waiting for Resources State for a Long Period of Time, para refinar a lista de instâncias.

2. Filtragem avançada.

   Clique no botão Filter na caixa de filtros. Combine diversos critérios, como Search by task name, task ID, or instance ID, Scheduling Resource Group, Run time e Computing Resource Name, para encontrar exatamente as instâncias necessárias.

Modo de ordenação

Ordene a lista de instâncias acionadas automaticamente em ordem crescente ou decrescente por campos como Data Timestamp, Priority e Timing Time. Para workflows executados com êxito, também é possível classificar as tarefas internas por Start Time, End Time e Duration.

Gerenciar uma única instância

Para gerenciar uma instância específica, localize-a na lista e utilize as opções na coluna Actions. A tabela a seguir descreve as ações disponíveis.

Gerenciar múltiplas instâncias

Para gerenciar várias instâncias simultaneamente, selecione-as na lista. Em seguida, utilize os botões de operação em massa na parte inferior da lista para Terminate, Rerun, Set to Successful, Change Resource Group, Freeze ou Unfreeze as instâncias selecionadas.

Para exportar a lista de instâncias dos resultados da pesquisa, realize primeiro a busca. Depois, clique no botão Export Query Results acima da lista. Na caixa de diálogo Export Query Results, confirme as seguintes informações:

• Operation Object: Mostra a quantidade de instâncias que correspondem aos critérios de filtro atuais. Clique em View Filter Conditions para ver os filtros específicos aplicados.

• Export Method: Selecione Export to Local File.

Recursos da página do DAG

Na página de detalhes do DAG da instância, execute operações como agregação de nós, análise downstream e ajuste do estilo de exibição do DAG.

Ações no DAG

Na página de detalhes do DAG, clique com o botão direito em uma instância do workflow para visualizar detalhes como relacionamentos upstream/downstream e código. As seguintes ações estão disponíveis:

• Show Ancestor Nodes: Exibe as tarefas upstream do nó atual para entender quais nós afetam sua saída de dados. Expanda os nós ancestrais por nível, até seis níveis por vez.

• Show Descendent Nodes: Mostra as tarefas downstream do nó atual para identificar quais nós são impactados por sua saída de dados. Expanda os nós descendentes por nível, até seis níveis por vez.

• View Runtime Log: Após o início da tarefa, acompanhe o processo detalhado no log de execução. Para descrições dos parâmetros principais, consulte Apêndice: Parâmetros do log de execução.

• Run Diagnostics: Verifica as dependências upstream, horário de agendamento, recursos de agendamento e status de execução da tarefa.

• View Code: Visualize o código do nó atual no ambiente de produção. Se não estiver conforme o esperado, confirme se a versão mais recente foi implantada com êxito.

• Edit Node: Abre o nó atual no DataStudio.

• View Lineage: Consulte a linhagem de dados da instância atual.

• More: Acesse detalhes como propriedades básicas da instância, logs de operação e código da tarefa.

• View auto triggered node: Visualize informações sobre o nó acionado automaticamente ao qual a instância pertence.

• Go to task 360 page: Acesse o Data Governance Center para obter uma visão panorâmica dos detalhes da tarefa em múltiplas dimensões, como linhas de base associadas e status de execução, além de realizar a governança da tarefa. Para mais informações, consulte Obter uma visão panorâmica de uma tarefa.

• Terminate: Interrompe uma tarefa que não precisa mais ser executada. O status será definido como falha. Somente instâncias nos estados Waiting time, Waiting for resources ou Running podem ser interrompidas.

• Rerun: Reexecuta uma tarefa nos estados Successful ou Failed. Após a execução bem-sucedida, a tarefa pode acionar suas tarefas downstream pendentes. Comumente usado para tratar nós com falha ou não executados.

• Rerun Descendent Nodes: Reexecuta os nós descendentes de uma tarefa nos estados Successful ou Failed. Selecione quais tarefas downstream reexecutar. Após a conclusão, elas acionam suas tarefas downstream pendentes. Frequentemente utilizado para recuperação de dados.

• Set to Successful: Define o status de uma tarefa com falha como bem-sucedida. Útil para evitar que uma falha bloqueie tarefas downstream. Geralmente aplicado no tratamento de nós com erro.

• Resume: Retoma uma tarefa com falha a partir do ponto de interrupção. Se a tarefa contiver múltiplas instruções SQL, ela poderá retomar a partir da instrução específica que falhou.

  Nota

  Esta operação é suportada apenas para tarefas MaxCompute SQL.

• Trigger Data Quality Check: Se houver regras de qualidade de dados configuradas para a tarefa, acione uma verificação de validação.

• Emergency Operations: As operações de emergência têm uso único e afetam apenas a execução atual do nó.

  • Delete Dependencies: Remove os relacionamentos de dependência do nó atual. Frequentemente usado para remover urgentemente uma dependência upstream quando uma tarefa anterior falha, mas não está relacionada aos dados da instância atual, permitindo que a tarefa corrente seja executada.

    Nota

    Confirme se esta ação afetará seus dados verificando o código da tarefa e a linhagem de dados.

  • Change Priority: A prioridade de uma instância é herdada de sua linha de base. Redefina a prioridade aqui conforme necessário. Um número maior indica maior prioridade.

  • Force Rerun: Força a reexecução do nó atual. Aplicável a instâncias acionadas automaticamente em estados de sucesso, falha ou não executado. Comum em cenários de recuperação de dados.

  • Force Heavy Run Downstream: Reexecuta forçadamente as tarefas downstream para processar dados das duas datas comerciais anteriores. Suportado apenas para instâncias acionadas automaticamente em estado Successful ou Failed, sendo frequentemente usado para recuperação de dados. Para mais informações, consulte Apêndice: Forçar reexecução downstream.

    Nota

    Apenas administradores do workspace, administradores do tenant e contas Alibaba Cloud podem iniciar uma reexecução forçada de nós downstream.

  • Clone Instance: Cria uma nova instância clonada com base em uma instância em execução (instância hospedeira). A nova instância recebe o nome no formato dw_clone_NodeName.

    Nota

    • Apenas instâncias de nós ODPS SQL podem ser clonadas, e cada instância pode ser clonada apenas uma vez.

    • Lógica de execução para instâncias hospedeiras e clonadas:

      • Ambas as instâncias (hospedeira e clonada) ficam em estado de execução. Se a instância hospedeira for concluída com êxito primeiro, a instância clonada é interrompida. Se a instância clonada for concluída primeiro, a instância hospedeira é interrompida e seu status é definido como bem-sucedido.

      • Se uma tarefa downstream da tarefa atual possuir uma instância clonada, a reexecução dos nós downstream não acionará a execução da instância clonada.

• Freeze: Congele uma instância caso ela e suas instâncias downstream não precisem ser executadas.

  Importante

  • Congelar uma instância upstream impede a execução de suas instâncias downstream. Proceda com cautela.

  • Não opere no nó projectname_root, pois ele é o nó raiz do workspace. Todas as instâncias acionadas automaticamente dependem dele. Congelar este nó impedirá a execução de qualquer instância.

  • Não é possível congelar uma instância nos estados Waiting for resources, Waiting time ou Running (por exemplo, se o código do nó estiver em execução ou uma verificação de qualidade de dados estiver em andamento).

• Unfreeze: Descongela uma instância que esteja no estado congelado.

  • Se a instância ainda não foi executada, ela será iniciada automaticamente após a conclusão de suas tarefas upstream.

  • Caso todas as tarefas upstream já tenham sido concluídas, o status da instância mudará para falha. Nesse caso, será necessário reexecutá-la manualmente.

  Nota

  A operação de descongelamento afeta apenas a instância atual. Se o nó acionado automaticamente permanecer congelado, a instância gerada no dia seguinte também estará congelada.

Detalhes da instância

No DAG da instância, clique com o botão esquerdo em uma instância específica e selecione View Log Data na janela pop-up, ou clique em Show Details para visualizar informações detalhadas nas abas General, Runtime Log, Operation Log e Code.