Lettura dei dati da S3 in base a un evento

Alla fine dell'ultimo capitolo, hai scritto un metodo per leggere i dati da S3: analyze_data. Tuttavia, dovevi eseguire quel metodo manualmente.

Ora scriveremo una funzione Lambda che si avvia ogni volta che Firehose scrive un nuovo file su S3. Per ora, si limita a stampare i file che sono stati aggiunti.

Modificherai il file recordReaderS3/lambda_function.py nell'editor. Contiene l'handler della nostra funzione Lambda.

Non dimenticare: la scrittura di un oggetto su S3 genera un evento ObjectCreated:Put. Puoi sempre fare clic sull'icona delle diapositive in alto a destra per vedere le slide: ti saranno molto utili!