View a markdown version of this page

Exception-Fehler im abgelaufenen Iterator - Amazon Kinesis Data Streams

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Exception-Fehler im abgelaufenen Iterator

Ausnahmefehler bei abgelaufenen Iteratoren (HTTP 400) treten auf, wenn der Shard-Iterator abgelaufen ist und beim Aufruf nicht mehr zum Abrufen von Stream-Datensätzen verwendet wird. GetRecords Dies tritt auf, wenn es zu Verzögerungen zwischen Lesevorgängen kommt, die durch lang andauernde Datenverarbeitungsaufgaben, Netzwerkprobleme oder Anwendungsausfälle verursacht werden.

Anmerkung

Ein Shard-Iterator ist ab dem Zeitpunkt seiner Ausgabe noch 5 Minuten gültig.

Empfehlungen für den Umgang mit Ausnahmen

  • Shard-Iteratoren werden aktualisiert, bevor sie ablaufen.

  • Integration der Fehlerbehandlung, um neue Iteratoren zu erhalten.

  • Verwendung der Kinesis Kinesis Client Library (KCL), die den Ablauf des Shard-Iterators automatisch verwaltet.

Weitere Informationen finden Sie unter Was ist? AWS Fault Injection Service

Um ein einfaches Experiment durchzuführen

  1. Erstellen Sie eine Experimentvorlage: Verwenden Sie die AWS FIS Konsole.

  2. Wählen Sie die Aktion aus: Verwenden Sie die aws:kinesis:inject-api-expired-iterator-exception Aktion.

  3. Konfigurieren Sie die Ziele: Geben Sie die IAM-Rolle und die Kinesis Data Streams-Operationen an.

  4. Legen Sie die Dauer fest: Beginnen Sie mit 5-10 Minuten für die ersten Tests.

  5. Stoppbedingungen hinzufügen: Stoppbedingungen für AWS FIS.

  6. Führen Sie das Experiment aus: Überwachen Sie das Verhalten der Anwendung.

Einzelheiten zur Aktion

  • Ressourcentyp: IAM-Rolle ARN

  • Zieloperationen: GetRecords

  • Fehlercode: ExpiredIteratorException (HTTP 400)

  • Beschreibung: Der bereitgestellte Iterator überschreitet das zulässige Höchstalter und simuliert Szenarien, in denen die Verarbeitung von Datensätzen zu langsam ist oder die Checkpoint-Logik fehlschlägt.

Parameters

  • IAM-Rolle ARN: Die Rolle, die Ihre Anwendung für Kinesis Data Streams Streams-Operationen verwendet.

  • Operationen: Zieloperationen: GetRecords

  • Ressourcenliste: die spezifischen Stream-Namen oder ARNs.

  • Dauer: Die Dauer des Experiments. Dies ist konfigurierbar.

  • Intensität: Der Prozentsatz der Drosselungsanfragen.

Erforderliche Berechtigungen

  • kinesis:InjectApiError