DataWorks:Nó de gatilho HTTP

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

   Utilize 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 acima pelos valores reais exigidos pelo seu cenário, seguindo as descrições de parâmetros abaixo.

   Parâmetro	Descrição
   nodeId	O Task ID do nó de gatilho HTTP obtido na etapa Obtain HTTP trigger node instance parameters.
   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 Obtain HTTP trigger node instance parameters. O formato de tempo é yyyy-MM-dd HH:mm:ss.
   endpoint	O endpoint do workspace onde reside o nó de gatilho HTTP alvo. 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 pertence o nó de gatilho HTTP alvo.	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 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 recuperar dinamicamente as informações de AccessKey lendo essas variáveis no código, evitando riscos de segurança causados pelo armazenamento em texto simples. Para mais detalhes, consulte Configure environment variables.
   ALIBABA_CLOUD_ACCESS_KEY_SECRET	O AccessKey Secret da conta Alibaba Cloud à qual pertence o nó de gatilho HTTP alvo.

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

   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 parâmetros a seguir 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 Obtain HTTP trigger node instance parameters.
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 Obtain HTTP trigger node instance parameters. O horário deve ser convertido para um timestamp em milissegundos.