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:
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!
Bài tập này là một phần của khóa học
Xử lý dữ liệu streaming với AWS Kinesis và Lambda
Hướng dẫn bài tập
- Khởi tạo phiên boto3 với
AWS_KEY_IDvàAWS_SECRET. - Truyền phiên này vào phương thức
read_csvcủ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".
Bài tập tương tác thực hành trực tiếp
Hãy thử làm bài tập này bằng cách hoàn thành đoạn mã mẫu này.
# Initialize boto3 session
session = boto3.____(aws_access_key_id = AWS_KEY_ID,
aws_secret_access_key = AWS_SECRET,
region_name="us-east-1")
# Read all records in the speeders folder
speeders_total = wr.s3.____('s3://sd-vehicle-data/speeders',
____ = session,
delimiter=" ")
# Write aggregated speeders file
____.____.to_csv(df = speeders_total,
boto3_session=session,
path="____://sd-vehicle-data/speeders-full/full.csv")