La table cible
Dans les exercices précédents, vous avez calculé un DataFrame appelé recommendations. Il contient des paires de user_id et de course_id, avec une cote qui représente la note moyenne de ce cours. L'hypothèse est que le cours admissible ayant la meilleure cote serait le meilleur à recommander à un utilisateur.
Il est temps d'insérer cette table dans une base de données afin qu'elle puisse être utilisée par plusieurs produits, comme un moteur de recommandation ou un système d'envoi de courriels.
Comme il s'agit d'un objet pandas.DataFrame, vous pouvez utiliser la méthode .to_sql(). Bien sûr, vous devrez d'abord vous connecter à la base de données en utilisant l'URI de connexion. La table recommendations est disponible dans votre environnement.
Cette activité fait partie du cours
Introduction à l'ingénierie des données
Instructions de l’exercice
- Indiquez l'URI de connexion pour la base de données Postgres sur l'hôte
localhostavec le port5432. Vous pouvez vous connecter avec l'utilisateurreplet le mot de passepassword. Le nom de la base de données estdwh. - Complétez la fonction
load_to_dwh(). Elle doit écrire dans la table"recommendations"et remplacer la table si elle existe déjà.
Exercice interactif pratique
Essayez cet exercice en complétant ce code d’exemple.
connection_uri = "____://____:____@____:____/____"
db_engine = sqlalchemy.create_engine(connection_uri)
def load_to_dwh(recommendations):
recommendations.____("____", ____, ____="____")