建立用來擷取資料的函式
在建立資料管線時,將程式碼模組化很重要。這能讓管線更容易閱讀與重複使用,也能加速除錯流程。在管線中為不同的操作建立並使用函式,甚至能在新專案起步時提供開發框架,幫助你更快展開工作。
已將 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)