DataWorks:Nœud de push de données

Fonctionnement

Un nœud de push de données utilise les paramètres Input and Output Parameters pour récupérer les paramètres de sortie des nœuds de requête SQL et des nœuds d'assignation en amont. Utilisez ensuite ces paramètres comme espaces réservés dans le corps du message avant de les envoyer vers une destination.

• Après l'exécution d'un nœud de requête SQL, celui-ci génère un paramètre outputs contenant les résultats de la requête et les transmet aux nœuds en aval. Pour plus d'informations, consultez la rubrique Configurer le contexte du nœud.

• Lors de la configuration du corps du message dans un nœud de push de données, utilisez le format ${Nom du paramètre} dans un composant Markdown pour référencer et afficher les paramètres de sortie d'un nœud en amont.

• Pour afficher les données dans un composant Tableau, sélectionnez les noms de champs issus de la requête SQL en amont dans les paramètres associés au composant.

Prérequis

• Le service DataWorks est activé. Pour plus d'informations, consultez le Guide d'achat.

• Un espace de travail DataWorks a été créé. Pour plus d'informations, consultez la rubrique Créer un espace de travail.

• Un workflow a été créé dans votre espace de travail DataWorks.

• Un groupe de ressources serverless est requis, car ce nœud ne s'exécute que sur ce type de groupe. Pour acheter et utiliser un groupe de ressources serverless, consultez la rubrique Utiliser des groupes de ressources serverless.

• L'accès au réseau public est activé pour le groupe de ressources. Pour plus d'informations, consultez la rubrique Présentation des solutions de connectivité réseau.

Limites

• Les limites de taille de données suivantes s'appliquent lors du push de données vers différentes destinations :

  • DingTalk : la taille du message ne doit pas dépasser 20 Ko.

  • Lark : la taille du message ne doit pas dépasser 20 Ko et les images doivent être inférieures à 10 Mo.

  • WeCom : chaque chatbot ne peut pas envoyer plus de 20 messages par minute.

  • Teams : la taille du message ne doit pas dépasser 28 Ko.

  • E-mail : chaque tâche de push de données prend en charge un seul corps d'e-mail. Pour les autres limitations, reportez-vous aux limites SMTP de votre fournisseur de services de messagerie.

• Le nœud de push de données est disponible uniquement dans les espaces de travail des régions suivantes : Chine (Hangzhou), Chine (Shanghai), Chine (Pékin), Chine (Shenzhen), Chine (Chengdu), Chine (Hong Kong), Singapour, Malaisie (Kuala Lumpur), États-Unis (Silicon Valley), États-Unis (Virginie) et Allemagne (Francfort).

1. Créer un nœud en amont

Un nœud de push de données récupère les Context Parameters du contexte d'un nœud en amont pour les transmettre à une destination. Avant de créer un nœud de push de données, créez un nœud de requête SQL ou un nœud d'assignation en amont.

2. Créer un nœud de push de données

1. Sur le canevas du workflow, cliquez sur pour créer un nœud de push de données.

   Paramètre	Description
   Node Type	Sélectionnez Data Push dans la liste déroulante.
   Path	Sélectionnez le chemin contenant le nœud en amont de l'étape 1.
   Name	Saisissez un nom pour le nœud.

2. Double-cliquez sur le nouveau nœud de push de données pour ouvrir sa page de configuration.

3. Dans le volet de droite, cliquez sur Properties. Sous Scheduling Dependency > Parent Nodes, cliquez sur Add pour définir le nœud créé à l'étape 1 comme dépendance en amont.

4. Dans le panneau Propriétés, sous Resource Group > Resource Group for Scheduling, sélectionnez un groupe de ressources serverless créé le 28 juin 2024 ou après cette date. Si votre groupe de ressources a été créé avant cette date, vous devez soumettre un ticket pour le mettre à niveau.

