DataWorks:Assignment node

Etapa 1: Configure o nó de atribuição

1. Faça login no console do DataWorks. No painel de navegação à esquerda, clique em Data Development & O&M > Data Development.

2. No fluxo de trabalho, crie e abra um nó de atribuição. Na página de configuração, selecione ODPS SQL como linguagem e escreva a consulta.

   select * from xc_dpe_e2.xc_rpt_user_info_d where dt='20191008' limit 10;

3. (Opcional) Clique em Properties no painel direito e selecione a aba Input and Output Parameters para confirme que o DataWorks criou automaticamente um parâmetro de saída chamado outputs.

Etapa 2: Configure o nó Shell

1. Crie um nó Shell. Na tela do fluxo de trabalho, arraste uma conexão do nó de atribuição para o nó Shell para defini-lo como subsequente.

2. Na página de configuração do nó Shell, clique em Properties no painel direito e selecione a aba Input and Output Parameters.

3. Na seção Input Parameters, clique em Create.

4. Na caixa de diálogo, selecione o parâmetro outputs do nó de atribuição e defina um nome para o parâmetro de entrada do nó atual, como param.

   Esta etapa cria uma dependência entre o nó Shell e o nó de atribuição.

5. Referencie o valor no script do nó Shell usando a sintaxe ${param}:

   ${param} , ${param[0]} e ${param[0][1]} são sintaxes de variável do DataWorks, não Shell padrão. O DataWorks substitui estaticamente esses espaços reservados pelos valores reais antes de enviar o script para execução.

   echo '${param}';
   echo 'First row: '${param[0]};
   echo 'Second field of the first row: '${param[0][1]};

Etapa 3: Execute e verifique

Abra o fluxo de negócios e clique em Run na barra de ferramentas para execute o fluxo de trabalho. A saída esperada é semelhante à seguinte:

Full result set: value1,value2
value3,value4
First row: value1,value2
Second field of the first row: value2

Para testar em um ambiente agendado, envie o nó para o ambiente de desenvolvimento, acesse o Operation Center e use o backfill de dados para validar a execução.

Transmitir um resultado ODPS SQL

O resultado de um SELECT SQL é transmitido como um array bidimensional.

Nó de atribuição

select * from xc_dpe_e2.xc_rpt_user_info_d where dt='20191008' limit 2;

Nó Shell (parâmetro de entrada param mapeado para outputs)

# Full 2D array
echo "Full result set: ${param}"

# First row (1D array)
echo "First row: ${param[0]}"

# Second field of the first row
echo "Second field of the first row: ${param[0][1]}"

Saída esperada

Full result set: value1,value2
value3,value4
First row: value1,value2
Second field of the first row: value2

Transmitir uma saída Python 2

A saída da última instrução print é dividida por vírgulas e transmitida como um array unidimensional.

Nó de atribuição

print "hello,dataworks";

Nó Shell (parâmetro de entrada param mapeado para outputs)

# Full 1D array
echo "Full result set: ${param}"

# Elements by index
echo "First element: ${param[0]}"
echo "Second element: ${param[1]}"

Saída esperada

Full result set: "hello","dataworks"
First element: hello
Second element: dataworks

Transmitir uma saída Shell

A saída da última instrução echo é dividida por vírgulas e transmitida como um array unidimensional.

Nó de atribuição

echo "hello,dataworks";

Nó Shell (parâmetro de entrada param mapeado para outputs)

# Full 1D array
echo "Full result set: ${param}"

# Elements by index
echo "First element: ${param[0]}"
echo "Second element: ${param[1]}"

Saída esperada

Full result set: "hello","dataworks"
First element: hello
Second element: dataworks