Polling-Schleife für asynchrone KI-Generierung mit Replicate - n8n-Workflow

• KI-Entwickler oder Content Creator, die Replicate-Modelle für zeitintensive Generierungsaufgaben nutzen.


• Anwender, die eine verlässliche n8n-Workflow-Vorlage zur Abwicklung asynchroner API-Aufrufe suchen.


• Automatisierungsspezialisten, die eine stabile Steuerung der Kernlogik, einschließlich Polling-Schleifen, in n8n implementieren müssen.

Die Abwicklung zeitaufwendiger Prozesse in der Automatisierung, wie z.B. komplexe KI-Modellgenerierungen, erfordert asynchrone Logik. Dieser spezifische n8n-Workflow löst die gängige Hürde, auf einen externen Dienst (Replicate) zu warten, ohne die gesamte Ausführung lahmzulegen. Durch den Einsatz einer n8n-Knotenschleife startet diese n8n-Vorlage die Generierung des Dessix Moss-TTSD-Modells (oder ähnlicher) und wechselt anschließend in eine Polling-Sequenz. Diese Vorgehensweise, die für professionelle n8n-Setups unerlässlich ist, stellt sicher, dass keine Ressourcen verschwendet werden und der Workflow nur dann weiterläuft, wenn der externe Prozess einen Erfolg meldet. Diese Kernlogiksteuerung ist ein mächtiges Feature der n8n-Plattform und macht diesen n8n-Workflow für jede API, die auf Hintergrundverarbeitung setzt, sehr gut wiederverwendbar.

Diese Automatisierung startet mit dem n8n-Trigger „Bei Klick auf ‚Ausführen‘“ (On clicking 'execute'), ausgelegt für manuelle Tests oder zeitgesteuerte Ausführungen.

1. Initialisierung: Der Workflow nutzt zunächst einen n8n-Knoten, um den Replicate API-Schlüssel sicher als wiederverwendbare Variable zu hinterlegen.


2. Vorhersage erstellen (Prediction Creation): Ein HTTP Request n8n-Knoten sendet eine POST-Anfrage an die Replicate API, um den KI-Generierungsauftrag zu initiieren (unter Verwendung der spezifischen Modellversion).


3. ID-Extraktion: Ein Code n8n-Knoten, ‚Extract Prediction ID‘, analysiert die initiale API-Antwort, um die eindeutige predictionId zu extrahieren und die für das Polling nötige URL aufzubauen.


4. Polling-Start & Wartezeit: Der Workflow tritt über den n8n-Knoten ‚Wait‘ in die asynchrone Schleife ein und pausiert die Ausführung für 2 Sekunden, um übermäßige API-Anfragen zu verhindern.


5. Statusabfrage: Ein weiterer HTTP Request n8n-Knoten, ‚Check Prediction Status‘, ruft den aktuellen Jobstatus unter Verwendung der extrahierten Vorhersage-URL und des API-Schlüssels ab.


6. Bedingte Prüfung (Kernlogikflusssteuerung): Ein If n8n-Knoten entscheidet, ob der Jobstatus auf ‚succeeded‘ steht. Ist dies nicht der Fall, folgt der Workflow dem FALSE-Pfad und springt zurück zum ‚Wait‘ n8n-Knoten, wodurch der Polling-Zyklus neu gestartet wird. Diese Schleife ist der Kern des asynchronen n8n-Workflows.


7. Ergebnisverarbeitung: Bei Erfolg folgt der Workflow dem TRUE-Pfad zum Code n8n-Knoten ‚Process Result‘, welcher das Endergebnis bereinigt und strukturiert, typischerweise liefert er die resultierende Asset-URL (z.B. Sprachdatei oder Textausgabe).

Um diesen sehr effizienten n8n-Workflow nutzen zu können, gehen Sie bitte wie folgt vor:

1. n8n-Workflow importieren: Kopieren Sie den bereitgestellten JSON-Code und importieren Sie ihn direkt in Ihre n8n-Instanz über den Bereich „Workflows“, indem Sie die Schaltfläche „Neu“ verwenden und „Aus JSON importieren“ auswählen.


2. Zugangsdaten setzen: Diese n8n-Vorlage verwendet eine generische Authentifizierungsstrategie über HTTP-Header, aber der API-Schlüssel selbst wird im n8n-Knoten „Set API Key“ hinterlegt.


3. API-Schlüssel einrichten: Öffnen Sie den n8n-Knoten „Set API Key“ und ersetzen Sie den Platzhalter YOURREPLICATEAPIKEY durch Ihren tatsächlichen Replicate API-Schlüssel. Achten Sie darauf, dass dieser Schlüssel in den HTTP-Header-Definitionen der nachfolgenden HTTP Request-Knoten mit ‚Bearer ‘ vorangestellt wird, wie im Ausdruck definiert: ={{ 'Bearer ' + $('Set API Key').item.json.replicateapi_key }}.


4. Test: Führen Sie den n8n-Workflow manuell über die Schaltfläche „Workflow ausführen“ aus, um die Polling-Logik und die API-Verbindung zu überprüfen.

Bei Klick auf ‚Ausführen‘ (n8n-Trigger): Der Startpunkt des n8n-Workflows. Es handelt sich um einen manuellen Trigger, der den Generierungsprozess zu Demonstrations- und Testzwecken anstößt.
API-Schlüssel setzen (n8n-Knoten): Essentiell für die Sicherheit. Er definiert die Variable replicateapikey und macht den API-Schlüssel über Ausdrücke für nachfolgende HTTP Request-Knoten einfach zugänglich.
Vorhersage erstellen (HTTP Request n8n-Knoten): Initiiert den langlaufenden Task durch das Senden einer POST-Anfrage. Er nutzt die Replicate API und beinhaltet die erforderliche Modellversion sowie die Input-Parameter.
Vorhersage-ID extrahieren (Code n8n-Knoten): Analysiert die initiale JSON-Antwort, um die wichtige id der Vorhersage zu isolieren, die für die Statusüberwachung benötigt wird. Dieser Custom n8n-Knoten bereitet die Datenstruktur für die Polling-Schleife vor.
Warten (n8n-Knoten): Implementiert eine notwendige Verzögerung (2 Sekunden) in der Polling-Schleife, um bei der Wartezeit auf den Abschluss der KI-Generierung Probleme mit der Ratenbegrenzung (Rate-Limiting) der externen API zu vermeiden. Dies ist entscheidend für einen stabilen n8n-Workflow.
Vorhersagestatus prüfen (HTTP Request n8n-Knoten): Wird innerhalb der Polling-Schleife wiederholt aufgerufen, wobei die in den vorherigen Schritten ermittelte Vorhersage-URL verwendet wird. Er ruft den aktuellen Status des KI-Jobs ab.

• Auf Erfolg prüfen (If n8n-Knoten): Das zentrale Steuerungsgate der Logik. Es prüft, ob $json.status gleich ‚succeeded‘ ist. Wenn nicht, folgt der Ablauf dem FALSE-Pfad und springt zurück zum ‚Wait‘ n8n-Knoten. Ist dies wahr, fährt der n8n-Workflow mit der Verarbeitung des Endergebnisses fort.