T:et i ELT

Glöm inte ELT! Här har funktionerna extract() och load() redan definierats åt dig. Nu återstår bara att färdigställa funktionen transform() och köra pipelinen. Nu kör vi!

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 nyligen uppdaterade funktionen transform() för att fylla tabellen 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