Загрузка в Postgres
В этом упражнении вы запишете данные в хранилище данных PostgreSQL. Это бывает полезно, когда у вас есть результат каких-либо преобразований и вы хотите использовать его в приложении.
Например, в результате преобразования мог быть добавлен столбец с рекомендациями по фильмам, которые вы хотите отображать в своём интернет-магазине.
В вашем рабочем пространстве уже есть DataFrame pandas под названием film_pdf.
Для справки: вот структура строки подключения для sqlalchemy:
postgresql://[user[:password]@][host][:port][/database]
Это упражнение является частью курса
Введение в дата-инжиниринг
Инструкции к упражнению
- Заполните строку подключения, чтобы создать движок базы данных. Имя пользователя и пароль —
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)