DataWorks:Nó de ramificação

Visão geral

Um nó de ramificação avalia parâmetros de saída de nós upstream usando operadores de comparação Python. Essa avaliação cria múltiplas ramificações condicionais, permitindo executar diferentes nós downstream conforme os resultados obtidos nos nós anteriores.

Pré-requisitos

• O usuário RAM que você deseja utilizar deve estar adicionado ao seu workspace.

  Para desenvolver tarefas com um usuário RAM, adicione-o como membro do workspace e atribua a função Develop ou Workspace Administrator. A função Workspace Administrator concede mais permissões do que o necessário; portanto, tenha cautela ao atribuí-la. Para mais detalhes sobre como adicionar membros e atribuir funções, consulte Adicionar membros a um workspace.

• Um grupo de recursos serverless deve estar associado ao seu workspace. Para mais informações, consulte os tópicos no diretório Usar grupos de recursos serverless.

• Antes de configurar um nó de ramificação, é necessário criá-lo. Para mais detalhes, consulte Criar um nó de workflow de agendamento.

Observações de uso

• Os nós de ramificação estão disponíveis apenas no DataWorks Standard Edition ou superior. Para saber mais sobre as edições do DataWorks e como adquiri-las, consulte Edições do DataWorks.

• Cada nó de ramificação suporta no máximo 50 ramificações.

• Geralmente, esses nós são utilizados em conjunto com nós de atribuição. Consulte Nó de atribuição para mais informações.

• Caso as condições de uma ramificação downstream não sejam atendidas, as tarefas dessa ramificação entram em estado de execução simulada (dry run). O log registrará uma mensagem semelhante a It's set condition-skip by task.

• As condições de ramificação não aceitam strings vazias ('') para avaliação. Por exemplo, se a condição for '${tp_code}' != '' e o valor do parâmetro for um espaço em branco, esse espaço será considerado como "possui valor" (um espaço difere de uma string vazia), fazendo com que a ramificação seja selecionada. Recomendamos o uso de um placeholder especial para representar valores vazios. Defina, por exemplo, o valor padrão do parâmetro como tp_code='NONE' e configure a condição da ramificação como '${tp_code}' != 'NONE'.

Etapa 1: Desenvolver o nó de ramificação

1. Acesse a página de configuração do nó de ramificação para definir a lógica de bifurcação.

   1. Na página Definition, clique em Add Branch.

   2. Na caixa de diálogo Branch Definition, configure os parâmetros.

      Parâmetro	Descrição
      Condition	As condições de ramificação utilizam operadores de comparação Python. Se uma expressão resultar em true durante a execução, a condição da ramificação será atendida. Caso não seja possível analisar uma expressão em tempo de execução, toda a instância do nó de ramificação falhará. É permitido usar variáveis globais e parâmetros definidos no contexto do nó dentro da condição. Por exemplo, ${input} pode representar um parâmetro de entrada do nó de ramificação.
      Associated Node Output	A saída do nó estabelece dependências para os nós downstream. Quando a condição da ramificação é atendida, o nó downstream dependente da saída vinculada é executado. Sua execução também depende do status dos demais nós upstream. Se a condição não for satisfeita, o nó downstream dependente dessa saída não será executado. O status do nó será definido como Not run because branch condition not met.
      Description	Breve descrição da definição da ramificação. Você pode, por exemplo, definir duas ramificações com as condições ${input}==1 e ${input}>2.

2. Configure os nós downstream.

   Diversos tipos de nós podem ser configurados após um nó de ramificação. Este exemplo utiliza nós MySQL.

   1. Crie dois nós MySQL chamados branch_1 e branch_2 e acesse a página de desenvolvimento de cada um.

   2. No lado direito da página de desenvolvimento do nó MySQL, escolha Scheduling Settings > Scheduling Dependency, clique em Add Dependency, selecione o nó de ramificação upstream e sua saída correspondente e salve a configuração.

3. Após concluir o desenvolvimento do nó de ramificação e de seus nós downstream, configure as propriedades de agendamento para habilitar a execução periódica. Para mais detalhes, consulte Configurar propriedades de agendamento para nós.

Etapa 2: Implantar e gerenciar nós

1. Concluídas as configurações de agendamento, implante os nós no ambiente de produção. Consulte Implantar nós e workflows para mais informações.

2. Uma vez implantadas, as tarefas serão executadas periodicamente conforme o cronograma definido. Acesse Operation and Maintenance Center > Node O&M > Auto Triggered Task O&M > Auto Triggered Task para visualizar as tarefas agendadas implantadas e realizar operações de O&M. Veja mais detalhes em Introdução ao Operation Center.

Apêndice: Operadores de comparação Python

Considere que a variável a seja 10 e a variável b seja 20.