Завантаження до Postgres
У цій вправі ви запишете деякі дані до сховища даних PostgreSQL. Це корисно, коли ви отримали результат певних перетворень і хочете використати його в застосунку.
Наприклад, у результаті перетворення могла з'явитися колонка з рекомендаціями фільмів, і ви хочете використати їх у своєму онлайн-магазині.
У вашому робочому середовищі є датафрейм pandas під назвою film_pdf.
Нагадаємо, ось структура URI підключення для sqlalchemy:
postgresql://[user[:password]@][host][:port][/database]
Ця вправа є частиною курсу
Вступ до Data Engineering
Інструкції до вправи
- Заповніть URI підключення, щоб створити рушій бази даних. Ім'я користувача та пароль —
replіpasswordвідповідно. Хост —localhost, порт —5432. Цього разу база даних —dwh. - Доповніть виклик так, щоб ми використовували схему
"store"у базі даних. Якщо таблиця вже існує, повністю замініть її.
Інтерактивна практична вправа
Спробуйте виконати цю вправу, доповнивши цей зразок коду.
# 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)