"T" ใน ELT
อย่าลืม ELT! ที่นี่ฟังก์ชัน extract() และ load() ถูกกำหนดไว้ให้แล้ว สิ่งที่เหลือคือกำหนดฟังก์ชัน transform() ให้เสร็จสมบูรณ์แล้วรันไปป์ไลน์ ลุยกันเลย!
แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร
ETL and ELT ใน Python
คำแนะนำการฝึกหัด
- ปรับปรุงฟังก์ชัน
transform()ให้เรียกใช้เมธอด.execute()บนอ็อบเจกต์data_warehouse - ใช้ฟังก์ชัน
transform()ที่เพิ่งปรับปรุงเพื่อเติมข้อมูลในตาราง target ชื่อtotal_salesโดยแปลงข้อมูลจากตาราง source ชื่อraw_sales_data
แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำ
ลองทำแบบฝึกหัดนี้โดยเติมโค้ดตัวอย่างนี้ให้สมบูรณ์
# Complete building the transform() function
def transform(source_table, target_table):
data_warehouse.____(f"""
CREATE TABLE {target_table} AS
SELECT
CONCAT("Product ID: ", product_id),
quantity * price
FROM {source_table};
""")
extracted_data = extract(file_name="raw_sales_data.csv")
load(data_frame=extracted_data, table_name="raw_sales_data")
# Populate total_sales by transforming raw_sales_data
____(source_table="____", target_table="____")