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

Kurs anzeigen

Anleitung zur Übung

Initialisiere die boto3-Sitzung mit AWS_KEY_ID und AWS_SECRET.
Übergib die Sitzung an die AWS Wrangler read_csv Methode, 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

Vervollständige den Beispielcode, um diese Übung erfolgreich abzuschließen.

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

Code bearbeiten und ausführen