DataWorks：Node pemicu HTTP

1. Instal SDK Java. Untuk informasi lebih lanjut, lihat Use Alibaba Cloud SDK for Java in an IDE.

   Tentukan konfigurasi Project Object Model (POM) berikut untuk menggunakan DataWorks SDK untuk Java:

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

2. Kode contoh

   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 DataWorks node execution
       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 configuration
           return client.triggerSchedulerTaskInstanceWithOptions(request, runtime); // Execute API call and return 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 service endpoint
           String endpoint = "xxx";
           // Convert string to Long type node ID
           Long nodeId1 = Long.parseLong(nodeId);
           // Output program usage instructions
           System.out.println("Usage: java -jar test-1.0-SNAPSHOT.jar nodeId EnvTypeStr cycTimeParam");
           // Parse 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 time string
           Long cycTime = calendar.getTimeInMillis(); // Get millisecond timestamp
           // Output debug information (timestamp)
           System.out.println("Scheduled timestamp: " + cycTime);
           // Initialize OpenAPI configuration 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 node trigger operation
           TriggerSchedulerTaskInstanceResponse response = runTriggerScheduler(client, nodeId1,EnvTypeStr, cycTime);
           // Output API response result (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 diperlukan untuk bisnis Anda sesuai 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. Atur nilainya ke Prod untuk lingkungan produksi. Atur nilainya ke Dev untuk lingkungan pengembangan.
   cycTimeStr	Scheduled Time dari tugas node pemicu HTTP yang Anda peroleh pada langkah Dapatkan parameter instans node pemicu HTTP. Waktu harus dalam format yyyy-MM-dd HH:mm:ss.
   endpoint	Titik akhir ruang kerja tempat node pemicu HTTP target berada. Untuk informasi lebih lanjut, lihat Alibaba Cloud OpenAPI Developer Service Endpoints.
   ALIBABA_CLOUD_ACCESS_KEY_ID	AccessKey ID dari Akun Alibaba Cloud tempat node pemicu HTTP tujuan berada.	Dapatkan pasangan AccessKey. Login ke Konsol DataWorks. Arahkan kursor ke gambar profil Anda di pojok kanan atas dan klik AccessKey Management untuk mendapatkan AccessKey ID dan AccessKey secret. Konfigurasikan variabel lingkungan. Konfigurasikan AccessKey ID dan AccessKey Secret yang diperoleh sebagai variabel lingkungan untuk lingkungan saat ini. Nantinya, Anda dapat memperoleh Informasi AccessKey secara dinamis dengan membaca variabel lingkungan, sehingga menghindari risiko keamanan penyimpanan teks biasa. Untuk informasi lebih lanjut, lihat Manage access credentials.
   ALIBABA_CLOUD_ACCESS_KEY_SECRET	AccessKey secret dari Akun Alibaba Cloud tempat node pemicu HTTP tujuan berada.

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

   Jalankan perintah berikut untuk menginstal DataWorks SDK untuk Python:

   pip install alibabacloud_dataworks_public20240518==6.2.0

2. Kode contoh.

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

   

Anda dapat membuka halaman debugging TriggerSchedulerTaskInstance, atur parameter yang sesuai di area berikut, lalu klik Call API di bawahnya.