Lecture des données de S3 en fonction d'un événement
À la fin du dernier chapitre, vous avez écrit une méthode pour lire les données de S3 - analyze_data. Cependant, vous devez exécuter cette méthode manuellement.
Nous allons écrire une fonction Lambda qui s'exécute à chaque fois que Firehose écrit un nouveau fichier sur S3. Pour l'instant, il n'imprime que les fichiers qui ont été ajoutés.
Vous allez modifier le fichier recordReaderS3/lambda_function.py dans l'éditeur. Il contient le gestionnaire de notre fonction Lambda.
N'oubliez pas : l'écriture d'un objet sur S3 entraîne un événement ObjectCreated:Put. Vous pouvez toujours cliquer sur l'icône des diapositives en haut à droite pour voir les diapositives - elles vous seront très utiles !
Cet exercice fait partie du cours
Streaming de données avec AWS Kinesis et Lambda
Instructions
- Mettez à jour la méthode lambda handler (
recordReaderS3/lambda_function.py) pour qu'elle accepte les bons arguments. - Analyse l'événement entrant. Si l'événement est un événement d'écriture S3 et qu'il se trouve dans le site
"sd-vehicle-data", renvoyez la nouvelle clé d'objet (cette dernière partie a été prise en charge pour vous). - Dans le terminal, exécutez
python3 run_lambda.pypour déployer et tester votre fonction lambda.
Exercice interactif pratique
Passez de la théorie à la pratique avec l’un de nos exercices interactifs
Commencer l’exercice