Чтение данных из S3 по событию

В конце предыдущей главы вы написали метод для чтения данных из S3 — analyze_data. Однако запускать его приходилось вручную.

Теперь напишем Lambda-функцию, которая будет запускаться каждый раз, когда Firehose записывает новый файл в S3. Пока что она только выводит имена добавленных файлов.

Вам нужно отредактировать файл recordReaderS3/lambda_function.py в редакторе. В нём находится обработчик нашей Lambda-функции.

Напоминаем: запись объекта в S3 порождает событие ObjectCreated:Put. Вы всегда можете нажать на значок слайдов в правом верхнем углу, чтобы просмотреть слайды — они будут очень полезны!