CommencerCommencer gratuitement

Code lambda à déclenchement temporel

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

Elle vous a demandé de créer un travail de nuit

La structure actuelle est la suivante : TfQB4.png

Ecrivez le code qui se trouve dans la méthode lambda_handler de la fonction que vous avez créée dans le dernier exercice.

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

C'est parti !

Cet exercice fait partie du cours

Streaming de données avec AWS Kinesis et Lambda

Afficher le cours

Instructions

  • Initialisez la session boto3 avec AWS_KEY_ID et AWS_SECRET.
  • Transmettez la session à la méthode AWS Wrangler read_csv pour obtenir toutes les DataFrame.
  • Utilisez AWS Wrangler pour écrire le csv résultant avec la clé "sd-vehicle-data/speeders-full/full.csv".

Exercice interactif pratique

Essayez cet exercice en complétant cet exemple de code.

# 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