Čtení z databáze
V tomto cvičení budeš extrahovat data uložená v tabulkách lokální PostgreSQL databáze. Pracovat budeš s ukázkovou databází Pagila. Tato databáze slouží jako základ fiktivní aplikace videopůjčovny a hojně se využívá v různých vzdělávacích materiálech jako příklad reálné databáze.
Vytvoříš a použiješ funkci, která extrahuje tabulku z databáze do objektu pandas DataFrame. Extrahovat budeš tyto tabulky:
film: filmy, které si zákazníci půjčují ve videopůjčovně.customer: zákazníci, kteří si filmy půjčovali.
Pro připojení k databázi je potřeba použít PostgreSQL connection URI, které vypadá přibližně takto:
postgresql://[user[:password]@][host][:port][/database]
Toto cvičení je součástí kurzu
Introduction to Data Engineering
Pokyny k cvičení
- Dokonči definici funkce
extract_table_to_pandas()tak, aby dotaz obsahoval argumenttablename. - Doplň connection URI. Uživatelské jméno je
repla heslo jepassword. Host jelocalhosta port5432. Název databáze jepagila. - Dokonči volání funkce
extract_table_to_pandas()tak, aby se extrahovaly tabulky film a customer.
Interaktivní cvičení na vyzkoušení si v praxi
Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.
# 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)