DataWorks:Nó HTTP Trigger

Um sistema de agendamento externo pode acionar uma tarefa em dois cenários típicos:

• O nó HTTP Trigger não possui nós ancestrais

  Neste cenário, crie o nó HTTP Trigger, configure o gatilho externo e defina as propriedades de agendamento e dependências para todos os nós no DataWorks. Para mais informações, consulte Create an HTTP Trigger node e Configure a trigger in an external scheduling system.

• O nó HTTP Trigger possui um ou mais nós ancestrais

  Neste cenário:

  • Crie o nó HTTP Trigger, configure o gatilho externo e defina as propriedades de agendamento e dependências para todos os nós no DataWorks. Para mais informações, consulte Create an HTTP Trigger node e Configure a trigger in an external scheduling system.

  • Por padrão, um nó HTTP Trigger depende do nó raiz do workflow. Se houver outros nós ancestrais, altere manualmente a dependência para o nó ancestral correto.

  • O nó HTTP Trigger inicia seus nós descendentes somente após a execução bem-sucedida dos nós ancestrais e o envio de uma solicitação de gatilho pelo sistema de agendamento externo.

    Se o sistema externo enviar a solicitação de gatilho antes da conclusão dos nós ancestrais, o nó HTTP Trigger reterá a solicitação e aguardará. Assim que os ancestrais forem concluídos, o nó iniciará seus descendentes.

    Importante

    Essa solicitação de gatilho é retida por apenas 24 horas. Caso os nós ancestrais não sejam concluídos dentro desse período, a solicitação expirará.

Um nó HTTP Trigger é executado apenas se as seguintes condições forem atendidas:

• Deve existir uma instância de ciclo para o nó. Encontre essa instância em Auto Triggered Instances na página Cycle Instance. Até que a API RunTriggerNode seja chamada com sucesso, a instância permanece em estado de espera por gatilho, bloqueando seus nós descendentes. Após a chamada bem-sucedida, o nó é executado.

• Todos os nós ancestrais foram executados com sucesso.

• O horário agendado do nó foi atingido.

• O grupo de recursos de agendamento do nó possui recursos suficientes.

• O nó HTTP Trigger não está em estado congelado.

• O acionamento ocorre apenas se o nó estiver em estado de espera por gatilho. Não é possível acionar novamente uma instância bem-sucedida.

Para configurar o gatilho externo, chame a versão 2020-05-18 da API RunTriggerNode de uma das seguintes maneiras para iniciar o nó.

• Java

  1. Instale o SDK Java . Para mais informações, consulte Get started.

     Utilize a seguinte configuração pom para o SDK do DataWorks.

     <dependency>
       <groupId>com.aliyun</groupId>
       <artifactId>dataworks_public20200518</artifactId>
       <version>8.0.0</version>
     </dependency>

  2. Código de exemplo

     Acesse a página de depuração RunTriggerNode e visualize o exemplo completo em Java na aba SDK Sample. No OpenAPI Explorer, na página RunTriggerNode (executar um nó de gatilho), defina o Endpoint como China (Shanghai). Na aba Parameter Configuration à esquerda, preencha os seguintes parâmetros obrigatórios: NodeId (o ID do nó de gatilho), CycleTime (o timestamp de 13 dígitos em milissegundos da tarefa correspondente ao nó de gatilho), BizDate (o timestamp da data de negócios da instância onde reside o nó de gatilho) e AppId (o ID do workspace do DataWorks ao qual o nó de gatilho pertence). À direita, selecione a aba SDK Sample e escolha a linguagem Java para visualizar o código de exemplo do SDK Java. No código, o endpoint é dataworks.cn-shanghai.aliyuncs.com, e você pode usar um par AccessKey (AK&SK) para inicializar o cliente. Clique em Run Sample para realizar a chamada ou em Download Full Project para obter o código completo.

• Python

  1. Instale o SDK Python . Para mais informações, consulte Integrate an SDK.

     Execute o comando a seguir para instalar o SDK do DataWorks.

     pip install aliyun-python-sdk-dataworks-public==2.1.2

  2. Código de exemplo

     Acesse a página de depuração RunTriggerNode e visualize o exemplo completo em Python na aba SDK Example. Na página da API RunTriggerNode no OpenAPI Explorer, mude a linguagem para Python, selecione China (Shanghai) como endpoint e insira os quatro parâmetros obrigatórios na área de parâmetros de entrada: NodeId, CycleTime, BizDate e AppId. A área de código à direita gera automaticamente um exemplo de código do SDK Python que inclui a lógica de inicialização do cliente para o SDK alibabacloud_dataworks_public20200518 (criando um cliente de conta usando um par AccessKey). Clique em Run Example para depurar online ou em Download Full Project para obter o código completo.

• Chamada de API

  Para detalhes sobre como chamar a API, consulte RunTriggerNode.