สร้างฟังก์ชันสำหรับดึงข้อมูล
การแบ่งโค้ดออกเป็นโมดูลเป็นสิ่งสำคัญมากเมื่อสร้าง data pipeline เพราะช่วยให้ pipeline อ่านง่ายขึ้น นำกลับมาใช้ซ้ำได้ และแก้ไขปัญหาได้รวดเร็วขึ้น นอกจากนี้ การสร้างฟังก์ชันสำหรับแต่ละขั้นตอนยังช่วยให้เริ่มต้นโปรเจกต์ใหม่ได้ง่ายขึ้น เพราะมีโครงสร้างพร้อมสำหรับการพัฒนาทันที
ได้ import pandas เป็น pd และ sqlalchemy พร้อมใช้งานแล้ว
แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร
ETL และ ELT ด้วย Python
แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำ
ลองทำแบบฝึกหัดนี้โดยเติมโค้ดตัวอย่างนี้ให้สมบูรณ์
def extract():
# Create a connection URI and connection engine
connection_uri = "postgresql+psycopg2://repl:password@localhost:____/____"
db_engine = sqlalchemy.____(connection_uri)