Construirea funcțiilor pentru extragerea datelor
Modularizarea codului este esențială atunci când construiești un pipeline de date. Aceasta face pipelines-urile mai lizibile și reutilizabile și poate accelera depanarea erorilor. Crearea unor funcții dedicate pentru operațiuni distincte dintr-un pipeline poate fi de mare ajutor chiar și la începutul unui proiect nou, oferind un cadru de la care să pornești dezvoltarea.
pandas a fost importat ca pd, iar sqlalchemy este gata de utilizare.
Acest exercițiu face parte din cursul
ETL și ELT în Python
Exercițiu interactiv practic
Încearcă acest exercițiu completând acest cod de exemplu.
def extract():
# Create a connection URI and connection engine
connection_uri = "postgresql+psycopg2://repl:password@localhost:____/____"
db_engine = sqlalchemy.____(connection_uri)