"T" v ELT

Nezapomínáme ani na ELT! Funkce extract() a load() jsou už připravené. Teď stačí dokončit definici funkce transform() a spustit celý pipeline. Do toho!

Toto cvičení je součástí kurzu

ETL a ELT v Pythonu

Zobrazit kurz

Pokyny k cvičení

Uprav funkci transform() tak, aby volala metodu .execute() na objektu data_warehouse.
Pomocí aktualizované funkce transform() naplň data v cílové tabulce total_sales transformací dat ze zdrojové tabulky raw_sales_data.

Interaktivní cvičení na vyzkoušení si v praxi

Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.

# 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="____")

Upravit a spustit kód