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

Cílová tabulka

V předchozích cvičeních jsi vypočítal/a DataFrame s názvem recommendations. Obsahuje dvojice user_id a course_id spolu s hodnocením, které představuje průměrné hodnocení daného kurzu. Předpoklad je takový, že nejlépe hodnocený kurz, který je pro daného uživatele dostupný, je zároveň tím nejvhodnějším doporučením.

Nastal čas uložit tuto tabulku do databáze, aby ji mohlo využívat více produktů – například doporučovací engine nebo emailový systém.

Protože jde o objekt pandas.DataFrame, můžeš použít metodu .to_sql(). Nejdřív se ale budeš muset připojit k databázi pomocí connection URI. Tabulka recommendations je dostupná ve tvém prostředí.

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

Introduction to Data Engineering

Zobrazit kurz

Pokyny k cvičení

  • Doplň connection URI pro databázi Postgres na hostu localhost s portem 5432. Připoj se jako uživatel repl s heslem password. Název databáze je dwh.
  • Dokonči funkci load_to_dwh(). Má zapisovat do tabulky "recommendations" a v případě, že tabulka již existuje, ji nahradit.

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

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

connection_uri = "____://____:____@____:____/____"
db_engine = sqlalchemy.create_engine(connection_uri)

def load_to_dwh(recommendations):
    recommendations.____("____", ____, ____="____")
Upravit a spustit kód