DataWorks:Nœud de déclenchement HTTP

1. Installez le SDK Java. Pour plus d'informations, consultez la rubrique Installer le SDK Java.

   Utilisez la configuration POM suivante pour le SDK DataWorks.

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

2. Exemple de code

   Vous pouvez accéder à la page de débogage TriggerSchedulerTaskInstance et consulter l'exemple Java complet dans l'onglet 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)));
       }
   }

   Remplacez les paramètres pertinents dans le code ci-dessus par les valeurs réelles requises par votre activité, en vous basant sur les descriptions de paramètres suivantes.

   Paramètre	Description
   nodeId	L'ID de tâche du nœud de déclenchement HTTP obtenu à l'étape Obtenir les paramètres d'instance du nœud de déclenchement HTTP.
   EnvTypeStr	L'environnement de projet dans lequel réside le nœud de déclenchement HTTP. Utilisez Prod pour l'environnement de production. Utilisez Dev pour l'environnement de développement.
   cycTimeStr	L'Heure planifiée de la tâche du nœud de déclenchement HTTP obtenue à l'étape Obtenir les paramètres d'instance du nœud de déclenchement HTTP. Le format de l'heure est yyyy-MM-dd HH:mm:ss.
   endpoint	Le point de terminaison de l'espace de travail dans lequel réside le nœud de déclenchement HTTP cible. Pour plus d'informations, consultez les points de terminaison du portail OpenAPI Developer d'Alibaba Cloud.
   ALIBABA_CLOUD_ACCESS_KEY_ID	L'AccessKey ID du compte Alibaba Cloud auquel appartient le nœud de déclenchement HTTP cible.	Obtenez les informations AccessKey. Connectez-vous à la console DataWorks, survolez l'icône de profil dans le coin supérieur droit de la barre de navigation supérieure et cliquez pour accéder à la page Accesskey Management afin d'obtenir l'AccessKey ID et l'AccessKey Secret. Configurez les variables d'environnement. Configurez l'AccessKey ID et l'AccessKey Secret obtenus comme variables d'environnement pour l'environnement actuel. Vous pouvez récupérer dynamiquement les informations AccessKey en lisant les variables d'environnement dans votre code, évitant ainsi les risques de sécurité liés au stockage en clair. Pour plus d'informations, consultez la rubrique [Configurer les variables d'environnement](t2499839.xdita#).
   ALIBABA_CLOUD_ACCESS_KEY_SECRET	L'AccessKey Secret du compte Alibaba Cloud auquel appartient le nœud de déclenchement HTTP cible.

1. Installez le SDK Python. Pour plus d'informations, consultez la rubrique Installer le SDK Python.

   Installez le SDK DataWorks en exécutant la commande suivante.

   pip install alibabacloud_dataworks_public20240518==6.2.0

2. Exemple de code.

   Vous pouvez accéder à la page de débogage TriggerSchedulerTaskInstance et consulter l'exemple Python complet dans l'onglet SDK Sample .

   Sur le côté gauche de la page de débogage, configurez les paramètres de requête TaskId (entier), EnvType (chaîne) et TriggerTime (entier). Sur le côté droit, sélectionnez Python comme langage pour afficher le code d'exemple SDK complet. Cliquez sur Run Sample pour effectuer un débogage en ligne.

Accédez à la page de débogage TriggerSchedulerTaskInstance, configurez les paramètres suivants dans les sections correspondantes, puis cliquez sur Submit pour initier l'appel.

Paramètre	Description
TaskId	L'ID de tâche du nœud de déclenchement HTTP obtenu à l'étape Obtenir les paramètres d'instance du nœud de déclenchement HTTP.
EnvType	L'environnement de projet dans lequel réside le nœud de déclenchement HTTP. Utilisez Prod pour l'environnement de production. Utilisez Dev pour l'environnement de développement.
TriggerTime	L'Heure planifiée de la tâche du nœud de déclenchement HTTP obtenue à l'étape Obtenir les paramètres d'instance du nœud de déclenchement HTTP. L'heure doit être convertie en horodatage en millisecondes.