ÎncepețiÎncepe gratuit

Tabelul destinație

În exercițiile anterioare, ai calculat un DataFrame numit recommendations. Acesta conține perechi de user_id și course_id, împreună cu un rating care reprezintă ratingul mediu al cursului respectiv. Presupunerea este că cel mai bine cotat curs eligibil pentru un utilizator ar fi cel mai potrivit de recomandat.

Este momentul să încarci acest tabel într-o bază de date, astfel încât să poată fi utilizat de mai multe produse, cum ar fi un motor de recomandări sau un sistem de emailuri.

Deoarece este un obiect pandas.DataFrame, poți folosi metoda .to_sql(). Bineînțeles, va trebui mai întâi să te conectezi la baza de date folosind URI-ul de conexiune. Tabelul recommendations este disponibil în mediul tău.

Acest exercițiu face parte din cursul

Introducere în Data Engineering

Vezi cursul

Instrucțiuni pentru exercițiu

  • Completează URI-ul de conexiune pentru baza de date Postgres de pe host-ul localhost, cu portul 5432. Te poți conecta cu utilizatorul repl și parola password. Numele bazei de date este dwh.
  • Completează funcția load_to_dwh(). Aceasta trebuie să scrie în tabelul "recommendations" și să îl înlocuiască dacă există deja.

Exercițiu interactiv practic

Încearcă acest exercițiu completând acest cod de exemplu.

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

def load_to_dwh(recommendations):
    recommendations.____("____", ____, ____="____")
Editează și rulează codul