Bắt đầu ngayBắt đầu miễn phí

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.

Bài tập này là một phần của khóa học

Introduction to Data Engineering

Xem khóa học

Hướng dẫn bài tập

  • Đ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.

Bài tập tương tác thực hành trực tiếp

Hãy thử làm bài tập này bằng cách hoàn thành đoạn mã mẫu này.

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

def load_to_dwh(recommendations):
    recommendations.____("____", ____, ____="____")
Chỉnh sửa và Chạy Mã