View a markdown version of this page

Errori di eccezione dell'iteratore scaduti - Flusso di dati Amazon Kinesis

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Errori di eccezione dell'iteratore scaduti

Gli errori di eccezione dell'iteratore scaduto (HTTP 400) si verificano quando lo shard iterator è scaduto e non vengono più utilizzati per recuperare i record di stream durante la chiamata. GetRecords Ciò si verifica quando si verificano ritardi tra le operazioni di lettura, causati da attività di elaborazione dati di lunga durata, problemi di rete o tempi di inattività delle applicazioni.

Nota

Uno shard iterator è valido per 5 minuti dal momento in cui viene emesso.

Consigli per la gestione delle eccezioni

  • Aggiornamento degli iteratori di shard prima che scadano.

  • Incorpora la gestione degli errori per ottenere nuovi iteratori.

  • Utilizzo della Kinesis Kinesis Client Library (KCL) che gestisce automaticamente la scadenza degli shard iterator.

Per ulteriori informazioni, consulta What is? AWS Fault Injection Service

Per eseguire un esperimento di base

  1. Crea un modello di esperimento: usa la AWS FIS console.

  2. Seleziona l'azione: usa l'aws:kinesis:inject-api-expired-iterator-exceptionazione.

  3. Configura gli obiettivi: specifica il ruolo IAM e le operazioni di Kinesis Data Streams.

  4. Imposta la durata: inizia con 5-10 minuti per il test iniziale.

  5. Aggiungi condizioni di arresto: condizioni di arresto per AWS FIS.

  6. Esegui l'esperimento: monitora il comportamento dell'applicazione.

Dettagli dell'azione

  • Tipo di risorsa: IAM Role ARN

  • Operazioni mirate: GetRecords

  • Codice di errore: ExpiredIteratorException (HTTP 400)

  • Descrizione: l'iteratore fornito supera l'età massima consentita, simulando scenari in cui l'elaborazione dei record è troppo lenta o la logica di checkpoint fallisce.

Parameters

  • IAM Role ARN: il ruolo utilizzato dall'applicazione per le operazioni di Kinesis Data Streams.

  • Operazioni: operazioni mirate: GetRecords

  • Elenco delle risorse: i nomi specifici dei flussi o ARNs.

  • Durata: la durata dell'esperimento. È configurabile.

  • Intensità: la percentuale di richieste da limitare.

Autorizzazioni richieste

  • kinesis:InjectApiError