开始使用免费开始使用

目标表

在之前的练习中,您计算出了一个名为 recommendations 的 DataFrame。它包含成对的 user_idcourse_id,以及代表该课程平均评分的一个分值。我们的假设是:对某个用户可选的课程中,评分最高的课程最适合推荐。

现在是将这张表写入数据库的时候了,以便推荐引擎或邮件系统等多个产品能够使用。

由于它是一个 pandas.DataFrame 对象,您可以使用 .to_sql() 方法。当然,您需要先通过连接 URI 连接到数据库。recommendations 表已在您的环境中可用。

本练习是课程的一部分

Data Engineering 入门

查看课程

练习说明

  • 为主机 localhost、端口 5432 的 Postgres 数据库填写连接 URI。可使用用户 repl 和密码 password 连接。数据库名为 dwh
  • 完成 load_to_dwh() 函数。它应写入 "recommendations" 表,且如果该表已存在则进行替换。

交互式实操练习

通过完成这段示例代码来试试这个练习。

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

def load_to_dwh(recommendations):
    recommendations.____("____", ____, ____="____")
编辑并运行代码