Geplante Nachrichtenübermittlung

QStash sendet HTTP-Anfragen nach einem festen Zeitplan oder nach einer Verzögerung und hält jeden Job bis zu seiner Zustellungszeit zurück. Ein Beam-Agent überwacht anstehende Zeitpläne und Payload-Datensätze. Wenn ein Job fällig ist, wendet er die Kundenregel an, um den Ziel-Endpunkt und die Header zu bestätigen, bevor er den Aufruf freigibt. Zustellungsergebnisse werden in das Ausführungsprotokoll zurückgeschrieben, und erfolgreiche Callbacks schließen das Element selbstständig. Wenn ein Zeitplan auf einen Endpunkt verweist, den die Regel nicht erkennt, oder eine Payload die Validierung nicht besteht, hält der Agent den Job an und benachrichtigt einen Techniker, anstatt eine unverifizierte Anfrage an einen Live-Dienst zu senden.

Fehlgeschlagene Wiederholungsversuche und Dead-Letter-Queues

QStash wiederholt Anfragen, die Fehler zurückgeben, und verschiebt fehlgeschlagene Nachrichten zur späteren Überprüfung in eine Dead-Letter-Queue. Ein Beam-Agent liest die Anzahl der Wiederholungsversuche und Antwortcodes aus und wendet bei wiederholtem Fehlschlagen die genehmigte Regel an, um die Nachricht erneut in die Warteschlange zu stellen, zu verzögern oder zu parken. Jede Entscheidung wird im ursprünglichen Job protokolliert, sodass der Verlauf für Audits transparent bleibt. Nachrichten, die die Dead-Letter-Queue aus Gründen außerhalb der Regel erreichen – wie beispielsweise ein unbekannter Statuscode oder ein Ausfall des Downstream-Dienstes –, werden an einen Mitarbeiter eskaliert, wobei die Antwortdetails für eine manuelle Entscheidung beigefügt werden.

Steuerung des Warteschlangen-Gegendrucks (Backpressure)

QStash begrenzt, wie viele Nachrichten gleichzeitig an einen Endpunkt fließen, damit Downstream-Dienste nicht von einer Spitze überlastet werden. Ein Beam-Agent liest die Warteschlangentiefe und die aktuellen Rateneinstellungen aus. Wenn das Volumen einen genehmigten Schwellenwert überschreitet, passt er die Parallelität an oder pausiert die Aufnahme gemäß der Kundenregel. Die Änderung und ihr Grund werden für eine spätere Überprüfung protokolliert. Wenn eine Warteschlange nach der Drosselung weiter wächst oder der Zieldienst dauerhafte Fehler meldet, stoppt der Agent die automatischen Änderungen und leitet die Situation an einen Bereitschaftstechniker weiter, wobei die aktuellen Metriken für diesen zusammengefasst werden.