Asynchrone KI-Generierung mithilfe einer Replicate-Abfrageschleife - n8n-Workflow

KI-Entwickler & Integratoren: Anwender, die langlaufende, asynchrone KI-Modelle (wie die auf Replicate gehosteten) in ihre Standardgeschäftsprozesse integrieren müssen.
n8n Power-User: Personen, die nach fortgeschrittenen Beispielen für die Verwendung des Code-n8n-Nodes und von Flusssteuerungsstrukturen (If und Wait) zur Handhabung externer APIs suchen.
Spezialisten für Content-Automatisierung: Alle, die zuverlässige n8n-Vorlagen zur Erstellung kreativer Inhalte basierend auf Prompts suchen.
Technische Automatisierer: Anwender, die einen robusten n8n-Trigger-Mechanismus benötigen, um komplexe Rechenjobs zu starten.

Die Generierung komplexer Inhalte erfordert oft die asynchrone Ausführung von Jobs. Das bedeutet, dass die erste Anfrage sofort einen Status zurückgibt, die endgültige Ausgabe jedoch verzögert wird. Dieser robuste n8n-Workflow löst dieses Problem durch die Implementierung einer benutzerdefinierten, nicht blockierenden Abfragesequenz, die auf die Replicate API zugeschnitten ist.

Im Gegensatz zu einfacheren Integrationen gewährleistet diese n8n-Vorlage Zuverlässigkeit, indem sie die Vorhersage initiiert, die Job-ID extrahiert und dann kontinuierlich alle zwei Sekunden den Status überprüft, bis der Job erfolgreich ist. Die Verwendung des httpRequest-n8n-Nodes in Kombination mit der Datenmanipulation im Code-n8n-Node bietet ein leistungsstarkes und wiederverwendbares Framework für die Integration jedes asynchronen Dienstes in Ihre n8n-Umgebung. Diese Struktur ist unerlässlich für den Aufbau missionskritischer Automatisierungen mit n8n.

Dieser leistungsstarke n8n-Workflow beginnt mit einem manuellen n8n-Trigger:

1. Initialisierung: Der Workflow wird manuell über den n8n-Trigger 'On clicking 'execute'' ausgeführt. Unmittelbar danach injiziert der n8n-Node 'Set API Key' Ihren Replicate API-Schlüssel sicher als Variable für nachfolgende HTTP-Anfragen.


2. Vorhersage starten: Der n8n-Node 'Create Prediction' (eine HTTP-Anfrage) sendet eine POST-Anfrage an Replicate, in der die Modellversion und der erforderliche Eingabeprompt angegeben werden. Dies startet den asynchronen KI-Job.


3. Extraktion: Die Antwort der Erstellungsanfrage enthält die Job-ID. Der Code-n8n-Node 'Extract Prediction ID' parst diese Antwort und speichert die Vorhersage-ID sowie die für das Polling benötigte URL.


4. Eintritt in die Abfrageschleife: Die Ausführung tritt in die Abfrageschleife ein. Zuerst trifft sie auf den 'Wait'-n8n-Node, der den gesamten n8n-Workflow für 2 Sekunden pausiert, um übermäßige API-Aufrufe zu vermeiden.


5. Statusprüfung: Der httpRequest-n8n-Node 'Check Prediction Status' fragt anschließend die zuvor extrahierte Vorhersage-URL ab, um den aktuellen Status des KI-Jobs abzurufen.


6. Bedingte Prüfung: Der If-n8n-Node 'Check If Complete' wertet den Status aus. Wenn der Status 'succeeded' entspricht (wahrer Zweig), ist der Job beendet und der n8n-Workflow fährt mit der Ergebnisverarbeitung fort. Ist der Status etwas anderes (falscher Zweig), springt die Verbindung zurück zum 'Wait'-n8n-Node, um den Abfrageprozess bis zum Abschluss fortzusetzen.


7. Ergebnisverarbeitung: Nach erfolgreichem Abschluss extrahiert der Code-n8n-Node 'Process Result' den endgültig generierten Inhalt (oft eine URL zum Asset) und formatiert ihn sauber für die Weiterverwendung in Ihrem n8n-Workflow.

Um diese n8n-Workflow-Vorlage zu verwenden, gehen Sie wie folgt vor:

1. Importieren: Kopieren Sie den bereitgestellten JSON-Code und importieren Sie ihn direkt in Ihre n8n-Instanz.


2. API-Schlüssel-Einrichtung (Replicate): Suchen Sie den n8n-Node 'Set API Key'.

1. Modelleingabe konfigurieren: Suchen Sie den n8n-Node 'Create Prediction'. Ändern Sie im JSON Body dieser Konfiguration den Wert von prompt und alle anderen Eingangsparameter (wie width, height usw.), um Ihren gewünschten Generierungsanforderungen zu entsprechen. Stellen Sie sicher, dass die Modellversion im JSON Body korrekt ist.


2. Ausführung: Führen Sie den n8n-Workflow manuell über die Schaltfläche 'Execute Workflow' auf dem n8n-Trigger-Node 'On clicking 'execute'' aus, um die Integration und die Abfrageschleife zu testen.

On clicking 'execute' (Manueller Trigger): Dient als Start-Trigger für den gesamten n8n-Workflow und ermöglicht die manuelle Ausführung für Tests und Konfigurationen.
Set API Key (Set): Ein kritischer n8n-Node, der zur sicheren Definition des Replicate API-Schlüssels verwendet wird, sodass er im gesamten restlichen n8n-Workflow als Ausdruck ($($Set API Key).item.json.replicateapikey) zugänglich ist.
Create Prediction (HTTP-Anfrage): Sendet die anfängliche asynchrone POST-Anfrage an die Replicate API und startet damit den KI-Generierungsjob. Er beinhaltet benutzerdefinierte Header für die Autorisierung mithilfe des zuvor definierten API-Schlüssels.
Extract Prediction ID (Code): Ein benutzerdefinierter Code-n8n-Node, der entscheidend für das Auslesen der Antwort der ursprünglichen Vorhersageanfrage ist. Er extrahiert die eindeutige predictionId und konstruiert die notwendige Polling-URL für nachfolgende Anfragen im n8n-Workflow.
Wait (Wait): Verwaltet die Flusssteuerung, indem der n8n-Workflow für eine festgelegte Dauer (2 Sekunden) pausiert wird, um schnelle API-Anfragen während der Abfrageschleife zu verhindern.
Check Prediction Status (HTTP-Anfrage): Führt eine GET-Anfrage über die extrahierte Vorhersage-URL aus, um den aktuellen Status des laufenden KI-Jobs zu überprüfen. Dies ist der Kernschritt des Pollings in dieser n8n-Vorlage.
Check If Complete (If): Ein n8n-Node zur Flusssteuerung, der die Logik des n8n-Workflows lenkt. Wenn der Status 'succeeded' ist, fährt er mit der Ergebnisbehandlung fort; andernfalls kehrt er zum 'Wait'-n8n-Node zurück, um das Polling fortzusetzen.
Process Result (Code): Der finale Code-n8n-Node, der nur bei Erfolg ausgeführt wird. Er strukturiert und extrahiert die fertiggestellte Ausgabe, einschließlich Metriken und der generierten Asset-URL, und bereinigt die Daten für die nächsten Schritte in Ihrem größeren n8n-Workflow.