Tải vào Postgres
Trong bài tập này, bạn sẽ ghi một số dữ liệu vào kho dữ liệu PostgreSQL. Điều đó hữu ích khi bạn có kết quả của một số bước biến đổi và muốn dùng chúng trong một ứng dụng.
Ví dụ, kết quả của một phép biến đổi có thể đã thêm một cột gợi ý phim, và bạn muốn dùng chúng trong cửa hàng trực tuyến của mình.
Có một DataFrame của pandas tên là film_pdf trong không gian làm việc của bạn.
Nhắc lại, đây là cấu trúc URI kết nối cho sqlalchemy:
postgresql://[user[:password]@][host][:port][/database]
Bài tập này là một phần của khóa học
Introduction to Data Engineering
Hướng dẫn bài tập
- Hoàn thiện URI kết nối để tạo database engine. User và mật khẩu lần lượt là
replvàpassword. Host làlocalhost, và cổng là5432. Lần này, database làdwh. - Hoàn tất lời gọi để chúng ta dùng schema
"store"trong cơ sở dữ liệu. Nếu bảng đã tồn tại, hãy thay thế hoàn toàn.
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.
# Finish the connection URI
connection_uri = "____://____:____@____:____/____"
db_engine_dwh = sqlalchemy.create_engine(connection_uri)
# Transformation step, join with recommendations data
film_pdf_joined = film_pdf.join(recommendations)
# Finish the .to_sql() call to write to store.film
film_pdf_joined.to_sql("film", ____, schema="____", if_exists="____")
# Run the query to fetch the data
pd.read_sql("SELECT film_id, recommended_film_ids FROM store.film", db_engine_dwh)