DataWorks:HTTP trigger node

1. Install the Java SDK. For more information, see Install the Java SDK.

   Use the following POM configuration for the DataWorks SDK.

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

2. Code sample

   You can go to the TriggerSchedulerTaskInstance debugging page and view the complete Java sample on the SDK Sample tab.

   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)));
       }
   }

   Replace the relevant parameters in the preceding code with the actual values required by your business based on the following parameter descriptions.

   Parameter	Description
   nodeId	The Task ID of the HTTP trigger node obtained in the Obtain HTTP trigger node instance parameters step.
   EnvTypeStr	The project environment in which the HTTP trigger node resides. Use Prod for the production environment. Use Dev for the development environment.
   cycTimeStr	The Scheduled Time of the HTTP trigger node task obtained in the Obtain HTTP trigger node instance parameters step. The time format is yyyy-MM-dd HH:mm:ss.
   endpoint	The endpoint of the workspace in which the target HTTP trigger node resides. For more information, see Alibaba Cloud OpenAPI Developer Portal endpoints.
   ALIBABA_CLOUD_ACCESS_KEY_ID	The AccessKey ID of the Alibaba Cloud account to which the target HTTP trigger node belongs.	Obtain the AccessKey information. Log on to the DataWorks console, hover over the profile icon in the upper-right corner of the top navigation bar, and click to go to the Accesskey Management page to obtain the AccessKey ID and AccessKey Secret. Configure environment variables. Configure the obtained AccessKey ID and AccessKey Secret as environment variables for the current environment. You can dynamically obtain the AccessKey information by reading environment variables in your code to avoid security risks caused by plaintext storage. For more information, see Configure environment variables.
   ALIBABA_CLOUD_ACCESS_KEY_SECRET	The AccessKey Secret of the Alibaba Cloud account to which the target HTTP trigger node belongs.

1. Install the Python SDK. For more information, see Install the Python SDK.

   Install the DataWorks SDK by running the following command.

   pip install alibabacloud_dataworks_public20240518==6.2.0

2. Code sample.

   You can go to the TriggerSchedulerTaskInstance debugging page and view the complete Python sample on the SDK Sample tab.

   On the left side of the debugging page, configure the request parameters TaskId (integer), EnvType (string), and TriggerTime (integer). On the right side, select Python as the language to view the complete SDK sample code. Click Run Sample to debug online.

You can go to the TriggerSchedulerTaskInstance debugging page, configure the following parameters in the corresponding sections, and click Submit to initiate the call.