DataWorks:Node pemicu HTTP

1. Instal SDK Java. Untuk informasi lebih lanjut, lihat Instal SDK Java.

   Gunakan konfigurasi POM berikut untuk SDK DataWorks.

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

2. Contoh kode

   Anda dapat membuka halaman debugging TriggerSchedulerTaskInstance dan melihat contoh lengkap Java di tab SDK Sample.

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

   Ganti parameter yang relevan dalam kode di atas dengan nilai aktual yang dibutuhkan oleh bisnis Anda berdasarkan deskripsi parameter berikut.

   Parameter	Deskripsi
   nodeId	Task ID dari node pemicu HTTP yang diperoleh pada langkah Dapatkan parameter instans node pemicu HTTP.
   EnvTypeStr	Lingkungan proyek tempat node pemicu HTTP berada. Gunakan Prod untuk lingkungan produksi. Gunakan Dev untuk lingkungan pengembangan.
   cycTimeStr	Scheduled Time dari tugas node pemicu HTTP yang diperoleh pada langkah Dapatkan parameter instans node pemicu HTTP. Format waktunya adalah yyyy-MM-dd HH:mm:ss.
   endpoint	Titik akhir ruang kerja tempat node pemicu HTTP target berada. Untuk informasi lebih lanjut, lihat titik akhir Portal Pengembang OpenAPI Alibaba Cloud.
   ALIBABA_CLOUD_ACCESS_KEY_ID	ID AccessKey dari Akun Alibaba Cloud tempat node pemicu HTTP target berada.	Dapatkan Informasi AccessKey. Masuk ke Konsol DataWorks, arahkan kursor ke ikon profil di pojok kanan atas bilah navigasi atas, lalu klik untuk membuka halaman Accesskey Management guna memperoleh ID AccessKey dan AccessKey Secret. Konfigurasikan variabel lingkungan. Konfigurasikan ID AccessKey dan AccessKey Secret yang diperoleh sebagai variabel lingkungan untuk lingkungan saat ini. Anda dapat memperoleh informasi AccessKey secara dinamis dengan membaca variabel lingkungan dalam kode Anda guna menghindari risiko keamanan akibat penyimpanan teks biasa. Untuk informasi lebih lanjut, lihat Konfigurasikan variabel lingkungan.
   ALIBABA_CLOUD_ACCESS_KEY_SECRET	AccessKey Secret dari Akun Alibaba Cloud tempat node pemicu HTTP target berada.

1. Instal SDK Python. Untuk informasi lebih lanjut, lihat Instal SDK Python.

   Instal SDK DataWorks dengan menjalankan perintah berikut.

   pip install alibabacloud_dataworks_public20240518==6.2.0

2. Contoh kode.

   Anda dapat membuka halaman debugging TriggerSchedulerTaskInstance dan melihat contoh lengkap Python di tab SDK Sample.

   Di sisi kiri halaman debugging, konfigurasikan parameter permintaan TaskId (integer), EnvType (string), dan TriggerTime (integer). Di sisi kanan, pilih Python sebagai bahasa untuk melihat kode contoh SDK lengkap. Klik Run Sample untuk melakukan debugging online.

Anda dapat membuka halaman debugging TriggerSchedulerTaskInstance, konfigurasikan parameter berikut di bagian yang sesuai, lalu klik Submit untuk memulai pemanggilan.