DataWorks:Nó de push de dados

Como funciona

Um nó de push de dados usa os Input and Output Parameters para recuperar parâmetros de saída de nós de consulta SQL e nós de atribuição upstream. Em seguida, você pode usar esses parâmetros como placeholders no corpo da mensagem e enviá-los para um destino.

• Após a execução de um nó de consulta SQL, ele gera um parâmetro outputs que contém os resultados da consulta e os passa para os nós downstream. Para obter mais informações, consulte Configure node context.

• Ao configurar o corpo da mensagem em um nó de push de dados, use o formato ${Parameter name} em um componente Markdown para referenciar e exibir parâmetros de saída de um nó upstream.

• Para exibir dados em um componente de tabela, selecione os nomes dos campos da consulta SQL upstream na configuração de parâmetro associada ao componente.

Pré-requisitos

• O service do DataWorks está ativado. Para obter mais informações, consulte Purchase guide.

• Um workspace do DataWorks foi criado. Para obter mais informações, consulte Create a workspace.

• Um workflow foi criado no seu workspace do DataWorks.

• É necessário um grupo de recursos serverless, pois este nó só pode ser executado em um grupo de recursos serverless. Para comprar e usar um grupo de recursos serverless, consulte Use serverless resource groups.

• O acesso à rede pública está ativado para o grupo de recursos. Para obter mais informações, consulte Overview of network connectivity solutions.

Limitações

• Os seguintes limites de tamanho de dados se aplicam ao enviar dados para diferentes destinos:

  • DingTalk: O tamanho da mensagem não pode exceder 20 KB.

  • Lark: O tamanho da mensagem não pode exceder 20 KB, e as imagens devem ser menores que 10 MB.

  • WeCom: Cada chatbot não pode enviar mais de 20 mensagens por minuto.

  • Teams: O tamanho da mensagem não pode exceder 28 KB.

  • E-mail: Cada tarefa de push de dados suporta apenas um corpo de e-mail. Para outras limitações, consulte os limites SMTP do seu provedor de service de e-mail.

• O nó de push de dados está disponível apenas em workspaces nas seguintes regiões: China (Hangzhou), China (Shanghai), China (Beijing), China (Shenzhen), China (Chengdu), China (Hong Kong), Singapore, Malaysia (Kuala Lumpur), US (Silicon Valley), US (Virginia) e Germany (Frankfurt).

1. Crie um nó upstream

Um nó de push de dados recupera os Context Parameters do contexto de um nó upstream para enviá-los a um destino. Antes de criar um nó de push de dados, crie um nó de consulta SQL ou um nó de atribuição upstream.

2. Crie um nó de push de dados

1. Na tela do workflow, clique em e crie um nó de push de dados.

   Parâmetro	Descrição
   Node Type	Selecione Data Push na lista suspensa.
   Path	Selecione o caminho que contém o nó upstream da Etapa 1.
   Name	Insira um nome para o nó.

2. Clique duas vezes no novo nó de push de dados para abrir sua página de configuração.

3. No painel à direita, clique em Properties. Em Scheduling Dependency > Parent Nodes, clique em Add e defina o nó criado em Step 1 como uma dependência upstream.

4. No painel Properties, em Resource Group > Resource Group for Scheduling, selecione um grupo de recursos serverless criado em ou após 28 de junho de 2024. Se o seu grupo de recursos foi criado antes dessa data, você deve enviar um ticket para atualizá-lo.

5. No painel Properties, em Input and Output Parameters > Input Parameters, clique em Add para criar um parâmetro de entrada. Para o seu valor, selecione o parâmetro de saída do nó de consulta da Etapa 1. Em seguida, feche o painel Scheduling.

6. Na página de configuração do nó, configure o destino, o título e o corpo da mensagem.

   1. Na lista suspensa Destination, selecione um destino. Se o destino desejado não estiver listado, clique em Create Data Push Destination e crie-o.

      Parâmetro	Descrição
      Type	Tipos suportados: DingTalk, Lark, WeCom, Teams e Email.
      Object	O nome do destino.
      Webhook	A URL do webhook para um chatbot do DingTalk, Lark ou WeCom; o webhook de entrada para o Teams; ou os detalhes SMTP para e-mail. Obtenha essas informações na plataforma de destino. Nota Para saber como obter o Webhook de um bot do Lark, consulte Configurar um gatilho de Webhook do Lark. Para saber como obter um Webhook do Teams, consulte Usar workflows do Microsoft Teams para criar um Webhook de entrada.

      Gerencie destinos de push:

      1. Faça login no console do DataWorks. Na região de destino, clique em Data Analysis and Service > DataService Studio no painel de navegação à esquerda. Selecione um workspace na lista suspensa e clique em Go to DataService Studio.

      2. Na página Service Development, clique no ícone de Configurações no canto inferior esquerdo e acesse a aba Destination Management. Nesta aba, você pode gerenciar destinos existentes ou clicar em Create Data Push Destination para adicionar um novo. Para obter mais informações, consulte Create a webhook data push destination.

   2. Name: Insira um título para a mensagem.

   3. Body: Você pode adicionar componentes Markdown e Table. Para obter mais informações, consulte Configure push content.

      Nota

      • Se o nó upstream for um nó de consulta SQL:

        • No corpo Markdown de um push de dados, use nomes de campos de uma consulta SQL como placeholders no formato ${field_name} para recuperar parâmetros de saída upstream.

        • Para tabelas em um corpo de push de dados, use nomes de campos de uma consulta SQL upstream como Parameters para recuperar dados.

      • Se o nó upstream for um nó de atribuição, use um placeholder no formato ${Input parameter name} no corpo da mensagem. ${Input parameter name} é o nome dos Input Parameters que você configurou no nó de push de dados.

7. Clique no ícone de Salvar e salve o nó de push de dados.

3. Execute e implante a tarefa

Após configurar o workflow de push de dados, teste-o e verifique se ele é executado corretamente e, em seguida, faça o commit e implante a tarefa.

1. Na tela do workflow, clique no ícone de Executar e execute o workflow.

2. Depois que o ícone de sucesso aparecer em todos os nós, clique no ícone de Commit para fazer o commit do workflow.

3. Na caixa de diálogo Submission, selecione os nós que deseja enviar e marque a caixa de seleção Ignore I/O Inconsistency Alerts.

4. Clique em Submission e envie.

5. Após o commit bem-sucedido dos nós, implante-os. Para obter mais informações, consulte Publish tasks.

Melhores práticas

O nó de push de dados suporta vários padrões de workflow: push simples, push combinado, push baseado em script, push condicional e push do MaxCompute. Para obter mais informações, consulte Best practices: Configure a data push node in a workflow.

Próximas etapas

Após a implantação, gerencie a tarefa no Operation Center. Para obter mais informações, consulte Perform basic O&M operations on auto triggered nodes.