1. Nauka
  2. /
  3. Kursy
  4. /
  5. Strumieniowanie danych z AWS Kinesis i Lambda

Connected

ćwiczenie

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: TfQB4.png

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!

Instrukcje

100 XP
  • 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".