Gegevens uit S3 lezen op basis van een event

Aan het einde van het vorige hoofdstuk schreef je een methode om data uit S3 te lezen: analyze_data. Die methode moest je echter handmatig uitvoeren.

We gaan een Lambda-functie schrijven die elke keer draait wanneer Firehose een nieuw bestand naar S3 schrijft. Voor nu print hij alleen de bestanden die zijn toegevoegd.

Je bewerkt het bestand recordReaderS3/lambda_function.py in de editor. Dit bevat de handler voor onze Lambda-functie.

Niet vergeten: een object dat naar S3 wordt geschreven, resulteert in een ObjectCreated:Put-event. Je kunt altijd op het pictogram Dia's rechtsboven klikken om de dia's te bekijken — die zijn erg handig!