:HTTP トリガーノード

1. Java SDK をインストールします。詳細については、「IDE で Alibaba Cloud SDK for Java を使用する」をご参照ください。

   DataWorks SDK for Java を使用するには、以下の Project Object Model (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 形式である必要があります。
   endpoint	ターゲットの HTTP トリガーノードが配置されているワークスペースのエンドポイント。詳細については、「Alibaba Cloud OpenAPI Developer Service Endpoints」をご参照ください。
   ALIBABA_CLOUD_ACCESS_KEY_ID	宛先の HTTP トリガーノードが属する Alibaba Cloud アカウントの AccessKey ID。	AccessKey ペアの取得。 DataWorks コンソールにログインします。右上のプロファイル画像にポインターを合わせ、[AccessKey 管理] をクリックして AccessKey ID と AccessKey Secret を取得します。 環境変数の設定。 取得した AccessKey ID と AccessKey Secret を現在の環境の環境変数として設定します。後で環境変数を読み取ることで AccessKey 情報を動的に取得でき、プレーンテキストでの保存によるセキュリティリスクを回避できます。詳細については、「アクセス認証情報の管理」をご参照ください。
   ALIBABA_CLOUD_ACCESS_KEY_SECRET	宛先の HTTP トリガーノードが属する Alibaba Cloud アカウントの AccessKey Secret。

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

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

   pip install alibabacloud_dataworks_public20240518==6.2.0

2. サンプルコード。

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

   

TriggerSchedulerTaskInstance デバッグページ にアクセスし、以下のエリアで対応するパラメーターを設定し、下部の [API の呼び出し] をクリックします。