Consultez les connecteurs compatibles avec Application Integration.

Tâche "Pour chaque parallèle"

La tâche Pour chaque parallèle vous permet d'exécuter d'autres intégrations (sous-intégrations) à partir de votre intégration principale. Comme son nom l'indique, les sous-intégrations s'exécutent en parallèle.

Cette tâche utilise l'ID de déclencheur de l'API comme "handle" pour identifier les intégrations à exécuter. Par exemple, si vous définissez l'ID de déclencheur de l'API comme étant api_trigger/APITriggerX, la tâche exécute toutes les sous-intégrations dotées de l'ID de déclencheur api_trigger/APITriggerX.

Après avoir exécuté une sous-intégration, vous pouvez également lire la réponse de la sous-intégration dans votre intégration principale. Utilisez cette tâche pour exécuter des sous-intégrations en tant que dépendances de l'intégration principale.

Avant de commencer

Configurer la tâche pour chaque parallèle

Pour configurer la tâche Pour chaque parallèle, procédez comme suit :

  1. Dans la console Google Cloud, accédez à la page Application Integration.

    Accéder à Application Integration

  2. Dans le menu de navigation, cliquez sur Integrations (Intégrations).

    La page Intégrations s'affiche, listant toutes les intégrations disponibles dans le projet Google Cloud.

  3. Sélectionnez une intégration existante ou cliquez sur Créer une intégration pour en créer une.

    Si vous créez une intégration :

    1. Saisissez un nom et une description dans le volet Create Integration (Créer une intégration).
    2. Sélectionnez une région pour l'intégration.
    3. Sélectionnez un compte de service pour l'intégration. Vous pouvez modifier ou mettre à jour les détails du compte de service d'une intégration à tout moment à partir du volet Integration summary (Résumé de l'intégration) dans la barre d'outils de l'intégration.
    4. Cliquez sur Créer.

    Cela entraîne son ouverture dans l'éditeur d'intégrations.

  4. Dans la barre de navigation de l'éditeur d'intégrations, cliquez sur Tâches pour afficher la liste des tâches et des connecteurs disponibles.
  5. Cliquez sur l'élément de tâche Pour chaque parallèle et placez-le dans l'éditeur d'intégrations.
  6. Cliquez sur l'élément de tâche Pour chaque parallèle dans l'éditeur afin d'ouvrir le volet de configuration de la tâche Pour chaque parallèle.
  7. Configurez les champs affichés à l'aide des propriétés de configuration de la tâche, comme indiqué dans les tableaux ci-dessous.

    Les modifications que vous avez apportées aux propriétés sont enregistrées automatiquement.

Propriétés de configuration

Cette section décrit les propriétés de configuration de la tâche Pour chaque parallèle.

Propriétés d'entrée

Nom de propriété Nom du paramètre Type de données Description
Sélection de tableau List to iterate Tableau de type "Chaîne", "Entier", "Double" ou JSON Liste des valeurs pour lesquelles les sous-intégrations doivent être exécutées. Un thread de sous-intégration distinct s'exécute pour chaque valeur de la liste, et tous les threads s'exécutent en parallèle.

Vous pouvez transmettre la valeur itérée à la sous-intégration en définissant le champ Où mapper les éléments de la liste individuelle.

Vous pouvez également transmettre des valeurs supplémentaires de l'intégration principale à la sous-intégration dans le champ Mapper avec des entrées supplémentaires de sous-intégration.

Détails de la sous-intégration API Trigger ID Chaîne ID du déclencheur de la sous-intégration diffusée à exécuter.

Cette valeur est disponible dans le champ ID du déclencheur du déclencheur d'API dans la sous-intégration.

Execution strategy ND

SYNC : exécute les sous-intégrations en mode synchrone. Dans ce mode, l'intégration principale attend que les sous-intégrations soient terminées avant de poursuivre les tâches en aval.

ASYNC : exécute les sous-intégrations en mode asynchrone. Dans ce mode, l'intégration principale n'attend pas que les sous-intégrations soient terminées. Immédiatement après l'appel des sous-intégrations, l'intégration principale exécute les tâches en aval.
Run all integrations with this API Trigger ID Non disponible Exécute toutes les intégrations ayant le même ID de déclencheur de l'API.

Par exemple, si l'intégration A et l'intégration B ont le même ID de déclencheur d'API, les intégrations A et B sont exécutées pour chaque élément de la liste à itérer.

Remarque : Si vous sélectionnez cette option, la réponse des sous-intégrations n'est pas disponible dans l'intégration principale. Si vous souhaitez utiliser la réponse des sous-intégrations, sélectionnez l'option Exécuter une seule intégration.

Run a single integration Non disponible Exécute uniquement l'intégration spécifiée dans le champ Nom de l'intégration. Vous pouvez utiliser les réponses des sous-intégrations en configurant la section Collecter les valeurs des sorties de sous-intégration.

À chaque exécution Where to map individual array elements Chaîne Nom de la variable d'entrée de sous-intégration dans laquelle les éléments du tableau doivent être mappés. Les éléments de tableau peuvent être directement mappés à une variable d'entrée de sous-intégration. Si une seule sous-intégration est sélectionnée, vous pouvez sélectionner la variable d'entrée de sous-intégration dans une liste déroulante.
Map to additional sub-integration input(s) Chaîne Option de mappage de sous-intégration supplémentaire.
  • Variable d'intégration depuis laquelle mapper : nom de la variable de l'intégration actuelle à transmettre à la variable d'entrée de sous-intégration.
  • Entrée de sous-intégration vers laquelle mapper : nom de la variable d'entrée de sous-intégration vers laquelle mapper.

Ce champ prend des valeurs sous la forme de paires clé/valeurs, où la clé est une variable dans l'intégration principale, et la valeur est la variable d'entrée correspondante dans la sous-intégration.

Par exemple, supposons que votre intégration principale possède la variable productID, que vous souhaitez mapper à la sous-variable d'intégration subIntProductID. Vous devez sélectionner productID dans le champ Variable d'intégration à mapper et saisir subIntProductID dans le champ Entrée de sous-intégration à laquelle mapper.
Collect values from sub-integration output(s) Chaîne Si la stratégie d'exécution est synchrone (SYNC) et qu'une seule sous-intégration (Exécuter une seule intégration) est sélectionnée, les sorties de la sous-intégration peuvent être collectées dans des variables de tableau dans l'intégration actuelle.
  • Sortie de sous-intégration depuis laquelle collecter : nom de la variable de sortie de sous-intégration à regrouper.
  • Variable d'intégration vers laquelle collecter : nom de la variable dans l'intégration actuelle destinée à collecter les sorties agrégées.
Paramètres d'exécution Integrations to execute at a time (parallel) Entier Nombre maximal d'exécutions parallèles autorisées pour les sous-intégrations. La valeur par défaut est 50 (10000 au maximum).

Toutes les sous-intégrations d'une cohorte s'exécutent complètement avant l'exécution de la prochaine cohorte de sous-intégrations.

Ignore failures Booléen

Vous pouvez spécifier l'une des valeurs suivantes :

  • True : la tâche ignore les échecs de sous-intégration et exécute toutes les exécutions.
  • False : la tâche échoue pour les échecs de sous-intégration et met fin à toutes les exécutions.

Bonnes pratiques

Nous vous recommandons d'appliquer les bonnes pratiques suivantes lorsque vous utilisez la tâche Pour chaque parallèle :

  • Définissez la taille de votre cohorte en fonction des limites de quota imposées par vos sous-intégrations.
  • Si vous souhaitez collecter les résultats de la sous-intégration en vue d'une utilisation ultérieure, utilisez une stratégie d'exécution SYNC.
  • Utilisez une stratégie d'exécution ASYNC lorsque votre sous-intégration peut durer plus de deux minutes.

Pour plus d'informations sur les limites d'utilisation qui s'appliquent à la tâche Pour chaque parallèle, consultez la section Limites d'utilisation.

Remarques

En général, n'utilisez pas de stratégie d'exécution SYNC si votre sous-intégration prend plus de deux minutes ou si vous prévoyez d'utiliser cette tâche avec des tâches naturellement asynchrones, telles que la tâche d'approbation.

Stratégie de traitement des erreurs

Une stratégie de traitement des erreurs d'une tâche spécifie l'action à effectuer si celle-ci échoue en raison d'une erreur temporaire. Pour en savoir plus sur l'utilisation et les différents types de stratégies de traitement des erreurs, consultez la page Stratégies de traitement des erreurs.

Quotas et limites

Pour plus d'informations sur les quotas et les limites, consultez la section Quotas et limites.

Étape suivante