Зчитування з бази даних
У цій вправі ви видобуватимете дані з таблиць локальної бази даних PostgreSQL. Ви працюватимете з прикладною базою даних Pagila. Ця база лежить в основі вигаданої програми магазину DVD і часто використовується в навчальних прикладах.
Ви створите та використаєте функцію, яка завантажує таблицю бази даних у об'єкт DataFrame бібліотеки pandas. Таблиці, які ви завантажите:
film: фільми, що видаються в магазині DVD.customer: клієнти, які брали фільми в магазині DVD.
Щоб під'єднатися до бази даних, потрібно використати URI підключення PostgreSQL, який має приблизно такий вигляд:
postgresql://[user[:password]@][host][:port][/database]
Ця вправа є частиною курсу
Вступ до Data Engineering
Інструкції до вправи
- Доповніть визначення функції
extract_table_to_pandas(), щоб додати аргументtablenameу запит. - Заповніть URI підключення. Ім'я користувача та пароль:
replіpasswordвідповідно. Хост —localhost, порт —5432. База даних —pagila. - Завершіть виклики
extract_table_to_pandas(), щоб завантажити таблиці film і customer.
Інтерактивна практична вправа
Спробуйте виконати цю вправу, доповнивши цей зразок коду.
# Function to extract table to a pandas DataFrame
def extract_table_to_pandas(tablename, db_engine):
query = "SELECT * FROM {}".format(____)
return pd.read_sql(query, db_engine)
# Connect to the database using the connection URI
connection_uri = "postgresql://____:____@____:____/____"
db_engine = sqlalchemy.create_engine(connection_uri)
# Extract the film table into a pandas DataFrame
extract_table_to_pandas("____", db_engine)
# Extract the customer table into a pandas DataFrame
extract_table_to_pandas("____", db_engine)