ETL_zalando_transform

transform.py

def transform_data(ti) -> None:
    data = ti.xcom_pull(key='extracted_data', task_ids=['extract_data'])[0]
    transformed_data = []
    for item in data:
        transformed_data.append({
            'sku': item.get("sku", ""),
            'Name': item['name'],
            'Price': item['price'].get("original"),
            'Brand Name': item['brand_name'],
            'Thumbnail': f"https://img01.ztat.net/article/{item['media'][0]['path']}",
            'Product URL': f"https://www.zalando.co.uk/{item['url_key']}.html"
        })
    ti.xcom_push(key='transformed_data', value=transformed_data)