Modelado

Bronze conserva fidelidad y trazabilidad; Silver aplica contratos y conformado; Gold publica modelos orientados a consumo.

Cada frontera debe tener propietario, regla de calidad y estrategia de reejecución. Una capa solo se justifica si cambia garantías o consumidores.

CREATE TABLE main.silver.orders_clean AS
SELECT * FROM main.bronze.orders WHERE order_id IS NOT NULL;

Normaliza tipos, claves y zonas horarias; deduplica con reglas deterministas y separa registros que incumplen el contrato.

Calidad no equivale a descartar: observa, cuarentena o falla según impacto y posibilidad de reparación.

SELECT * FROM main.bronze.orders
WHERE order_id IS NOT NULL AND amount >= 0;

Una vista calcula al consultar; una materialized view conserva resultados y refresca; una streaming table procesa entradas incrementales; una tabla se mantiene mediante una carga explícita. Una metric view de Unity Catalog centraliza dimensiones y medidas gobernadas para que distintas herramientas evalúen la misma semántica mediante MEASURE().

La elección depende de latencia, patrón de cambios y coste de recomputación. Una metric view no corrige un grain físico defectuoso ni sustituye una materialización cara: se apoya en fuentes bien modeladas y evita que cada dashboard redefina ingresos, margen o clientes activos.

CREATE OR REFRESH MATERIALIZED VIEW main.gold.daily_sales AS
SELECT order_date, sum(amount) revenue
FROM main.silver.orders GROUP BY order_date;

La tabla de hechos fija un grain inequívoco y contiene claves y medidas; dimensiones describen cliente, producto o tiempo.

El grain se define antes de columnas. Mezclar una fila por pedido con una por línea duplica importes y rompe agregaciones.

SELECT order_id, line_id, customer_key, product_key, quantity, net_amount
FROM main.silver.order_lines;

Checks de unicidad, completitud, validez y frescura deben tener umbral y acción, no solo una consulta booleana.

Los SLO permiten detectar degradación y decidir si bloquear publicación. El contrato se versiona cuando cambia la expectativa del consumidor.

SELECT avg(CASE WHEN customer_id IS NOT NULL THEN 1 ELSE 0 END) AS completeness
FROM main.silver.orders;