Lesen von Daten aus S3 auf der Grundlage eines Ereignisses

Am Ende des letzten Kapitels hast du eine Methode zum Lesen von Daten aus S3 geschrieben - analyze_data. Allerdings musstest du diese Methode manuell ausführen.

Wir werden eine Lambda-Funktion schreiben, die jedes Mal ausgeführt wird, wenn Firehose eine neue Datei in S3 schreibt. Im Moment werden nur die Dateien ausgedruckt, die hinzugefügt wurden.

Du wirst die Datei recordReaderS3/lambda_function.py mit dem Editor bearbeiten. Dies enthält den Handler für unsere Lambda-Funktion.

Vergiss nicht: Ein Objekt, das in S3 geschrieben wird, führt zu einem ObjectCreated:Put Ereignis. Du kannst jederzeit auf das Foliensymbol oben rechts klicken, um die Folien zu sehen - sie sind sehr hilfreich!