A tabela de destino
Nos exercícios anteriores, você calculou um DataFrame chamado recommendations. Ele contém pares de user_id e course_id, com uma nota que representa a avaliação média desse curso. A suposição é que o curso com a maior nota, elegível para um usuário, é o melhor para recomendar.
É hora de colocar essa tabela em um banco de dados para que possa ser usada por vários produtos, como um mecanismo de recomendação ou um sistema de e-mails.
Como é um objeto pandas.DataFrame, você pode usar o método .to_sql(). Claro, primeiro você precisará se conectar ao banco de dados usando a URI de conexão. A tabela recommendations está disponível no seu ambiente.
Este exercício faz parte do curso
Introdução à Engenharia de Dados
Instruções do exercício
- Preencha a URI de conexão para o banco de dados Postgres no host
localhostcom a porta5432. Você pode se conectar com o usuárioreple a senhapassword. O nome do banco de dados édwh. - Complete a função
load_to_dwh(). Ela deve escrever 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.____("____", ____, ____="____")