Code Lambda déclenché par horaire

Cody souhaite pouvoir obtenir un rapport complet de tous les conducteurs en excès de vitesse, pour toujours, et elle veut qu'il soit mis à jour chaque nuit.

Elle vous a demandé de créer une tâche nocturne.

La structure actuelle ressemble à ceci :

Écrivez le code qui irait dans la méthode lambda_handler de la fonction que vous avez créée dans le dernier exercice.

boto3, pandas et awsrangler ont déjà été importés pour vous, et les clés ont été définies.

Allons-y !

Cette activité fait partie du cours

Données en continu avec AWS Kinesis et Lambda

Voir le cours

Instructions de l’exercice

Initialisez la session boto3 avec AWS_KEY_ID et AWS_SECRET.
Passez la session à la méthode read_csv d'AWS Wrangler pour obtenir tous les DataFrame des excès de vitesse.
Utilisez AWS Wrangler pour écrire le fichier CSV résultant avec la clé "sd-vehicle-data/speeders-full/full.csv".

Exercice interactif pratique

Essayez cet exercice en complétant ce code d’exemple.

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

Modifier et exécuter le code