Citirea datelor din S3 pe baza unui eveniment

La finalul capitolului anterior, ai scris o metodă pentru a citi date din S3 – analyze_data. Totuși, a trebuit să o execuți manual.

Acum vom scrie o funcție Lambda care rulează de fiecare dată când Firehose scrie un fișier nou în S3. Deocamdată, aceasta doar afișează fișierele care au fost adăugate.

Vei edita fișierul recordReaderS3/lambda_function.py din editor. Acesta conține handler-ul funcției noastre Lambda.

Nu uita: scrierea unui obiect în S3 generează un eveniment de tip ObjectCreated:Put. Poți oricând să dai click pe iconița slide-uri din colțul din dreapta sus pentru a vedea slide-urile – vor fi de mare ajutor!