Завантаження даних до бази даних Postgres
Після того як дані витягнуто з джерельної системи та перетворено під потреби аналітики чи звітності, настав час завантажити їх до підсумкового сховища. Зберігати очищені дані в базі даних SQL зручно — споживачі даних зможуть легко отримувати доступ і виконувати запити. У цьому прикладі ви попрактикуєтеся завантажувати очищені дані до бази даних Postgres.
sqlalchemy вже імпортовано, а pandas доступна як pd. Перші кілька рядків датафрейма 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, щоб записати датафреймcleaned_testing_scoresдо таблиціscoresу базі данихschools. - Якщо таблицю вже заповнено даними, обов'язково замініть значення поточним датафреймом.
Інтерактивна практична вправа
Спробуйте виконати цю вправу, доповнивши цей зразок коду.
# 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="____"
)