构建用于抽取数据的函数
在构建数据管道时,将代码模块化非常重要。这能让管道更易读、可复用,并有助于加快排障。为管道中的独立操作创建并使用函数,甚至在新项目起步阶段也能提供一个开发框架,帮助您尽快开始。
已将 pandas 导入为 pd,sqlalchemy 也已准备就绪。
本练习是课程的一部分
使用 Python 的 ETL 和 ELT
交互式实操练习
通过完成这段示例代码来试试这个练习。
def extract():
# Create a connection URI and connection engine
connection_uri = "postgresql+psycopg2://repl:password@localhost:____/____"
db_engine = sqlalchemy.____(connection_uri)