Začněte nyníZačněte zdarma

Načtení do Postgresu

V tomto cvičení zapíšeš data do datového skladu PostgreSQL. To se hodí, když máš výsledek nějakých transformací a chceš ho využít v aplikaci.

Například transformace mohla přidat sloupec s doporučeními filmů, která pak chceš zobrazovat ve svém e-shopu.

V tvém pracovním prostoru je připravený pandas DataFrame s názvem film_pdf.

Pro připomenutí – takto vypadá struktura connection URI pro sqlalchemy:

postgresql://[user[:password]@][host][:port][/database]

Toto cvičení je součástí kurzu

Introduction to Data Engineering

Zobrazit kurz

Pokyny k cvičení

  • Dokonči connection URI pro vytvoření databázového enginu. Uživatelské jméno je repl, heslo je password. Host je localhost a port je 5432. Tentokrát je databáze dwh.
  • Dokonči volání tak, aby se použilo schéma "store" v databázi. Pokud tabulka již existuje, nahraď ji celou.

Interaktivní cvičení na vyzkoušení si v praxi

Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.

# 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)
Upravit a spustit kód