Cod lambda declanșat la interval de timp

Cody vrea să poată genera un raport complet cu toți șoferii care au depășit viteza legală – pentru totdeauna, fără excepție – și vrea ca acesta să fie actualizat în fiecare noapte.

Te-a rugat să creezi un job nocturn.

Structura actuală arată astfel:

Scrie codul care va fi inclus în metoda lambda_handler a funcției create în exercițiul anterior.

boto3, pandas și awsrangler au fost deja importate, iar cheile sunt deja definite.

Să începem!

Acest exercițiu face parte din cursul

Date în flux cu AWS Kinesis și Lambda

Vezi cursul

Instrucțiuni pentru exercițiu

Inițializează sesiunea boto3 folosind AWS_KEY_ID și AWS_SECRET.
Transmite sesiunea metodei read_csv din AWS Wrangler pentru a obține toate dataframe-urile cu șoferi care au depășit viteza.
Folosește AWS Wrangler pentru a scrie fișierul CSV rezultat cu cheia "sd-vehicle-data/speeders-full/full.csv".

Exercițiu interactiv practic

Încearcă acest exercițiu completând acest cod de exemplu.

# 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")

Editează și rulează codul