„T"-ul din ELT

Să nu uităm de ELT! Funcțiile extract() și load() au fost deja definite pentru tine. Tot ce mai rămâne de făcut este să finalizezi definirea funcției transform() și să rulezi pipeline-ul. Hai să trecem la treabă!

Acest exercițiu face parte din cursul

ETL și ELT în Python

Vezi cursul

Instrucțiuni pentru exercițiu

Actualizează funcția transform() pentru a apela metoda .execute() pe obiectul data_warehouse.
Folosește funcția transform() actualizată pentru a popula datele în tabela țintă total_sales, transformând datele din tabela sursă raw_sales_data.

Exercițiu interactiv practic

Încearcă acest exercițiu completând acest cod de exemplu.

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

Editează și rulează codul