Charger des données dans une base de données Postgres
Une fois les données extraites d'un système source et transformées pour répondre aux besoins d'analyse ou de production de rapports, il est temps de les charger dans un espace de stockage final. Entreposer des données nettoyées dans une base de données SQL facilite l'accès pour les utilisateurs et l'exécution de requêtes. Dans cet exemple, vous pratiquerez le chargement de données nettoyées dans une base de données Postgres.
sqlalchemy a été importé, et pandas est disponible sous pd. Les premières lignes du DataFrame cleaned_testing_scores sont présentées ci‑dessous :
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
Cette activité fait partie du cours
ETL et ELT en Python
Instructions de l’exercice
- Mettez à jour la chaîne de connexion pour écrire dans la base de données
schoolset créez un objet de connexion avecsqlalchemy. - Utilisez
pandaspour écrire le DataFramecleaned_testing_scoresdans la tablescoresde la base de donnéesschools. - Si la table contient déjà des données, assurez-vous de remplacer les valeurs par celles du DataFrame actuel.
Exercice interactif pratique
Essayez cet exercice en complétant ce code d’exemple.
# 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="____"
)