Začněte nyníZačněte zdarma

Kód lambda funkce spouštěné časovačem

Cody chce mít k dispozici úplný přehled všech řidičů překračujících rychlost – navždy a pro všechny časy – a chce, aby se každou noc aktualizoval.

Požádala tě o vytvoření nočního jobu.

Aktuální struktura vypadá takto: TfQB4.png

Napiš kód, který bude patřit do metody lambda_handler funkce vytvořené v předchozím cvičení.

boto3, pandas i awsrangler jsou už naimportované a klíče jsou definované.

Do toho!

Toto cvičení je součástí kurzu

Streamování dat s AWS Kinesis a Lambda

Zobrazit kurz

Pokyny k cvičení

  • Inicializuj boto3 session pomocí AWS_KEY_ID a AWS_SECRET.
  • Předej session metodě read_csv v AWS Wrangler, aby načetla všechny dataframy s překračovateli rychlosti.
  • Pomocí AWS Wrangler zapiš výsledné CSV s klíčem "sd-vehicle-data/speeders-full/full.csv".

Interaktivní cvičení na vyzkoušení si v praxi

Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.

# 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")
Upravit a spustit kód