De "T" in ELT
Vergeet ELT niet! Hier zijn de functies extract() en load() al voor je gedefinieerd. Het enige wat nog rest, is de functie transform() afmaken en de pipeline draaien. Succes!
Deze oefening maakt deel uit van de cursus
ETL en ELT in Python
Oefeninstructies
- Werk de functie
transform()bij zodat deze de methode.execute()aanroept op het objectdata_warehouse. - Gebruik de zojuist bijgewerkte functie
transform()om gegevens in de doeltabeltotal_saleste vullen door gegevens in de brontabelraw_sales_datate transformeren.
Praktische interactieve oefening
Probeer deze oefening eens door deze voorbeeldcode in te vullen.
# 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="____")