Asynchroner Manager für parallele Aufgaben mittels Wait-Nodes - n8n-Workflow

Fortgeschrittene n8n-Benutzer: Personen, die komplexe, nicht-lineare Ausführungspfade verwalten müssen.
Systemintegratoren: Entwickler, die Stapelverarbeitungen oder ETL-Jobs ausführen, bei denen lange Wartezeiten für externe Systeme anfallen.
Leistungsoptimierer: Diejenigen, die den Durchsatz ihres n8n-Workflows verbessern möchten, indem sie Teilaufgaben gleichzeitig ausführen.
n8n-Automatisierungsspezialisten: Benutzer, die fortgeschrittene Funktionen des n8n Wait-Nodes und asynchrone Aufrufe erkunden.

Bei langlaufenden Operationen – wie Videoverarbeitung, komplexes Daten-Crunching oder API-Aufrufe, die Polling erfordern – kann ein standardmäßiger linearer n8n-Workflow blockiert werden, was potenziell zu Timeouts oder übermäßigem Zeitverbrauch führt. Dieser spezialisierte n8n-Workflow löst dies durch die Nutzung eines asynchronen Musters.

Diese robuste n8n-Vorlage verwendet den Execute Workflow n8n-Node, um parallele Teilaufgaben (Worker) zu starten, und den leistungsstarken Wait n8n-Node, um den Haupt-Orchestrator anzuhalten, bis diese Teilaufgaben abgeschlossen sind und über einen eindeutigen Webhook zurückmelden. Dies ermöglicht es der primären Ausführung, effizient zu warten, zahlreiche parallele Threads zu verwalten, die Ressourcennutzung zu maximieren und Timeouts zu verhindern. Wenn Sie nach zuverlässigen n8n-Vorlagen für Hochleistungsautomatisierung suchen, ist dieses asynchrone Design entscheidend.

Dieser n8n-Workflow arbeitet in zwei unterschiedlichen Modi: dem Orchestrator (Haupt-Flow) und dem Worker (Sub-Flow), wobei rekursive Aufrufe derselben n8n-Workflow-Definition genutzt werden.

Orchestrator-Flow (Initiierung und Sammlung)

1. Start n8n Trigger: Der Prozess beginnt mit dem manuellen Start n8n-Trigger.


2. Parallele Ausführung: Der n8n-Workflow verzweigt sich sofort und verwendet zwei Execute Workflow-Nodes (Call 1 und Call 2). Entscheidend ist, dass der Parameter waitForSubWorkflow auf false gesetzt ist, wodurch die Aufrufe nicht blockierend (asynchron) werden.


3. Übermittlung der Wiederaufnahme-Details: Jeder Aufruf übergibt spezifische Parameter (wait-Dauer und einen eindeutigen webhook-Suffix) an den Worker. Die Webhook-URL ist die resumeUrl der Haupt-n8n-Ausführung, die es dem Worker ermöglicht, zurückzurufen.


4. Warten auf Ergebnisse: Der Haupt-n8n-Workflow trifft dann auf zwei dedizierte Wait n8n-Nodes (Wait for Webhook 1 und Wait for Webhook 2). Die Ausführung hält unbegrenzt (oder für ein festgelegtes Limit) an, bis die Worker-Flows die jeweiligen Webhook-Endpunkte (/call1 und /call2) erfolgreich aufrufen.


5. Zusammenführen und Summieren: Sobald beide parallelen Aufgaben ihre Ergebnisse gemeldet haben, kombiniert der Merge n8n-Node die Payloads, und der Sum n8n-Node berechnet das Gesamtergebnis aus den parallelen Operationen.

Worker-Flow (Aufgabensimulation und Meldung)

1. Worker-Trigger: Der Sub-Workflow startet über den Call Entry Point n8n-Trigger (einen Execute Workflow Trigger), wenn er vom Orchestrator aufgerufen wird.


2. Simulierte Langzeitaufgabe: Der Wait Seconds n8n-Node pausiert den Flow für die vom Orchestrator angeforderte Dauer (z. B. 5 Sekunden für Call 1, 3 Sekunden für Call 2) und simuliert so die langlaufende Aufgabe.


