Пример трансформации данных на Python (библиотека pandas):

 

import pandas as pd

 

# 1. Extract (Извлечение)

df_sales = pd.read_csv('raw_sales.csv')

 

# 2. Transform (Очистка и расчет показателей)

df_sales = df_sales.dropna(subset=['client_id', 'amount'])

df_sales['sale_date'] = pd.to_datetime(df_sales['sale_date'])

df_sales['amount_with_vat'] = df_sales['amount'] * 1.12

 

# 3. Load (Загрузка в аналитическую витрину)

df_sales.to_parquet('dwh_fact_sales.parquet', index=False)