Zacznij terazZacznij za darmo

Tabela docelowa

W poprzednich ćwiczeniach utworzyłeś DataFrame o nazwie recommendations. Zawiera on pary wartości user_id i course_id wraz z oceną reprezentującą średnią ocenę danego kursu. Założenie jest takie, że najwyżej oceniany kurs, który jest dostępny dla użytkownika, będzie najlepszą rekomendacją.

Nadszedł czas, aby zapisać tę tabelę w bazie danych, skąd będzie mogła korzystać z niej różne systemy – na przykład silnik rekomendacji lub system mailingowy.

Ponieważ recommendations to obiekt pandas.DataFrame, możesz użyć metody .to_sql(). Oczywiście najpierw musisz połączyć się z bazą danych przy użyciu identyfikatora URI połączenia. Tabela recommendations jest dostępna w twoim środowisku.

To ćwiczenie jest częścią kursu

Wprowadzenie do inżynierii danych

Zobacz kurs

Instrukcje do ćwiczenia

  • Uzupełnij identyfikator URI połączenia dla bazy danych Postgres na hoście localhost z portem 5432. Możesz połączyć się jako użytkownik repl z hasłem password. Nazwa bazy danych to dwh.
  • Dokończ funkcję load_to_dwh(). Powinna ona zapisywać dane do tabeli "recommendations" i zastępować tę tabelę, jeśli już istnieje.

Interaktywne ćwiczenie praktyczne

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

connection_uri = "____://____:____@____:____/____"
db_engine = sqlalchemy.create_engine(connection_uri)

def load_to_dwh(recommendations):
    recommendations.____("____", ____, ____="____")
Edytuj i uruchom kod