Chữ "T" trong ELT
Đừng quên ELT! Ở đây, các hàm extract() và load() đã được định nghĩa sẵn cho bạn. Giờ việc còn lại là hoàn thiện hàm transform() và chạy pipeline. Bắt tay vào làm thôi!
Bài tập này là một phần của khóa học
ETL và ELT với Python
Hướng dẫn bài tập
- Cập nhật hàm
transform()để gọi phương thức.execute()trên đối tượngdata_warehouse. - Dùng hàm
transform()vừa cập nhật để đổ dữ liệu vào bảng đíchtotal_salesbằng cách chuyển đổi dữ liệu trong bảng nguồnraw_sales_data.
Bài tập tương tác thực hành trực tiếp
Hãy thử làm bài tập này bằng cách hoàn thành đoạn mã mẫu này.
# 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="____")