Codice Lambda attivato a tempo

Cody vuole poter estrarre un report completo di tutti i guidatori oltre il limite di velocità, per sempre, per tutti i tempi — e lo vuole aggiornato ogni notte.

Ti ha chiesto di creare un job notturno.

L'attuale struttura è la seguente:

Scrivi il codice che andrebbe nel metodo lambda_handler della funzione che hai creato nell'esercizio precedente.

boto3, pandas e awsrangler sono già stati importati per te e le chiavi sono state definite.

Andiamo!

Questo esercizio fa parte del corso

Dati in streaming con AWS Kinesis e Lambda

Visualizza il corso

Istruzioni dell'esercizio

Inizializza la sessione boto3 con AWS_KEY_ID e AWS_SECRET.
Passa la sessione al metodo read_csv di AWS Wrangler per ottenere tutti i DataFrame dei guidatori oltre il limite.
Usa AWS Wrangler per scrivere il CSV risultante con la chiave "sd-vehicle-data/speeders-full/full.csv".

Esercizio pratico interattivo

Prova a risolvere questo esercizio completando il codice di esempio.

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

Modifica ed esegui il codice