Risolvi gli errori in Amazon Data Firehose - Amazon Data Firehose

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à.

Risolvi gli errori in Amazon Data Firehose

Se Firehose riscontra errori durante la consegna o l'elaborazione dei dati, riprova fino alla scadenza della durata del nuovo tentativo configurata. Se la durata del nuovo tentativo termina prima che i dati vengano consegnati correttamente, Firehose esegue il backup dei dati nel bucket di backup S3 configurato. Se la destinazione è Amazon S3 e la consegna non riesce o se la consegna al bucket S3 di backup fallisce, Firehose continua a riprovare fino al termine del periodo di conservazione.

Per informazioni sul tracciamento degli errori di consegna utilizzando, consulta. CloudWatch Monitora Amazon Data Firehose utilizzando i log CloudWatch

Direct PUT

Per gli stream DirectPut Firehose, Firehose conserva i record per 24 ore. Per uno stream Firehose la cui origine dati è un flusso di dati Kinesis, è possibile modificare il periodo di conservazione come descritto in Modifica del periodo di conservazione dei dati. In questo caso, Firehose riprova le seguenti operazioni all'infinito:DescribeStream,, e. GetRecords GetShardIterator

Se lo stream Firehose utilizzaDirectPut, controlla le IncomingRecords metriche IncomingBytes and per vedere se c'è traffico in entrata. Se utilizzi PutRecord o PutRecordBatch, assicurati di rilevare le eccezioni e riprova. Consigliamo una policy di tentativi con back-off esponenziale con jitter e diversi tentativi. Inoltre, se utilizzi l'PutRecordBatchAPI, assicurati che il codice controlli il valore di FailedPutCountnella risposta anche quando la chiamata API ha esito positivo.

Kinesis Data Stream

Se il flusso Firehose utilizza un flusso di dati Kinesis come origine, controlla le IncomingRecords metriche IncomingBytes e per il flusso di dati di origine. Inoltre, assicuratevi che le DataReadFromKinesisStream.Records metriche DataReadFromKinesisStream.Bytes and vengano emesse per lo stream Firehose.