开始使用免费开始使用

按时间触发的 Lambda 代码

Cody 希望能够长期获取所有超速司机的完整报告,并且每晚更新一次。

她请您创建一个每晚运行的作业。

当前结构如下所示: TfQB4.png

请编写代码,填入您在上一个练习中创建的函数的 lambda_handler 方法中。

boto3pandasawsrangler 已为您导入,所需的键也已定义。

开始动手!

本练习是课程的一部分

使用 AWS Kinesis 与 Lambda 处理流数据

查看课程

练习说明

  • 使用 AWS_KEY_IDAWS_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")
编辑并运行代码