DataWorks:HTTP tetikleyici düğümü

1. Java SDK'yı yükleyin. Daha fazla bilgi için bkz. Java SDK'yı yükleme.

   DataWorks SDK için aşağıdaki POM yapılandırmasını kullanın.

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

2. Kod örneği

   TriggerSchedulerTaskInstance hata ayıklama sayfasına giderek SDK Sample sekmesinde eksiksiz Java örneğini görüntüleyebilirsiniz.

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

   Yukarıdaki koddaki ilgili parametreleri, aşağıdaki parametre açıklamalarına dayanarak iş ihtiyaçlarınıza göre gerçek değerlerle değiştirin.

   Parametre	Açıklama
   nodeId	HTTP tetikleyici düğümü örnek parametrelerini edinme adımında elde edilen HTTP tetikleyici düğümünün Görev Kimliği.
   EnvTypeStr	HTTP tetikleyici düğümünün bulunduğu proje ortamı. Üretim ortamı için Prod kullanın. Geliştirme ortamı için Dev kullanın.
   cycTimeStr	HTTP tetikleyici düğümü örnek parametrelerini edinme adımında elde edilen HTTP tetikleyici düğümü görevinin Zamanlanmış Saati. Zaman biçimi yyyy-MM-dd HH:mm:ss şeklindedir.
   endpoint	Hedef HTTP tetikleyici düğümünün bulunduğu çalışma alanının uç noktası. Daha fazla bilgi için bkz. Alibaba Cloud OpenAPI Geliştirici Portalı uç noktaları.
   ALIBABA_CLOUD_ACCESS_KEY_ID	Hedef HTTP tetikleyici düğümünün ait olduğu Alibaba Cloud hesabının AccessKey ID değeri.	AccessKey bilgilerini edinin. DataWorks konsoluna giriş yapın, üst gezinme çubuğunun sağ üst köşesindeki profil simgesinin üzerine gelin ve Accesskey Management sayfasına giderek AccessKey ID ve AccessKey Secret değerlerini edinin. Ortam değişkenlerini yapılandırın. Edindiğiniz AccessKey ID ve AccessKey Secret değerlerini mevcut ortamınız için ortam değişkeni olarak yapılandırın. Kodunuzda ortam değişkenlerini okuyarak AccessKey bilgilerini dinamik olarak edinebilir ve düz metin olarak saklamaktan kaynaklanan güvenlik risklerini önleyebilirsiniz. Daha fazla bilgi için bkz. Ortam değişkenlerini yapılandırma.
   ALIBABA_CLOUD_ACCESS_KEY_SECRET	Hedef HTTP tetikleyici düğümünün ait olduğu Alibaba Cloud hesabının AccessKey Secret değeri.

1. Python SDK'yı yükleyin. Daha fazla bilgi için bkz. Python SDK'yı yükleme.

   DataWorks SDK'yı yüklemek için aşağıdaki komutu çalıştırın.

   pip install alibabacloud_dataworks_public20240518==6.2.0

2. Kod örneği.

   TriggerSchedulerTaskInstance hata ayıklama sayfasına giderek SDK Sample sekmesinde eksiksiz Python örneğini görüntüleyebilirsiniz.

   Hata ayıklama sayfasının sol tarafında TaskId (integer), EnvType (string) ve TriggerTime (integer) istek parametrelerini yapılandırın. Sağ tarafta dil olarak Python seçerek eksiksiz SDK örnek kodunu görüntüleyin. Çevrimiçi hata ayıklamak için Run Sample seçeneğine tıklayın.

TriggerSchedulerTaskInstance hata ayıklama sayfasına gidin, ilgili bölümlerde aşağıdaki parametreleri yapılandırın ve çağrıyı başlatmak için Submit seçeneğine tıklayın.

Parametre	Açıklama
TaskId	HTTP tetikleyici düğümü örnek parametrelerini edinme adımında elde edilen HTTP tetikleyici düğümünün Görev Kimliği.
EnvType	HTTP tetikleyici düğümünün bulunduğu proje ortamı. Üretim ortamı için Prod kullanın. Geliştirme ortamı için Dev kullanın.
TriggerTime	HTTP tetikleyici düğümü örnek parametrelerini edinme adımında elde edilen HTTP tetikleyici düğümü görevinin Zamanlanmış Saati. Zaman, milisaniye cinsinden zaman damgasına dönüştürülmelidir.