ddmitry/de-roadmap
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Забыли заполнить dds.orders

Browse Source
This commit is contained in:
ddadmin
2025-11-07 16:31:23 +03:00
parent cefe9971b8
commit be1557716f
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
dwh-modeling/sql/02_dim.sql
+10 -2
View File
@@ -37,6 +37,14 @@ INSERT INTO stg.products_raw (product_id, name) VALUES
TRUNCATE ods.customers, ods.orders, ods.order_items, ods.products; TRUNCATE ods.customers, ods.orders, ods.order_items, ods.products;
INSERT INTO ods.orders (order_id, order_date, customer_id)
SELECT
order_id::INT,
TO_DATE(order_date, 'YYYY-MM-DD'),
customer_id::INT
FROM stg.orders_raw
WHERE order_date IS NOT NULL AND customer_id ~ '^\d+$';
-- берём по BK самую позднюю запись (event_ts > _load_ts > _load_id) -- берём по BK самую позднюю запись (event_ts > _load_ts > _load_id)
WITH src AS ( WITH src AS (
SELECT SELECT
@@ -191,5 +199,5 @@ JOIN dds.dim_customer dc
-- 7. Проверка — вывод итогов (не часть ETL, но полезно для отладки) -- 7. Проверка — вывод итогов (не часть ETL, но полезно для отладки)
-- В реальном пайплайне такие SELECT выносятся в отдельные скрипты или дашборды -- В реальном пайплайне такие SELECT выносятся в отдельные скрипты или дашборды
-- SELECT 'dim_customer count = ' || COUNT(*) FROM dds.dim_customer; SELECT 'dim_customer count = ' || COUNT(*) FROM dds.dim_customer WHERE is_current ;
-- SELECT 'fact_sales count = ' || COUNT(*) FROM dds.fact_sales; SELECT 'fact_sales count = ' || COUNT(*) FROM dds.fact_sales;