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