DataWorks:HTTP trigger node

1. Add the DataWorks SDK dependency to your Project Object Model (POM):

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

   For SDK installation instructions, see Use Alibaba Cloud SDK for Java in an IDE.

2. Call the API with the following sample code. Replace the placeholder values with your actual parameters (see the parameter table below).

   Placeholder	Description
   <task-id>	The Task ID retrieved in step 1 Step 1: Get the instance task ID and scheduled time.
   <Prod-or-Dev>	Prod for the production environment; Dev for the development environment.
   <scheduled-time>	The Scheduled Time retrieved in step 1 Step 1: Get the instance task ID and scheduled time. The time must be in the yyyy-MM-dd HH:mm:ss format.
   <workspace-endpoint>	The endpoint of the workspace where the HTTP trigger node is located. See Alibaba Cloud OpenAPI Developer Service Endpoints.
   ALIBABA_CLOUD_ACCESS_KEY_ID	Set this environment variable to the AccessKey ID of the Alibaba Cloud account that owns the HTTP trigger node. To get your AccessKey pair, go to AccessKey Management in the DataWorks console. For secure credential configuration, see Manage access credentials.
   ALIBABA_CLOUD_ACCESS_KEY_SECRET	Set this environment variable to the AccessKey secret of the same account.

   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 {
       public static TriggerSchedulerTaskInstanceResponse runTriggerScheduler(
               com.aliyun.dataworks_public20240518.Client client,
               Long nodeId,
               String EnvType,
               Long TriggerTime) throws Exception {
           TriggerSchedulerTaskInstanceRequest request = new TriggerSchedulerTaskInstanceRequest();
           request.setTaskId(nodeId);       // Task ID of the HTTP trigger node instance
           request.setEnvType(EnvType);     // Environment: "Prod" or "Dev"
           request.setTriggerTime(TriggerTime); // Scheduled time as a millisecond timestamp
           RuntimeOptions runtime = new RuntimeOptions();
           return client.triggerSchedulerTaskInstanceWithOptions(request, runtime);
       }
   
       public static void main(String[] args) throws Exception {
           String nodeId = "<task-id>";
           String EnvTypeStr = "<Prod-or-Dev>";
           String cycTimeStr = "<scheduled-time>";   // Format: yyyy-MM-dd HH:mm:ss
           String endpoint = "<workspace-endpoint>";
   
           Long nodeId1 = Long.parseLong(nodeId);
   
           // Convert the scheduled time string to a millisecond timestamp
           SimpleDateFormat sdft = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
           Calendar calendar = Calendar.getInstance();
           calendar.setTime(sdft.parse(cycTimeStr));
           Long cycTime = calendar.getTimeInMillis();
   
           // Initialize the client using AccessKey credentials from environment variables
           Config config = new Config();
           config.setAccessKeyId(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"));
           config.setAccessKeySecret(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
           config.setEndpoint(endpoint);
   
           Client client = new Client(config);
           TriggerSchedulerTaskInstanceResponse response =
               runTriggerScheduler(client, nodeId1, EnvTypeStr, cycTime);
           System.out.println(com.aliyun.teautil.Common.toJSONString(
               com.aliyun.teautil.Common.toMap(response)));
       }
   }

   Replace the following placeholders with your actual values: For a complete Java example, see the TriggerSchedulerTaskInstance debugging pageTriggerSchedulerTaskInstance debugging pageTriggerSchedulerTaskInstance debugging pageSDK Sample tab on the TriggerSchedulerTaskInstance debugging page.

1. Install the Alibaba Cloud SDK for Python:

   pip install alibabacloud_dataworks_public20240518==6.2.0

   For SDK installation instructions, see Integrate SDK.

2. For a complete Python example, see the SDK Sample tab on the TriggerSchedulerTaskInstance debugging page.

Use the TriggerSchedulerTaskInstance debugging page to call the API directly without writing code. Set the following parameters and click Call API.