"T":et i ELT

Dags att fokusera på ELT! Funktionerna extract() och load() är redan definierade. Det som återstår är att färdigställa funktionen transform() och köra pipelinen.

Den här övningen är en del av kursen

ETL och ELT i Python

Visa kurs

Övningsinstruktioner

Uppdatera funktionen transform() så att den anropar metoden .execute() på objektet data_warehouse.
Använd den uppdaterade funktionen transform() för att fylla måltabellen total_sales med data genom att transformera data från källtabellen raw_sales_data.

Interaktiv övning med praktiskt arbete

Testa den här övningen genom att slutföra den här exempelkoden.

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

Redigera och kör kod