Kod funkcji lambda wyzwalanej czasowo

Cody chce mieć dostęp do pełnego raportu o wszystkich przekraczających prędkość – zawsze i na bieżąco. Zależy jej na tym, żeby raport był aktualizowany co noc.

Poprosiła cię o stworzenie zadania uruchamianego nocą.

Aktualna struktura wygląda tak:

Napisz kod, który trafi do metody lambda_handler funkcji utworzonej w poprzednim ćwiczeniu.

boto3, pandas i awsrangler zostały już zaimportowane, a klucze są zdefiniowane.

Do dzieła!

To ćwiczenie jest częścią kursu

Strumieniowanie danych z AWS Kinesis i Lambda

Zobacz kurs

Instrukcje do ćwiczenia

Zainicjalizuj sesję boto3, używając AWS_KEY_ID i AWS_SECRET.
Przekaż sesję do metody read_csv biblioteki AWS Wrangler, aby pobrać wszystkie ramki danych o przekraczających prędkość.
Użyj AWS Wrangler, aby zapisać wynikowy plik CSV z kluczem "sd-vehicle-data/speeders-full/full.csv".

Interaktywne ćwiczenie praktyczne

Spróbuj tego ćwiczenia, uzupełniając ten przykładowy kod.

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

Edytuj i uruchom kod