DataWorks：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調試頁面，在以下地區設定對應參數，單擊下方的發起調用。