Čtení dat z S3 na základě události

Na konci předchozí kapitoly jsi napsal/a metodu pro čtení dat z S3 – analyze_data. Spustit ji ale bylo potřeba ručně.

Teď napíšeme Lambda funkci, která se spustí pokaždé, když Firehose zapíše nový soubor do S3. Zatím bude jen vypisovat přidané soubory.

Budeš upravovat soubor recordReaderS3/lambda_function.py v editoru. Ten obsahuje handler naší Lambda funkce.

Nezapomeň: zápis objektu do S3 vyvolá událost ObjectCreated:Put. Kdykoli si můžeš kliknout na ikonu slides v pravém horním rohu a prohlédnout si snímky – budou se hodit!