Kom igångKom igång gratis

Läs in data i Postgres

I den här övningen skriver du ut data till ett PostgreSQL-datalager. Det kan vara användbart när du har ett resultat från en transformation och vill använda det i en applikation.

Transformationen kan till exempel ha lagt till en kolumn med filmrekommendationer som du vill använda i din webbutik.

Det finns en pandas DataFrame kallad film_pdf i din miljö.

Här är strukturen för en anslutnings-URI i sqlalchemy:

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

Den här övningen är en del av kursen

Introduktion till datatekniker

Visa kurs

Övningsinstruktioner

  • Fyll i anslutnings-URI:n för att skapa databasmotorn. Användarnamnet är repl och lösenordet är password. Värden är localhost och porten är 5432. Den här gången är databasen dwh.
  • Slutför anropet så att schemat "store" används i databasen. Om tabellen redan finns ska den ersättas helt.

Interaktiv övning med praktiskt arbete

Testa den här övningen genom att slutföra den här exempelkoden.

# 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)
Redigera och kör kod