HTTP触发器节点

1. 安装Java SDK，详情可参见通过IDE使用阿里云Java SDK。

   其中，DataWorks的SDK请用下面的pom配置。

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

2. 代码示例

   您可进入TriggerSchedulerTaskInstance调试页面，在SDK示例页签查看完整的Java示例。

   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 {
       // 触发DataWorks节点运行的方法
       public static TriggerSchedulerTaskInstanceResponse runTriggerScheduler(com.aliyun.dataworks_public20240518.Client client, Long nodeId, String EnvType, Long TriggerTime) throws Exception {
           TriggerSchedulerTaskInstanceRequest request = new TriggerSchedulerTaskInstanceRequest(); // 创建API请求对象
           request.setTaskId(nodeId); // 设置要触发的节点ID
           request.setEnvType(EnvType); // 设置项目环境
           request.setTriggerTime(TriggerTime); //设置定时触发时间（毫秒级时间戳）
           RuntimeOptions runtime = new RuntimeOptions(); // 初始化运行时配置
           return client.triggerSchedulerTaskInstanceWithOptions(request, runtime); // 执行API调用并返回响应
       }
   
       public static void main(String[] args) throws Exception {
           // 初始化节点ID（示例值）
           String nodeId = "xxx";
           // 初始化项目环境（示例值）
           String EnvTypeStr = "xxx";
           // 初始化定时时间（示例值）
           String cycTimeStr = "xxx";
           //设置服务端点
           String endpoint = "xxx";
           // 将字符串转换为Long类型节点ID
           Long nodeId1 = Long.parseLong(nodeId);
           // 输出程序使用说明
           System.out.println("Usage: java -jar test-1.0-SNAPSHOT.jar nodeId EnvTypeStr cycTimeParam");
           // 解析定时时间并转换为时间戳
           SimpleDateFormat sdft = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
           Calendar calendar = Calendar.getInstance();
           calendar.setTime(sdft.parse(cycTimeStr)); // 解析时间字符串
           Long cycTime = calendar.getTimeInMillis(); // 获取毫秒级时间戳
           // 输出调试信息（时间戳）
           System.out.println("定时时间戳：" + cycTime);
           // 初始化OpenAPI配置对象
           Config config = new Config();
           config.setAccessKeyId(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID")); // 从环境变量获取访问密钥ID
           config.setAccessKeySecret(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));// 从环境变量获取访问密钥Secret
           config.setEndpoint(endpoint);
           // 创建阿里云客户端实例
           Client client = new Client(config);
           // 执行触发节点操作
           TriggerSchedulerTaskInstanceResponse response = runTriggerScheduler(client, nodeId1,EnvTypeStr, cycTime);
           // 输出API响应结果（JSON格式）
           System.out.println(com.aliyun.teautil.Common.toJSONString(com.aliyun.teautil.Common.toMap(response)));
       }
   }

   按照以下参数说明，将上述代码中的相关参数替换成业务所需实际值。

   参数	说明
   nodeId	获取HTTP触发节点实例参数步骤获取的HTTP触发器节点任务ID。
   EnvTypeStr	HTTP触发器节点所在的项目环境。 生产环境用Prod。 开发环境用Dev。
   cycTimeStr	获取HTTP触发节点实例参数步骤获取的HTTP触发器节点任务的定时时间。时间格式为yyyy-MM-dd HH:mm:ss。
   endpoint	目标HTTP触发器节点所在工作空间的服务地址，详情请参见阿里云OpenAPI开发者服务地址。
   ALIBABA_CLOUD_ACCESS_KEY_ID	目标HTTP触发器节点所在阿里云账号的AccessKey ID。	获取AccessKey信息。 登录DataWorks控制台，将鼠标悬停在顶部菜单栏右侧的用户头像上，单击进入AccessKey管理页面，获取AccessKey ID及AccessKey Secret信息。 配置环境变量。 将获取到的 AccessKey ID 和 AccessKey Secret 配置为当前环境的环境变量。后续在代码中可通过读取环境变量的方式动态获取AK信息，从而避免明文存储带来的安全风险。详情请参见管理访问凭据。
   ALIBABA_CLOUD_ACCESS_KEY_SECRET	目标HTTP触发器节点所在阿里云账号的AccessKey Secret。

1. 安装Python SDK，详情可参见集成SDK。

   其中，DataWorks的SDK请使用下面的命令安装。

   pip install alibabacloud_dataworks_public20240518==6.2.0

2. 代码示例。

   您可进入TriggerSchedulerTaskInstance调试页面，在SDK示例页签查看完整的Python示例。

   

您可进入TriggerSchedulerTaskInstance调试页面，在以下区域设置对应参数，单击下方的发起调用。