Lire des données depuis S3 à partir d’un événement

À la fin du chapitre précédent, vous avez écrit une méthode pour lire des données depuis S3 : analyze_data. Cependant, vous deviez l’exécuter manuellement.

Nous allons écrire une fonction Lambda qui s’exécute chaque fois que Firehose écrit un nouveau fichier dans S3. Pour l’instant, elle se contente d’afficher les fichiers ajoutés.

Vous allez modifier le fichier recordReaderS3/lambda_function.py dans l’éditeur. Il contient le gestionnaire (handler) de notre fonction Lambda.

N’oubliez pas : lorsqu’un objet est écrit dans S3, cela génère un événement ObjectCreated:Put. Vous pouvez toujours cliquer sur l’icône Diaporama en haut à droite pour afficher les diapositives : elles vous seront très utiles !