เริ่มต้นใช้งานเริ่มต้นใช้งานได้ฟรี

โค้ด Lambda แบบ Time-triggered

Cody ต้องการดึงรายงานฉบับเต็มของผู้ที่ขับรถเร็วเกินกำหนดทั้งหมด ตลอดทุกช่วงเวลา และต้องการให้อัปเดตทุกคืน

เธอขอให้คุณสร้างงานที่รันทุกคืน

โครงสร้างปัจจุบันเป็นดังนี้: TfQB4.png

เขียนโค้ดที่จะนำไปใส่ใน method lambda_handler ของฟังก์ชันที่สร้างในแบบฝึกหัดที่แล้ว

boto3, pandas และ awsrangler ถูก import มาให้แล้วทั้งหมด รวมถึงกำหนด key ต่าง ๆ ไว้เรียบร้อยแล้ว

เริ่มกันเลย!

แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร

Streaming Data ด้วย AWS Kinesis และ Lambda

ดูคอร์ส

คำแนะนำการฝึกหัด

  • เริ่มต้น session ของ boto3 โดยใช้ AWS_KEY_ID และ AWS_SECRET
  • ส่ง session ไปยัง method read_csv ของ AWS Wrangler เพื่อดึง dataframe ของผู้ขับรถเร็วทั้งหมด
  • ใช้ AWS Wrangler เพื่อเขียนไฟล์ CSV ที่ได้ โดยใช้ key "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")
แก้ไขและรันโค้ด