Загрузка данных в базу данных Postgres
Когда данные извлечены из исходной системы и преобразованы под нужды аналитики или отчётности, наступает время загрузить их в конечное хранилище. Хранение очищенных данных в базе данных SQL упрощает доступ к ним и позволяет легко выполнять запросы. В этом упражнении вы потренируетесь загружать очищенные данные в базу данных Postgres.
Библиотека sqlalchemy уже импортирована, а pandas доступен как pd. Первые несколько строк DataFrame cleaned_testing_scores показаны ниже:
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
Это упражнение является частью курса
ETL и ELT на Python
Инструкции к упражнению
- Обновите строку подключения, указав базу данных
schools, и создайте объект подключения с помощьюsqlalchemy. - Используйте
pandas, чтобы записать DataFramecleaned_testing_scoresв таблицуscoresбазы данныхschools. - Если таблица уже содержит данные, замените их данными из текущего DataFrame.
Интерактивное практическое упражнение
Попробуйте выполнить это упражнение, дополнив этот пример кода.
# 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="____"
)