Citire dintr-o bază de date
În acest exercițiu, vei extrage date din tabelele unei baze de date PostgreSQL locale. Datele pe care le vei folosi provin din baza de date exemplu Pagila. Aceasta stă la baza unei aplicații fictive pentru un magazin de DVD-uri și este folosită frecvent ca bază de date exemplu în resurse educaționale.
Vei crea și folosi o funcție care extrage o tabelă din baza de date într-un obiect pandas DataFrame. Tabelele pe care le vei extrage sunt:
film: filmele disponibile pentru închiriere în magazinul de DVD-uri.customer: clienții care au închiriat filme din magazin.
Pentru a te conecta la baza de date, va trebui să folosești un URI de conexiune PostgreSQL, care arată astfel:
postgresql://[user[:password]@][host][:port][/database]
Acest exercițiu face parte din cursul
Introducere în Data Engineering
Instrucțiuni pentru exercițiu
- Completează definiția funcției
extract_table_to_pandas()pentru a include argumentultablenameîn interogare. - Completează URI-ul de conexiune. Numele de utilizator și parola sunt
repl, respectivpassword. Gazda estelocalhost, iar portul este5432. Baza de date estepagila. - Completează apelurile funcției
extract_table_to_pandas()pentru a extrage tabelele film și customer.
Exercițiu interactiv practic
Încearcă acest exercițiu completând acest cod de exemplu.
# 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)