DataWorks:Nó de gatilho HTTP

1. Instale o SDK do Java. Para mais informações, consulte Instalar o SDK do Java.

   Use a seguinte configuração POM para o SDK do DataWorks.

   <dependency>
     <groupId>com.aliyun</groupId>
     <artifactId>dataworks_public20240518</artifactId>
     <version>6.2.0</version>
   </dependency>

2. Exemplo de código

   Acesse a página de depuração TriggerSchedulerTaskInstance e visualize o exemplo completo em Java na aba SDK Sample.

   package com.example.demo;
   import com.aliyun.dataworks_public20240518.Client;
   import com.aliyun.dataworks_public20240518.models.TriggerSchedulerTaskInstanceRequest;
   import com.aliyun.dataworks_public20240518.models.TriggerSchedulerTaskInstanceResponse;
   import com.aliyun.teaopenapi.models.Config;
   import com.aliyun.teautil.models.RuntimeOptions;
   import java.text.SimpleDateFormat;
   import java.util.Calendar;
   public class CrossTenantTriggerSchedulerTaskTo {
       // Method to trigger a DataWorks node run
       public static TriggerSchedulerTaskInstanceResponse runTriggerScheduler(com.aliyun.dataworks_public20240518.Client client, Long nodeId, String EnvType, Long TriggerTime) throws Exception {
           TriggerSchedulerTaskInstanceRequest request = new TriggerSchedulerTaskInstanceRequest(); // Create API request object
           request.setTaskId(nodeId); // Set the node ID to trigger
           request.setEnvType(EnvType); // Set the project environment
           request.setTriggerTime(TriggerTime); // Set the scheduled trigger time (millisecond timestamp)
           RuntimeOptions runtime = new RuntimeOptions(); // Initialize runtime options
           return client.triggerSchedulerTaskInstanceWithOptions(request, runtime); // Execute the API call and return the response
       }
       public static void main(String[] args) throws Exception {
           // Initialize node ID (example value)
           String nodeId = "xxx";
           // Initialize project environment (example value)
           String EnvTypeStr = "xxx";
           // Initialize scheduled time (example value)
           String cycTimeStr = "xxx";
           // Set the endpoint
           String endpoint = "xxx";
           // Convert string to Long type node ID
           Long nodeId1 = Long.parseLong(nodeId);
           // Print usage instructions
           System.out.println("Usage: java -jar test-1.0-SNAPSHOT.jar nodeId EnvTypeStr cycTimeParam");
           // Parse the scheduled time and convert to timestamp
           SimpleDateFormat sdft = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
           Calendar calendar = Calendar.getInstance();
           calendar.setTime(sdft.parse(cycTimeStr)); // Parse the time string
           Long cycTime = calendar.getTimeInMillis(); // Get the millisecond timestamp
           // Print debug info (timestamp)
           System.out.println("Scheduled timestamp: " + cycTime);
           // Initialize OpenAPI config object
           Config config = new Config();
           config.setAccessKeyId(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID")); // Get AccessKey ID from environment variable
           config.setAccessKeySecret(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));// Get AccessKey Secret from environment variable
           config.setEndpoint(endpoint);
           // Create Alibaba Cloud client instance
           Client client = new Client(config);
           // Execute the trigger node operation
           TriggerSchedulerTaskInstanceResponse response = runTriggerScheduler(client, nodeId1,EnvTypeStr, cycTime);
           // Print the API response (JSON format)
           System.out.println(com.aliyun.teautil.Common.toJSONString(com.aliyun.teautil.Common.toMap(response)));
       }
   }

   Substitua os parâmetros relevantes no código anterior pelos valores reais exigidos pelo seu negócio, seguindo as descrições de parâmetros abaixo.

   Parâmetro	Descrição
   nodeId	O Task ID do nó de gatilho HTTP obtido na etapa Obter parâmetros da instância do nó de gatilho HTTP.
   EnvTypeStr	O ambiente de projeto onde o nó de gatilho HTTP está localizado. Use Prod para o ambiente de produção. Use Dev para o ambiente de desenvolvimento.
   cycTimeStr	O Scheduled Time da tarefa do nó de gatilho HTTP obtido na etapa Obter parâmetros da instância do nó de gatilho HTTP. O formato de hora é yyyy-MM-dd HH:mm:ss.
   endpoint	O endpoint do workspace onde o nó de gatilho HTTP de destino está localizado. Para mais informações, consulte Endpoints do Portal do Desenvolvedor OpenAPI da Alibaba Cloud.
   ALIBABA_CLOUD_ACCESS_KEY_ID	O AccessKey ID da conta Alibaba Cloud à qual o nó de gatilho HTTP de destino pertence.	Obtenha as informações de AccessKey. Faça login no console do DataWorks, passe o mouse sobre o ícone de perfil no canto superior direito da barra de navegação superior e clique em para acessar a página Accesskey Management e obter o AccessKey ID e o AccessKey Secret. Configure as variáveis de ambiente. Defina o AccessKey ID e o AccessKey Secret obtidos como variáveis de ambiente para o ambiente atual. É possível obter dinamicamente as informações de AccessKey lendo variáveis de ambiente no seu código, evitando riscos de segurança causados pelo armazenamento em texto simples. Para mais informações, consulte Configurar variáveis de ambiente.
   ALIBABA_CLOUD_ACCESS_KEY_SECRET	O AccessKey Secret da conta Alibaba Cloud à qual o nó de gatilho HTTP de destino pertence.

1. Instale o SDK do Python. Para mais informações, consulte Instalar o SDK do Python.

   Instale o SDK do DataWorks executando o seguinte comando.

   pip install alibabacloud_dataworks_public20240518==6.2.0

2. Exemplo de código.

   Acesse a página de depuração TriggerSchedulerTaskInstance e visualize o exemplo completo em Python na aba SDK Sample.

   No lado esquerdo da página de depuração, configure os parâmetros de solicitação TaskId (inteiro), EnvType (string) e TriggerTime (inteiro). No lado direito, selecione Python como linguagem para visualizar o código de exemplo completo do SDK. Clique em Run Sample para depurar online.

Acesse a página de depuração TriggerSchedulerTaskInstance, configure os seguintes parâmetros nas seções correspondentes e clique em Submit para iniciar a chamada.

Parâmetro	Descrição
TaskId	O Task ID do nó de gatilho HTTP obtido na etapa Obter parâmetros da instância do nó de gatilho HTTP.
EnvType	O ambiente de projeto onde o nó de gatilho HTTP está localizado. Use Prod para o ambiente de produção. Use Dev para o ambiente de desenvolvimento.
TriggerTime	O Scheduled Time da tarefa do nó de gatilho HTTP obtido na etapa Obter parâmetros da instância do nó de gatilho HTTP. O horário deve ser convertido para um carimbo de data/hora em milissegundos.