1. Learn
    2. /
  2. Courses
    3. /
  3. Introduction to Data Engineering
Connected

Exercise

Bảng đích

Ở các bài trước, bạn đã tính được một DataFrame tên là recommendations. Nó chứa các cặp user_id và course_id, kèm theo một điểm đánh giá đại diện cho điểm trung bình của khóa học đó. Giả định ở đây là khóa học có điểm cao nhất và phù hợp với một người dùng sẽ là gợi ý tốt nhất.

Đã đến lúc đưa bảng này vào cơ sở dữ liệu để có thể được nhiều sản phẩm sử dụng, như hệ thống gợi ý hoặc hệ thống gửi email.

Vì đây là một đối tượng pandas.DataFrame, bạn có thể dùng phương thức .to_sql(). Tất nhiên, trước tiên bạn phải kết nối tới cơ sở dữ liệu bằng URI kết nối. Bảng recommendations đã có sẵn trong môi trường của bạn.

Instructions

100 XP
  • Điền URI kết nối cho cơ sở dữ liệu Postgres trên host localhost với cổng 5432. Bạn có thể kết nối với user repl và mật khẩu password. Tên cơ sở dữ liệu là dwh.
  • Hoàn thiện hàm load_to_dwh(). Hàm này cần ghi vào bảng "recommendations" và thay thế bảng nếu nó đã tồn tại.