De "T" in ELT
We vergeten ELT niet! Hier zijn de functies extract() en load() al voor je gedefinieerd. Jij hoeft nu alleen de functie transform() af te maken en de pipeline uit te voeren. 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 te vullen in de doeltabeltotal_salesdoor gegevens uit de brontabelraw_sales_datate transformeren.
Interactieve oefening met praktijkervaring
Probeer deze oefening door deze voorbeeldcode aan 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="____")