Đọc dữ liệu từ S3 dựa trên một sự kiện

Ở cuối chương trước, bạn đã viết một phương thức để đọc dữ liệu từ S3 - analyze_data. Tuy nhiên, bạn phải tự chạy phương thức đó thủ công.

Chúng ta sẽ viết một hàm Lambda chạy mỗi khi Firehose ghi một tệp mới lên S3. Tạm thời, hàm này chỉ in ra danh sách các tệp vừa được thêm.

Bạn sẽ chỉnh sửa tệp recordReaderS3/lambda_function.py trong trình soạn thảo. Tệp này chứa handler cho hàm Lambda của chúng ta.

Đừng quên: khi một đối tượng được ghi lên S3, nó tạo ra sự kiện ObjectCreated:Put. Bạn luôn có thể nhấp vào biểu tượng Các slide ở góc trên bên phải để xem các slide — chúng sẽ rất hữu ích!