DataWorks:Nœud de déclenchement HTTP

Un système d'ordonnancement externe peut déclencher une tâche dans deux scénarios typiques :

• Le nœud de déclenchement HTTP ne possède aucun nœud ancêtre

  Dans ce scénario, créez le nœud de déclenchement HTTP, configurez le déclencheur externe, puis définissez les propriétés d'ordonnancement et les dépendances pour tous les nœuds dans DataWorks. Pour plus d'informations, consultez les sections Création d'un nœud de déclenchement HTTP et Configuration d'un déclencheur dans un système d'ordonnancement externe.

• Le nœud de déclenchement HTTP possède un ou plusieurs nœuds ancêtres

  Dans ce scénario :

  • Créez le nœud de déclenchement HTTP, configurez le déclencheur externe, puis définissez les propriétés d'ordonnancement et les dépendances pour tous les nœuds dans DataWorks. Pour plus d'informations, consultez les sections Création d'un nœud de déclenchement HTTP et Configuration d'un déclencheur dans un système d'ordonnancement externe.

  • Par défaut, un nœud de déclenchement HTTP dépend du nœud racine du workflow. S'il possède d'autres nœuds ancêtres, modifiez manuellement la dépendance pour la faire pointer vers le nœud ancêtre correct.

  • Le nœud de déclenchement HTTP lance ses nœuds descendants uniquement après l'exécution réussie de ses nœuds ancêtres et la réception d'une requête de déclenchement envoyée par le système d'ordonnancement externe.

    Si le système externe envoie la requête de déclenchement avant la fin de l'exécution des nœuds ancêtres, le nœud de déclenchement HTTP met la requête en attente. Une fois les nœuds ancêtres achevés, le nœud lance ses descendants.

    Important

    Cette requête de déclenchement est conservée pendant 24 heures seulement. Si les nœuds ancêtres ne sont pas terminés dans ce délai, la requête expire.

Un nœud de déclenchement HTTP s'exécute uniquement si les conditions suivantes sont remplies :

• Une instance cyclique doit exister pour le nœud. Vous pouvez trouver cette instance dans la section Auto Triggered Instances de la page Cycle Instance. Tant que l'API RunTriggerNode n'a pas été appelée avec succès, l'instance reste dans un état d'attente de déclenchement, bloquant ainsi ses nœuds descendants. Une fois l'appel réussi, le nœud s'exécute.

• Tous les nœuds ancêtres ont été exécutés avec succès.

• L'heure planifiée du nœud est arrivée.

• Le groupe de ressources d'ordonnancement du nœud dispose de ressources suffisantes.

• Le nœud de déclenchement HTTP n'est pas gelé.

• Un nœud ne peut être déclenché que s'il se trouve dans un état d'attente de déclenchement. Une instance ayant abouti ne peut pas être déclenchée à nouveau.

Pour configurer le déclencheur externe, appelez la version 2020-05-18 de l'API RunTriggerNode selon l'une des méthodes suivantes pour démarrer le nœud.

• Java

  1. Installez le SDK Java . Pour plus d'informations, consultez la section Prise en main.

     Utilisez la configuration pom suivante pour le SDK DataWorks.

     <dependency>
       <groupId>com.aliyun</groupId>
       <artifactId>dataworks_public20200518</artifactId>
       <version>8.0.0</version>
     </dependency>

  2. Exemple de code

     Accédez à la page de débogage RunTriggerNode et consultez l'exemple Java complet dans l'onglet SDK Sample. Dans OpenAPI Explorer, sur la page RunTriggerNode (exécuter un nœud de déclenchement), définissez l'Endpoint sur China (Shanghai). Dans l'onglet Parameter Configuration à gauche, renseignez les paramètres obligatoires suivants : NodeId (ID du nœud de déclenchement), CycleTime (horodatage en millisecondes à 13 chiffres de la tâche correspondant au nœud de déclenchement), BizDate (horodatage de la date métier de l'instance où réside le nœud de déclenchement) et AppId (ID de l'espace de travail DataWorks auquel appartient le nœud de déclenchement). À droite, sélectionnez l'onglet SDK Sample et choisissez le langage Java pour afficher l'exemple de code du SDK Java. Dans le code, l'endpoint est dataworks.cn-shanghai.aliyuncs.com et vous pouvez utiliser une paire AccessKey (AK&SK) pour initialiser le client. Cliquez sur Run Sample pour effectuer l'appel, ou sur Download Full Project pour obtenir le code complet.

• Python

  1. Installez le SDK Python . Pour plus d'informations, consultez la section Intégration d'un SDK.

     Exécutez la commande suivante pour installer le SDK DataWorks.

     pip install aliyun-python-sdk-dataworks-public==2.1.2

  2. Exemple de code

     Accédez à la page de débogage RunTriggerNode et consultez l'exemple Python complet dans l'onglet SDK Example. Sur la page de l'API RunTriggerNode dans OpenAPI Explorer, basculez le langage sur Python, sélectionnez China (Shanghai) comme endpoint et saisissez les quatre paramètres requis dans la zone des paramètres d'entrée : NodeId, CycleTime, BizDate et AppId. La zone de code à droite génère automatiquement un exemple de code du SDK Python incluant la logique d'initialisation du client pour le SDK alibabacloud_dataworks_public20200518 (création d'un client de compte à l'aide d'une paire AccessKey). Vous pouvez cliquer sur Run Example pour déboguer en ligne, ou sur Download Full Project pour obtenir le code complet.

• Appel d'API

  Pour plus de détails sur l'appel de l'API, consultez la section RunTriggerNode.