from datazone import transform, Input, Dataset
@transform(
input_mapping={
"orders": Input(Dataset(alias="order_data")),
"customers": Input(Dataset(alias="customer_data")),
"products": Input(Dataset(alias="product_catalog"))
}
)
def create_order_summary(orders, customers, products):
# Join orders with customer data
orders_with_customers = orders.join(
customers,
orders.customer_id == customers.id,
"left"
)
# Join with product data
complete_orders = orders_with_customers.join(
products,
orders.product_id == products.id,
"left"
)
return complete_orders.select(
"order_id",
"order_date",
"customer_name",
"product_name",
"quantity",
"total_amount"
)