3. Rückmeldung: Der Request Webhook n8n-Node verwendet die eingegebene webhook-URL, um eine HTTP-Anfrage zurück an den Wait n8n-Node des Haupt-n8n-Workflows zu senden. Dieser Aufruf transportiert das berechnete Ergebnis und signalisiert dem Haupt-Flow, fortzufahren.

Um diese n8n-Vorlage bereitzustellen und diese parallele Verarbeitungstechnik zu nutzen, gehen Sie wie folgt vor:

1. Importieren: Kopieren Sie die bereitgestellten JSON-Daten und importieren Sie sie direkt über das Menü 'Neu' > 'Aus JSON importieren' in Ihre n8n-Instanz. Dieser eine Import definiert sowohl die Orchestrator- als auch die Worker-Logik.


2. Selbstverweis-Prüfung: Da dieser n8n-Workflow sich rekursiv selbst aufruft, stellen Sie sicher, dass der workflowId-Parameter in den Execute Workflow n8n-Nodes Call 1 und Call 2 auf die ID des neu importierten Workflows verweist. Er sollte den Selbstverweis automatisch erkennen, aber überprüfen Sie dies bei einem Ausführungsfehler.


3. Anmeldeinformationen: Dieser spezifische n8n-Workflow verwendet Basis-n8n-Nodes (Manual Trigger, Wait, Execute Workflow, HTTP Request) und erfordert keine externen Anmeldeinformationen.


4. Ausführung: Führen Sie den Start n8n-Trigger manuell aus. Beobachten Sie, wie der Workflow sich aufteilt, die zeitgesteuerten Aufgaben asynchron ausführt und dann auf die Webhooks wartet, um die Zusammenfassung fortzusetzen und abzuschließen.

Start (n8n Trigger): Ein Manual Trigger n8n-Trigger, der ausschließlich zur Initiierung des Haupt-Orchestrator-n8n-Workflows für Testzwecke dient.
Call Entry Point (n8n Trigger): Der dedizierte Execute Workflow Trigger, der die eingehenden Aufrufe vom Haupt-Flow bearbeitet. Er akzeptiert die Parameter wait (Zahl) und webhook (String), die für die Worker-Aufgabe erforderlich sind.
Call 1 / Call 2 (Execute Workflow n8n node): Diese Nodes sind entscheidend für die Parallelisierung. Sie rufen denselben n8n-Workflow (diese Vorlage) auf, sind aber mit waitForSubWorkflow: false konfiguriert, um eine asynchrone Ausführung zu gewährleisten. Sie übergeben eindeutige wait-Zeiten und die vollständige Webhook-URL zur Wiederaufnahme.
Wait Seconds (Wait n8n node): Dieser n8n-Node befindet sich im Worker-Pfad und pausiert die Ausführung für eine dynamische Zeitdauer, definiert durch den Eingangsparameter ={{ $('Call Entry Point').item.json.wait }}.
Request Webhook (HTTP Request n8n node): Der letzte Schritt des Worker-Flows. Er fordert dynamisch die vom Orchestrator bereitgestellte resumeUrl (={{ $('Call Entry Point').item.json.webhook }}) an und transportiert dabei die Ergebnis-Payload, um den Haupt-n8n-Workflow fortzusetzen.
Wait for Webhook 1 / Wait for Webhook 2 (Wait n8n node): Diese Nodes befinden sich im Orchestrator-Pfad und stoppen die Ausführung. Sie warten gezielt auf einen passenden Webhook-Aufruf (unter Verwendung eines Suffix wie /call1 oder /call2), um das asynchrone Ergebnis zu liefern, bevor der n8n-Workflow fortfahren kann.

• Merge / Sum (n8n node): Standardmäßige Aggregations-Nodes, die verwendet werden, um die von den Wait-Nodes empfangenen Ergebnisse zu kombinieren und die Gesamtsumme zu berechnen, was eine erfolgreiche asynchrone Datensammlung demonstriert.