Crear funciones para extraer datos
Es importante modularizar el código al construir una canalización de datos. Esto ayuda a que las canalizaciones sean más legibles y reutilizables, y puede acelerar la resolución de problemas. Crear y usar funciones para operaciones específicas dentro de una canalización también puede ayudarte a arrancar un proyecto nuevo, ya que proporciona un marco para empezar el desarrollo.
pandas se ha importado como pd, y sqlalchemy está listo para usarse.
Este ejercicio forma parte del curso
ETL and ELT con Python
Ejercicio interactivo práctico
Prueba este ejercicio y completa el código de muestra.
def extract():
# Create a connection URI and connection engine
connection_uri = "postgresql+psycopg2://repl:password@localhost:____/____"
db_engine = sqlalchemy.____(connection_uri)