Ingestion de données rationalisée avec pandas
Amany Mahfouz
Instructor






create_engine() de sqlalchemy crée un moteur pour gérer les connexionssqlite:///filename.dbpd.read_sql(query, engine) pour charger des données d'une basequery : chaîne SQL à exécuter ou nom de table à chargerengine : objet moteur/connexion à la baseSELECT [column_names] FROM [table_name];
SELECT * FROM [table_name];
# Charger pandas et create_engine de sqlalchemy import pandas as pd from sqlalchemy import create_engine# Créer un moteur de base pour gérer les connexions engine = create_engine("sqlite:///data.db")# Charger toute la table weather par son nom weather = pd.read_sql("weather", engine)
# Créer un moteur de base pour gérer les connexions engine = create_engine("sqlite:///data.db")# Charger toute la table weather avec du SQL weather = pd.read_sql("SELECT * FROM weather", engine)print(weather.head())
station name latitude ... prcp snow tavg tmax tmin
0 USW00094728 NY CITY CENTRAL PARK, NY US 40.77898 ... 0.00 0.0 52 42
1 USW00094728 NY CITY CENTRAL PARK, NY US 40.77898 ... 0.00 0.0 48 39
2 USW00094728 NY CITY CENTRAL PARK, NY US 40.77898 ... 0.00 0.0 48 42
3 USW00094728 NY CITY CENTRAL PARK, NY US 40.77898 ... 0.00 0.0 51 40
4 USW00094728 NY CITY CENTRAL PARK, NY US 40.77898 ... 0.75 0.0 61 50
[5 rows x 13 columns]
Ingestion de données rationalisée avec pandas