Încărcarea datelor într-o bază de date Postgres

După ce datele au fost extrase dintr-un sistem sursă și transformate pentru a corespunde nevoilor de analiză sau raportare, urmează să le încarci într-un mediu de stocare final. Stocarea datelor curățate într-o bază de date SQL le face ușor accesibile consumatorilor de date, care pot rula interogări direct asupra lor. În acest exercițiu, vei exersa încărcarea datelor curățate într-o bază de date Postgres.

sqlalchemy a fost importat, iar pandas este disponibil ca pd. Primele câteva rânduri ale DataFrame-ului cleaned_testing_scores sunt afișate mai jos:

             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

Acest exercițiu face parte din cursul

ETL și ELT în Python

Vezi cursul

Instrucțiuni pentru exercițiu

Actualizează șirul de conexiune pentru a scrie în baza de date schools și creează un obiect de conexiune folosind sqlalchemy.
Folosește pandas pentru a scrie DataFrame-ul cleaned_testing_scores în tabela scores din baza de date schools.
Dacă tabela conține deja date, asigură-te că le înlocuiești cu valorile din DataFrame-ul curent.

Exercițiu interactiv practic

Încearcă acest exercițiu completând acest cod de exemplu.

# 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="____"
)

Editează și rulează codul