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à.
Abilitare la decompressione su un flusso Firehose esistente
Questa sezione fornisce istruzioni per abilitare la decompressione sui flussi Firehose esistenti. Copre due scenari: flussi con elaborazione Lambda disabilitata e flussi con elaborazione Lambda già abilitata. Le seguenti sezioni descrivono step-by-step le procedure per ogni caso, tra cui la creazione o la modifica di funzioni Lambda, l'aggiornamento delle impostazioni di Firehose e le metriche di CloudWatch monitoraggio per garantire una corretta implementazione della funzionalità di decompressione integrata Firehose.
Abilitazione della decompressione quando l'elaborazione Lambda è disabilitata
Per abilitare la decompressione su un flusso Firehose esistente con l'elaborazione Lambda disabilitata, è necessario prima abilitare l'elaborazione Lambda. Questa condizione è valida solo per gli stream esistenti. I passaggi seguenti mostrano come abilitare la decompressione su flussi esistenti che non hanno l'elaborazione Lambda abilitata.
-
Creazione di una funzione Lambda. È possibile creare un passthrough di record fittizio o utilizzare questo blueprint
per creare una nuova funzione Lambda. -
Aggiorna lo stream Firehose corrente per abilitare l'elaborazione Lambda e usa la funzione Lambda che hai creato per l'elaborazione.
-
Dopo aver aggiornato lo stream con la nuova funzione Lambda, torna alla console Firehose e attiva la decompressione.
-
Disabilita l'elaborazione Lambda abilitata nel passaggio 1. Ora puoi eliminare la funzione che hai creato nel passaggio 1.
Abilitazione della decompressione quando l'elaborazione Lambda è abilitata
Se disponi già di uno stream Firehose con una funzione Lambda, per eseguire la decompressione puoi sostituirlo con la funzionalità di decompressione Firehose. Prima di procedere, esamina il codice della funzione Lambda per confermare che esegua solo la decompressione o l'estrazione dei messaggi. L'output della funzione Lambda dovrebbe essere simile agli esempi mostrati in Fig 1 o Fig 2. Se l'output è simile, puoi sostituire la funzione Lambda utilizzando i passaggi seguenti.
Sostituisci la tua attuale funzione Lambda con questo modello.
La nuova funzione Lambda Blueprint rileva automaticamente se i dati in entrata sono compressi o decompressi. Esegue la decompressione solo se i dati di input sono compressi. Attiva la decompressione utilizzando l'opzione Firehose integrata per la decompressione.
Abilita le CloudWatch metriche per il tuo stream Firehose se non è già abilitato. Monitora la metrica
CloudWatchProcessorLambda_IncomingCompressedDatae attendi che questa metrica diventi zero. Ciò conferma che tutti i dati di input inviati alla funzione Lambda sono decompressi e che la funzione Lambda non è più necessaria.Rimuovi la trasformazione dei dati Lambda perché non ti serve più per decomprimere lo stream.
