Načítání dat do databáze Postgres

Jakmile jsou data extrahována ze zdrojového systému a transformována tak, aby odpovídala analytickým nebo reportovacím potřebám, přichází čas je načíst do finálního úložiště. Uložení vyčištěných dat do SQL databáze pak datovým konzumentům usnadňuje přístup k nim i spouštění dotazů. V tomto příkladu si vyzkoušíš načtení vyčištěných dat do databáze Postgres.

sqlalchemy je již naimportován a pandas je dostupný jako pd. Prvních několik řádků DataFrame cleaned_testing_scores je zobrazeno níže:

             street_address       city  math_score  ... best_score
01M539  111 Columbia Street  Manhattan       657.0      Math
02M545     350 Grand Street  Manhattan       613.0      Math
01M292     220 Henry Street  Manhattan       410.0      Math

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

ETL a ELT v Pythonu

Zobrazit kurz

Pokyny k cvičení

Uprav connection string tak, aby zapisoval do databáze schools, a vytvoř objekt připojení pomocí sqlalchemy.
Pomocí pandas zapiš DataFrame cleaned_testing_scores do tabulky scores v databázi schools.
Pokud tabulka již obsahuje data, zajisti, aby byla nahrazena hodnotami z aktuálního DataFrame.

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

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

# Update the connection string, create the connection object to the schools database
db_engine = sqlalchemy.____("postgresql+psycopg2://repl:password@localhost:5432/____")

# Write the DataFrame to the scores table
cleaned_testing_scores.____(
	name="____",
	con=db_engine,
	index=False,
	if_exists="____"
)

Upravit a spustit kód