Zeitgesteuerter Lambda-Code
Cody möchte einen vollständigen Bericht über alle Raser erstellen, für immer und für alle Zeiten - und sie möchte ihn jede Nacht aktualisieren.
Sie hat dich gebeten, einen nächtlichen Job zu erstellen
Die aktuelle Struktur sieht wie folgt aus:
Schreibe den Code für die lambda_handler Methode der Funktion, die du in der letzten Übung erstellt hast.
Alle boto3, pandas und awsrangler wurden für dich importiert, und die Schlüssel wurden definiert.
Los geht's!
Diese Übung ist Teil des Kurses
Datenstreaming mit AWS Kinesis und Lambda
Anleitung zur Übung
- Initialisiere die boto3-Sitzung mit
AWS_KEY_IDundAWS_SECRET. - Übergib die Sitzung an die AWS Wrangler
read_csvMethode, um alle Speeder DataFrames zu erhalten. - Verwende AWS Wrangler, um die resultierende csv-Datei mit dem Schlüssel
"sd-vehicle-data/speeders-full/full.csv"zu schreiben.
Interaktive Übung zum Anfassen
Probieren Sie diese Übung aus, indem Sie diesen Beispielcode ausführen.
# 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")