Odczytywanie danych z S3 na podstawie zdarzenia

Pod koniec poprzedniego rozdziału napisałeś metodę do odczytywania danych z S3 – analyze_data. Trzeba ją było jednak uruchamiać ręcznie.

Teraz napiszemy funkcję Lambda, która będzie uruchamiać się automatycznie za każdym razem, gdy Firehose zapisze nowy plik do S3. Na razie będzie ona jedynie wypisywać nazwy dodanych plików.

Będziesz edytować plik recordReaderS3/lambda_function.py w edytorze. Zawiera on handler naszej funkcji Lambda.

Pamiętaj: zapisanie obiektu w S3 generuje zdarzenie ObjectCreated:Put. Możesz w każdej chwili kliknąć ikonę slajdów w prawym górnym rogu, aby przejrzeć slajdy – na pewno się przydadzą!