DataWorks:HTTP トリガーノード

1. Java SDK をインストールします。詳細については、「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("Scheduled timestamp: " + cycTime);
           // OpenAPI 構成オブジェクトを初期化
           Config config = new Config();
           config.setAccessKeyId(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID")); // 環境変数から AccessKey ID を取得
           config.setAccessKeySecret(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));// 環境変数から AccessKey Secret を取得
           config.setEndpoint(endpoint);
           // Alibaba Cloud クライアントインスタンスを作成
           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形式の文字列です。API を呼び出す前に、この値をミリ秒タイムスタンプに変換する必要があります。
   endpoint	対象の HTTP トリガーノードが存在するワークスペースのエンドポイントです。詳細については、「Alibaba Cloud OpenAPI Developer Portal のエンドポイント」をご参照ください。
   ALIBABA_CLOUD_ACCESS_KEY_ID	対象の HTTP トリガーノードが属する Alibaba Cloud アカウントのAccessKey IDです。	AccessKey 情報を取得します。 DataWorks コンソールにログインし、上部のナビゲーションバーの右上隅にあるプロフィールアイコンにカーソルを合わせ、クリックして [アクセスキー管理] ページに移動し、AccessKey ID と AccessKey Secret を取得します。 環境変数を構成します。 取得した AccessKey ID と AccessKey Secret を現在の環境の環境変数として構成します。コード内で環境変数を読み取ることで AccessKey 情報を動的に取得でき、平文保存によるセキュリティリスクを回避できます。詳細については、「環境変数の構成」をご参照ください。
   ALIBABA_CLOUD_ACCESS_KEY_SECRET	対象の HTTP トリガーノードが属する Alibaba Cloud アカウントのAccessKey Secretです。

1. Python SDK をインストールします。詳細については、「Python SDK のインストール」をご参照ください。

   次のコマンドを実行して DataWorks SDK をインストールします。

   pip install alibabacloud_dataworks_public20240518==6.2.0

2. コードサンプル

   TriggerSchedulerTaskInstance デバッグページに移動し、[SDK サンプル] タブで完全な Python サンプルを表示できます。

   デバッグページの左側で、リクエストパラメーターTaskId(整数)、EnvType(文字列)、TriggerTime(整数) を構成します。右側で、言語としてPythonを選択すると、完全な SDK サンプルコードが表示されます。[サンプルの実行]をクリックすると、オンラインでデバッグできます。

TriggerSchedulerTaskInstance のデバッグページ に移動し、対応するセクションで次のパラメーターを構成して、[送信]をクリックして呼び出しを開始できます。