Nạp dữ liệu vào cơ sở dữ liệu Postgres
Sau khi dữ liệu được trích xuất từ hệ thống nguồn và chuyển đổi để phù hợp với các bài toán phân tích hoặc báo cáo, đã đến lúc nạp dữ liệu vào nơi lưu trữ cuối cùng. Lưu dữ liệu đã làm sạch trong cơ sở dữ liệu SQL giúp người dùng dữ liệu dễ dàng truy cập và chạy truy vấn. Trong ví dụ này, bạn sẽ thực hành nạp dữ liệu đã làm sạch vào cơ sở dữ liệu Postgres.
sqlalchemy đã được import, và pandas có sẵn dưới tên pd. Một vài hàng đầu tiên của DataFrame cleaned_testing_scores được hiển thị bên dưới:
street_address city math_score ... best_score
01M539 111 Columbia Street Manhattan 657.0 Math
02M545 350 Grand Street Manhattan 613.0 Math
01M292 220 Henry Street Manhattan 410.0 Math
Bài tập này là một phần của khóa học
ETL và ELT với Python
Hướng dẫn bài tập
- Cập nhật chuỗi kết nối để ghi vào cơ sở dữ liệu
schoolsvà tạo một đối tượng kết nối bằngsqlalchemy. - Dùng
pandasđể ghi DataFramecleaned_testing_scoresvào bảngscorestrong cơ sở dữ liệuschools. - Nếu bảng đã có dữ liệu, hãy đảm bảo thay thế các giá trị bằng DataFrame hiệ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.
# Update the connection string, create the connection object to the schools database
db_engine = sqlalchemy.____("postgresql+psycopg2://repl:password@localhost:5432/____")
# Write the DataFrame to the scores table
cleaned_testing_scores.____(
name="____",
con=db_engine,
index=False,
if_exists="____"
)