按时间触发的 Lambda 代码
Cody 希望能够长期获取所有超速司机的完整报告,并且每晚更新一次。
她请您创建一个每晚运行的作业。
当前结构如下所示:

请编写代码,填入您在上一个练习中创建的函数的 lambda_handler 方法中。
boto3、pandas 和 awsrangler 已为您导入,所需的键也已定义。
开始动手!
本练习是课程的一部分
使用 AWS Kinesis 与 Lambda 处理流数据
练习说明
- 使用
AWS_KEY_ID和AWS_SECRET初始化 boto3 会话。 - 将该会话传入 AWS Wrangler 的
read_csv方法,读取所有超速数据的数据框。 - 使用 AWS Wrangler 写出生成的 csv,键为
"sd-vehicle-data/speeders-full/full.csv"。
交互式实操练习
通过完成这段示例代码来试试这个练习。
# 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")