La tabella di destinazione
Negli esercizi precedenti, hai calcolato un DataFrame chiamato recommendations. Contiene coppie di user_id e course_id, con un punteggio che rappresenta la valutazione media di questo corso. L’assunzione è che il corso con la valutazione più alta, tra quelli idonei per un utente, sia il migliore da raccomandare.
È il momento di inserire questa tabella in un database, così da poterla usare in diversi prodotti come un motore di raccomandazione o un sistema di email.
Dato che è un oggetto pandas.DataFrame, puoi usare il metodo .to_sql(). Naturalmente, prima dovrai connetterti al database usando la URI di connessione. La tabella recommendations è disponibile nel tuo ambiente.
Questo esercizio fa parte del corso
Introduzione al Data Engineering
Istruzioni dell'esercizio
- Compila la URI di connessione per il database Postgres sull’host
localhostcon porta5432. Puoi connetterti con l’utentereple la passwordpassword. Il nome del database èdwh. - Completa la funzione
load_to_dwh(). Deve scrivere nella tabella"recommendations"e sostituire la tabella se esiste già.
Esercizio pratico interattivo
Prova a risolvere questo esercizio completando il codice di esempio.
connection_uri = "____://____:____@____:____/____"
db_engine = sqlalchemy.create_engine(connection_uri)
def load_to_dwh(recommendations):
recommendations.____("____", ____, ____="____")