1. Học hỏi
  2. /
  3. Khoa Học
  4. /
  5. Xử lý dữ liệu streaming với AWS Kinesis và Lambda

Connected

Bài tập

Mã lambda kích hoạt theo thời gian

Cody muốn có thể lấy một báo cáo đầy đủ về tất cả các trường hợp vượt tốc độ, mãi mãi, cho mọi thời điểm — và cô ấy muốn nó được cập nhật mỗi đêm.

Cô ấy đã nhờ bạn tạo một tác vụ chạy đêm

Cấu trúc hiện tại như sau: TfQB4.png

Hãy viết đoạn mã sẽ nằm trong phương thức lambda_handler của hàm bạn đã tạo ở bài trước.

Tất cả boto3, pandas và awsrangler đã được import sẵn cho bạn, và các key đã được định nghĩa.

Bắt đầu thôi!

Hướng dẫn

100 XP
  • Khởi tạo phiên boto3 với AWS_KEY_ID và AWS_SECRET.
  • Truyền phiên này vào phương thức read_csv của AWS Wrangler để lấy tất cả các dataframe vượt tốc.
  • Dùng AWS Wrangler để ghi tệp csv kết quả với key "sd-vehicle-data/speeders-full/full.csv".