Modèle de Division et Reprise de Flux de Travail Asynchrone - Workflow n8n

• Utilisateurs avancés de n8n ayant besoin de gérer des processus asynchrones.


• Développeurs créant des intégrations de longue durée nécessitant des services externes chronophages.


• Toute personne concevant des modèles n8n complexes où une exécution principale doit se mettre en pause et attendre un événement de déclenchement n8n secondaire.

Ce flux de travail n8n avancé démontre une technique cruciale pour gérer les processus qui nécessitent une période d'attente significative ou qui impliquent un système externe indépendant déclenchant un rappel. Lorsqu'une exécution n8n typique rencontre un long délai, elle risque d'atteindre le délai d'attente (timeout). Ce modèle de flux de travail n8n résout ce problème en initiant une 'Exécution Principale' qui se met en pause à l'aide du nœud spécialisé Wait de n8n. Il génère une resumeUrl unique qui est ensuite transmise à une 'Exécution Secondaire' (qui peut être un flux de travail n8n distinct ou un système externe). L'Exécution Secondaire effectue les étapes nécessaires (comme récupérer des données ou attendre une réponse externe) et utilise la resumeUrl pour déclencher un rappel, reprenant ainsi l'Exécution Principale d'origine. Cela permet au flux Principal d'accéder aux données de contexte collectées à la fois avant la pause et pendant le processus Secondaire, ce qui en fait un mécanisme de contrôle de flux n8n puissant.

Ce flux de travail n8n fonctionne en deux phases principales : l'Exécution Principale et le Processus Secondaire/Indépendant.

Exécution Principale

1. Déclencheur n8n Initial : L'exécution commence par le déclencheur manuel n8n Lorsque vous cliquez sur 'Tester le flux de travail'.


2. Définition du Contexte : Le nœud n8n Définir le Contexte de l'Exécution Principale stocke les variables nécessaires pour le reste du flux.


3. Lancement du Flux Secondaire : Le nœud n8n Requête HTTP - Lancer le Processus Indépendant appelle le webhook du Processus Secondaire, en transmettant de manière cruciale $execution.resumeUrl comme paramètre de charge utile (payload).


4. Pause : Le flux Principal atteint le nœud n8n Attendre (Wait), suspendant son exécution indéfiniment jusqu'à ce que son URL de rappel webhook unique (dérivée de l'URL de reprise) soit sollicitée.


5. Reprise : Une fois que le Processus Secondaire exécute le rappel, l'exécution Principale reprend au niveau du nœud Attendre.


6. Fusion des Données : Le nœud n8n Ce Nœud Peut Accéder aux Données Principales et Secondaires démontre comment les données stockées avant l'attente et les données renvoyées via le rappel (provenant du Processus Secondaire) sont combinées.

Processus Secondaire/Indépendant

1. Déclencheur n8n Indépendant : Le déclencheur n8n Webhook démarre cette exécution distincte, recevant la resumeUrlForWaitingExecution et le contexte.


2. Simulation Externe : Ce processus simule un travail, récupérant des données (comme une blague aléatoire depuis Requête HTTP - Obtenir une Blague Aléatoire) et attendant une courte période.


3. Rappel : Le nœud n8n Simuler l'Événement qui Déclenche le 2ème Déclencheur/Flux (une Requête HTTP) utilise la resumeUrl reçue pour envoyer une requête POST de retour au nœud Attendre de l'Exécution Principale, en transmettant les données collectées (comme la blague) dans le corps de la requête. Cette action reprend l'exécution du flux n8n d'origine.

Pour utiliser ce modèle de flux de travail n8n complexe, suivez ces étapes :

1. Importation : Copiez l'intégralité du JSON du flux de travail n8n et importez-le dans votre instance n8n.


2. Séparation : Notez que ce fichier contient deux flux (Principal et Secondaire). Pour une utilisation en production, les nœuds étiquetés 'Processus Externe Indépendant Simulé' (commençant par le nœud Webhook à la position [280, 1260] et ses successeurs) doivent idéalement être coupés et collés dans une instance de flux de travail n8n distincte.


3. Ajustement des URL : Étant donné que ce modèle implique une communication inter-flux de travail, vous devez vous assurer que tous les nœuds Requête HTTP n8n qui font référence à http://127.0.0.1:5678 sont mis à jour avec l'URL de votre instance n8n réelle si vous l'exécutez à distance.


4. Activation : Activez les deux flux de travail n8n, Principal et Secondaire.


5. Test : Exécutez le flux de travail Principal via le déclencheur manuel n8n pour observer l'action de division et de reprise.

• Lorsque vous cliquez sur 'Tester le flux de travail' (Déclencheur manuel n8n) : Lance l'Exécution Principale de ce flux de travail n8n.


• Définir le Contexte de l'Exécution Principale (Nœud Set n8n) : Stocke les éléments de contexte initiaux, y compris un identifiant de remplacement pour le flux de travail externe simulé, qui est utilisé à l'étape suivante.


• Requête HTTP - Lancer le Processus Indépendant (Nœud Requête HTTP n8n) : Envoie une requête pour démarrer le Processus Secondaire. La configuration critique consiste à transmettre {{ $execution.resumeUrl }} pour permettre au flux secondaire de rappeler et de reprendre l'exécution Principale.


• Attendre (Nœud Wait n8n) : Met en pause l'Exécution Principale indéfiniment, transformant le flux en un écouteur webhook en attente, attendant un rappel POST vers son resumeUrl unique.


• Recevoir l'Entrée du Processus Externe et Indépendant (Déclencheur n8n Webhook) : Sert de déclencheur n8n indépendant pour le Processus Secondaire, capturant la resumeUrlForWaitingExecution transmise par le flux Principal.


• Requête HTTP - Reprendre l'Exécution de l'Autre Flux (Nœud Requête HTTP n8n) : La dernière étape du Processus Secondaire. Il construit une requête HTTP POST ciblant le resumeUrl de l'exécution principale, reprenant ainsi le flux de travail n8n initialement mis en pause. Il transmet également de nouvelles données (par exemple, les détails de la blague) en retour.


• Ce Nœud Peut Accéder aux Données Principales et Secondaires (Nœud Set n8n) : Démontre la portée des données en accédant aux variables du contexte principal initial (Définir le Contexte de l'Exécution Principale) et aux variables renvoyées par le webhook repris (via le nœud Attendre).