5. Dans le panneau Propriétés, sous Input and Output Parameters > Input Parameters, cliquez sur Add pour créer un paramètre d'entrée. Pour sa valeur, sélectionnez le paramètre de sortie du nœud de requête de l'étape 1. Fermez ensuite le panneau Scheduling .

6. Sur la page de configuration du nœud, configurez la destination, le titre et le corps du message.

   1. Dans la liste déroulante Destination , sélectionnez une destination. Si la destination souhaitée ne figure pas dans la liste, cliquez sur Create Data Push Destination pour la créer.

      Paramètre	Description
      Type	Types pris en charge : DingTalk, Lark, WeCom, Teams et E-mail.
      Object	Le nom de la destination.
      Webhook	L'URL Webhook d'un chatbot DingTalk, Lark ou WeCom ; le webhook entrant pour Teams ; ou les détails SMTP pour l'e-mail. Obtenez ces informations depuis la plateforme cible. Remarque Pour savoir comment obtenir un Webhook de bot Lark, consultez la rubrique Configurer un déclencheur Webhook Lark. Pour savoir comment obtenir un Webhook Teams, consultez la rubrique Utiliser les workflows Microsoft Teams pour créer un Webhook entrant.

      Pour gérer les destinations de push :

      1. Connectez-vous à la console DataWorks. Dans la région cible, cliquez sur Data Analysis and Service > DataService Studio dans le volet de navigation de gauche. Sélectionnez un espace de travail dans la liste déroulante et cliquez sur Go to DataService Studio.

      2. Sur la page Service Development , cliquez sur l'icône Paramètres dans le coin inférieur gauche et accédez à l'onglet Destination Management . Sur cet onglet, vous pouvez gérer les destinations existantes ou cliquer sur Create Data Push Destination pour en ajouter une nouvelle. Pour plus d'informations, consultez la rubrique Créer une destination de push de données Webhook.

   2. Name : saisissez un titre pour le message.

   3. Body : vous pouvez ajouter des composants Markdown et Tableau. Pour plus d'informations, consultez la rubrique Configurer le contenu du push.

      Remarque

      • Si le nœud en amont est un nœud de requête SQL :

        • Dans le corps Markdown d'un push de données, utilisez les noms de champs d'une requête SQL comme espaces réservés au format ${nom_du_champ} pour récupérer les paramètres de sortie en amont.

        • Pour les tableaux dans le corps d'un push de données, utilisez les noms de champs d'une requête SQL en amont comme Parameters pour récupérer les données.

      • Si le nœud en amont est un nœud d'assignation, vous devez utiliser un espace réservé au format ${Nom du paramètre d'entrée} dans le corps du message. ${Nom du paramètre d'entrée} correspond au nom des Input Parameters que vous avez configurés sur le nœud de push de données.

7. Cliquez sur l'icône Enregistrer pour enregistrer le nœud de push de données.

3. Exécuter et déployer la tâche

Après avoir configuré le workflow de push de données, testez-le pour vérifier qu'il s'exécute correctement, puis validez et déployez la tâche.

1. Sur le canevas du workflow, cliquez sur l'icône Exécuter pour exécuter le workflow.

2. Une fois que l'icône de succès apparaît sur tous les nœuds, cliquez sur l'icône Valider pour valider le workflow.

3. Dans la boîte de dialogue Submission , sélectionnez les nœuds que vous souhaitez valider et cochez la case Ignore I/O Inconsistency Alerts .

4. Cliquez sur Submission .

5. Une fois les nœuds validés avec succès, déployez-les. Pour plus d'informations, consultez la rubrique Publier des tâches.

Bonnes pratiques

Le nœud de push de données prend en charge plusieurs modèles de workflow : push simple, push combiné, push basé sur un script, push conditionnel et push MaxCompute. Pour plus d'informations, consultez la rubrique Bonnes pratiques : configurer un nœud de push de données dans un workflow.

Étapes suivantes

Après le déploiement, gérez la tâche dans Operation Center. Pour plus d'informations, consultez la rubrique Effectuer des opérations de maintenance de base sur les nœuds déclenchés automatiquement.