Tijdgestuurde lambda-code

Cody wil een volledig rapport kunnen ophalen van alle hardrijders, voor altijd, voor alle tijd — en ze wil dat het elke nacht wordt bijgewerkt.

Ze heeft je gevraagd een nachtelijke job te maken

De huidige structuur ziet er zo uit:

Schrijf de code die in de lambda_handler-methode zou komen van de functie die je in de vorige oefening hebt gemaakt.

Alle boto3, pandas en awsrangler zijn al voor je geïmporteerd en de keys zijn gedefinieerd.

Let's roll!

Deze oefening maakt deel uit van de cursus

Streaming data met AWS Kinesis en Lambda

Bekijk cursus

Oefeninstructies

Initialiseer de boto3-sessie met AWS_KEY_ID en AWS_SECRET.
Geef de sessie door aan de AWS Wrangler-methode read_csv om alle dataframes met hardrijders op te halen.
Gebruik AWS Wrangler om het resulterende csv-bestand te schrijven met de key "sd-vehicle-data/speeders-full/full.csv".

Interactieve oefening met praktijkervaring

Probeer deze oefening door deze voorbeeldcode aan te vullen.

# 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 bewerken en uitvoeren