Huruf "T" dalam ELT
Jangan lupakan ELT! Di sini, fungsi extract() dan load() sudah disiapkan untuk Anda. Sekarang, yang tersisa adalah menyelesaikan definisi fungsi transform() dan menjalankan pipeline. Semangat!
Latihan ini adalah bagian dari kursus
ETL dan ELT di Python
Petunjuk latihan
- Perbarui fungsi
transform()untuk memanggil method.execute()pada objekdata_warehouse. - Gunakan fungsi
transform()yang telah diperbarui tersebut untuk mengisi data pada tabel targettotal_salesdengan mentransformasi data pada tabel sumberraw_sales_data.
Latihan interaktif praktis
Cobalah latihan ini dengan menyelesaikan kode contoh berikut.
# 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="____")