Läsa data från S3 baserat på en händelse

I slutet av förra kapitlet skrev du en metod för att läsa data från S3 – analyze_data. Du behövde dock köra den metoden manuellt.

Nu ska vi skriva en Lambda-funktion som körs varje gång Firehose skriver en ny fil till S3. För tillfället skriver den bara ut de filer som lagts till.

Du kommer att redigera filen recordReaderS3/lambda_function.py i editorn. Den innehåller hanteraren för vår Lambda-funktion.

Kom ihåg: när ett objekt skrivs till S3 skapas en ObjectCreated:Put-händelse. Du kan alltid klicka på ikonen Slides uppe till höger för att se slidesen – de är till stor hjälp!