n8n Rate Limit: Backoff und Throttling für stabile Workflows

n8n Backoff selbst bauen: Wartezeit, die mitwächst

Trifft dein Workflow trotz Drossel auf ein n8n Rate Limit, das länger anhält, brauchst du einen echten Backoff. Dabei wartet jeder neue Versuch doppelt so lange wie der vorige. Google empfiehlt das für die Sheets API ausdrücklich, mit einem Zufallsanteil und einer Obergrenze von 32 oder 64 Sekunden. Dieser Jitter verhindert, dass viele gescheiterte Abläufe im selben Moment wieder anklopfen. Laut einer Simulation im Architektur-Blog von AWS schneidet Backoff ohne Jitter am schlechtesten ab.

Sub-Workflow mit vier Nodes aufbauen

Am saubersten baust du die Schleife in einen eigenen Sub-Workflow. Er beginnt mit dem Trigger When Executed by Another Workflow und enthält vier Nodes: HTTP Request, IF, Code und Wait. Im HTTP Request schaltest du unter Options, Response die Punkte Include Response Headers and Status und Never Error ein. So kommt eine 429 als normales Ergebnis mit statusCode und headers an, statt den Lauf abzubrechen.

Wartezeit im Code Node berechnen

Der IF Node prüft danach, ob statusCode gleich 429 oder mindestens 500 ist. Im Ja-Zweig rechnet daraufhin ein Code Node die Wartezeit aus:

// Versuch 0, 1, 2 … dieses Nodes
const versuch = $runIndex;
const maxVersuche = 5;
if (versuch >= maxVersuche) {
  throw new Error('Rate Limit: nach ' + maxVersuche + ' Versuchen aufgegeben');
}
const antwort = $input.first().json;
// Retry-After in Sekunden hat Vorrang
const retryAfter = Number(antwort.headers?.['retry-after']);
// sonst 1, 2, 4, 8, 16 s plus Jitter
const basis = Math.min(2 ** versuch, 64);
const wartezeit = retryAfter > 0 ? retryAfter : basis + Math.random();
return [{ json: { ...antwort, versuch, wartezeit: Math.round(wartezeit * 100) / 100 } }];

Danach folgt der Wait Node mit Resume After Time Interval, als Wait Amount der Ausdruck {{ $json.wartezeit }} und als Wait Unit Seconds. Vom Wait Node führt die Verbindung schließlich zurück zum HTTP Request. Die Reihe 1, 2, 4, 8, 16 Sekunden ergibt bei fünf Versuchen zusammen 31 Sekunden Wartezeit plus Jitter.

Wichtig dabei: Nach der ersten Runde enthält $json die Antwort der API, nicht mehr deine Daten. Greif im HTTP Request deshalb über den Trigger auf die Felder zu, etwa mit {{ $('When Executed by Another Workflow').first().json.email }}.

Sub-Workflow je Datensatz aufrufen

Im Haupt-Workflow rufst du den Sub-Workflow mit dem Node Execute Sub-workflow auf und stellst Mode auf Run once for each item. Jeder Datensatz bekommt so eine eigene Ausführung, deshalb zählt $runIndex für jeden wieder ab null, denn der Wert gibt laut n8n-Doku an, wie oft der aktuelle Node in der Ausführung schon lief.