A tabela de destino
Nos exercícios anteriores, você calculou um DataFrame chamado recommendations
. Ele contém pares de user_id
's' e course_id
's, com uma classificação que representa a classificação média desse curso. O pressuposto é que o curso mais bem avaliado, que é elegível para um usuário, seria o melhor a ser recomendado.
É hora de colocar essa tabela em um banco de dados para que ela possa ser usada por vários produtos, como um mecanismo de recomendação ou um sistema de e-mail.
Como se trata de um objeto pandas.DataFrame
, você pode usar o método .to_sql()
. Obviamente, você terá que se conectar ao banco de dados usando a conexão URI primeiro. A tabela recommendations
está disponível em seu ambiente.
Este exercício faz parte do curso
Introdução à engenharia de dados
Instruções do exercício
- Preencha a conexão URI para o banco de dados Postgres no host
localhost
com a porta5432
. Você pode se conectar com o usuáriorepl
e a senhapassword
. O nome do banco de dados édwh
. - Conclua a função
load_to_dwh()
. Ele deve gravar na tabela"recommendations"
e substituir a tabela se ela já existir.
Exercício interativo prático
Experimente este exercício completando este código de exemplo.
connection_uri = "____://____:____@____:____/____"
db_engine = sqlalchemy.create_engine(connection_uri)
def load_to_dwh(recommendations):
recommendations.____("____", ____, ____="____")