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. Việc còn lại là hoàn thiện hàm transform() và chạy pipeline. Cố lên nào!
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 để đưa 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="____")