MulaiMulai sekarang secara gratis

Muat ke Postgres

Dalam latihan ini, Anda akan menulis sebagian data ke gudang data PostgreSQL. Ini berguna ketika Anda memiliki hasil dari beberapa transformasi dan ingin menggunakannya dalam sebuah aplikasi.

Sebagai contoh, hasil transformasi dapat menambahkan kolom berisi rekomendasi film, dan Anda ingin menggunakannya di toko online Anda.

Terdapat pandas DataFrame bernama film_pdf di workspace Anda.

Sebagai pengingat, berikut adalah struktur URI koneksi untuk sqlalchemy:

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

Latihan ini adalah bagian dari kursus

Pengantar Data Engineering

Lihat Kursus

Petunjuk latihan

  • Lengkapi URI koneksi untuk membuat database engine. User dan password masing-masing adalah repl dan password. Host adalah localhost, dan port 5432. Kali ini, databasenya adalah dwh.
  • Selesaikan pemanggilan sehingga kita menggunakan skema "store" di database. Jika tabel sudah ada, ganti seluruhnya.

Latihan interaktif praktis

Cobalah latihan ini dengan menyelesaikan kode contoh berikut.

# 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)
Edit dan Jalankan Kode