„T"-ul din ELT
Să nu uităm de ELT! Aici, funcțiile extract() și load() sunt deja definite pentru tine. Tot ce mai trebuie să faci este să finalizezi definirea funcției transform() și să rulezi pipeline-ul. Succes!
Acest exercițiu face parte din cursul
ETL și ELT în Python
Instrucțiuni pentru exercițiu
- Actualizează funcția
transform()pentru a apela metoda.execute()pe obiectuldata_warehouse. - Folosește funcția
transform()nou actualizată pentru a popula datele în tabelul țintătotal_sales, transformând datele din tabelul sursăraw_sales_data.
Exercițiu interactiv practic
Încearcă acest exercițiu completând acest cod de exemplu.
# 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="____")