Construirea funcțiilor pentru extragerea datelor
Este important să modularizezi codul atunci când construiești o pipeline de date. Acest lucru ajută la a face pipeline-urile mai lizibile și reutilizabile, și poate accelera eforturile de depanare. Crearea și utilizarea funcțiilor pentru operații distincte dintr-o pipeline poate ajuta chiar și la începerea 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)