Agregación e informes consolidados

Agregación e informes consolidados

La agregación es la conversión de registros detallados en indicadores de resumen por los cortes y períodos deseados. Consolidación - Combinar agregados de diferentes fuentes/entidades/productos en un solo informe con ajustes (moneda, política contable, eliminaciones). A continuación, un enfoque sistémico: desde el diseño de escaparates hasta la operación de informes.

1) Tareas y tipos de consolidación

Operativo/producto: DAU/WAU/MAU, conversiones, ingresos por países/canales/plataformas.
Financiero (opr. y regulatorio): P&L, Cash Flow, Balance Sheet, GGR/Net Gaming Revenue, impuestos, informes jurados.
Riesgo/cumplimiento: antifraude, indicadores RG, SLA/disponibilidad, derivación de datos/modelos.
Estratégico: KPI consolidados por holding, portafolio de marcas, regiones.

2) Arquitectura de capas de agregaciones

Capas de datos: 'raw' → 'staging' → 'core' (hechos/medidas) → 'marts' (agregados bajo informes).
Capa semántica: definiciones de métricas, calendario, monedas, reglas de rollup.
Grain and time-grain: 'event', 'user _ day', 'txn',' brand _ country _ day '→ más rollos hasta la semana/mes/trimestre.
Identidades: claves estables (user/brand/legal_entity), tablas de correspondencia (mapping).

3) Rollos y jerarquías

Las jerarquías de medición son: 'Juego → Categoría → Proveedor', 'Canal → Campaña → Creativo', 'Ciudad → Región → País → Clúster'.
Reglas de suma: aditivo (suma), semiaditivo (snapshot - promedio/último por período), no aditivo (coeficientes/porcentajes).
Deduplicación: usuarios únicos y eventos por grano; evite la doble contabilización en la fusión de fuentes.

4) Multivalura, zonas de tiempo, calendario

Tiempo: almacena 'event _ time _ utc' y cortes locales; calendario de vacaciones/días-esclavo.
Moneda: almacena la cantidad «cruda» + 'base _ ccy' al tipo de cambio en la fecha de la operación (o el tipo de cambio medio del periodo con reserva).
Normalización: muestra las unidades explícitas/moneda/fecha del tipo de cambio.

sql
WITH fx AS (
SELECT date, from_ccy, to_ccy, rate
FROM dim_fx_rates
WHERE to_ccy = 'EUR'
),
tx AS (
SELECT t. txn_id, t. amount, t. ccy, t. brand, t. country, t. event_date
FROM fact_tx
)
SELECT brand, country, DATE_TRUNC('month', event_date) AS month,
SUM(amount COALESCE(fx. rate, 1)) AS revenue_eur
FROM tx
LEFT JOIN fx
ON fx. date = tx. event_date AND fx. from_ccy = tx. ccy
GROUP BY 1,2,3;

5) Consolidación por fuentes/jurlis

Mapping de planes de cuentas: CoA (Chart of Accounts) + mapping desde planes locales.
Políticas contables: IFRS/GAAP/reglas fiscales → capa de transformación (por ejemplo, ingresos brutos/netos, reconocimiento de bonificaciones/comisiones).
Eliminaciones de revoluciones intragrupo: exclusión de transacciones entre jurados de la explotación.
Métodos de consolidación: total, participativo (proportionate), contable por participación (equity method).
Minoritarios: asignación de la participación de los accionistas descontrolados (NCI).

sql
WITH interco AS (
SELECT a. txn_id
FROM fact_tx a
JOIN dim_counterparty b ON a. counterparty_id = b. id
WHERE a. legal_entity IN (SELECT id FROM dim_legal WHERE group_id = 1)
AND b. legal_entity IN (SELECT id FROM dim_legal WHERE group_id = 1)
)
SELECT
FROM agg_pl_month
WHERE txn_id NOT IN (SELECT txn_id FROM interco);

6) Calidad y conciliación (reconciliation)

Conciliaciones por fuente: suma por fuente = suma en escaparate (con tolerancia por tasa/tiempo).
Invariantes: 'DAU ≤ MAU', suma por día = total mensual (para métricas aditivas).
Control de integridad: proporción NULL, proporción de duplicados, retraso en la frescura.
Informe de discrepancias: lista de inconsistencias y pasos para resolver.

7) Rendimiento y SLO

Frescura de SLO: unidades operativas - tracción ≤ 15 min; diurna - hasta 06:00 hora local; mensual - hasta T + 1/T + 3.
Optimización: preagrupaciones, recalculaciones incrementales, particiones (por fecha/marca/país), caché para cortes populares.
Restricciones de IU: ≤ 12 categorías por gráfico; paginación de tablas; lazy-load.

8) Administración de definiciones y versiones

Diccionario métrico: código, definición, fórmula, fuente, unidades, propietarios, guardrails.
Versificación: 'METRIC _ vN'; cualquier edición → nueva versión + backfill y changelog.
Capa semántica: una fuente de verdad para BI/experimentos/envíos.

9) Seguridad y acceso

RLS/CLS: acceso por roles (país/marca/jurlizo), enmascaramiento PII.
Auditoría: quién y qué informe descargó; control de la exportación (plazos, tokens).
Minimización: emitir unidades, no datos PII crudos.

10) Unidades y visualizaciones típicas

Producto: embudos (step-bars), cohortes (heatmap), retención de D7/D30, ARPU/ARPPU, GGR/Net.
Finanzas: P&L por jerarquía, cascada (puente) de factores, estructura de ingresos por región, dinámica de G & A.
Operaciones/ML: SLA, latency p95/p99, PR- AUC/Recall@FPR≤x%, PSI-heatmap deriva.

11) Pasaporte de informe consolidado (plantilla)

Código/versión: 'CONSOL _ PNL _ v3'

Destino: gestión de P&L por grupo de marcas, multivalor → moneda base EUR

Cobertura: todos los jurados del grupo; método - consolidación completa; NCI - Resaltado

Fuente/capa: 'mart _ fin _ pnl _ v3' (basado en 'nat _ tx _ v2', 'dim _ legal', 'dim _ fx _ rates')

Granularidad: mes (rollo del día)

Eliminaciones: 'intercompany = true' - Excluidas las revoluciones intragrupo

SLO: T + 1 06:00 lock.; disponibilidad ≥ 99. 9%

Conciliaciones: informe de contabilidad 'BK _ PNL _ T + 1', discrepancia ≤ 0. 3%

Propietarios: Finance Analytics, Data Platform

Guardrails: tabla FX no mayor de 24 h; coverage de transacciones ≥ 99. 5%

12) Errores frecuentes y cómo evitarlos

Tranquilos cambios de fórmulas: siempre a través de versiones y changelog.
Doble contabilidad: toma de fuentes/joynes - controla las llaves y el grano.
Mezcla de zonas temporales: calendario centralizado y almacenamiento UTC.
Porcentajes incorrectos: agregue el numerador/denominador, no el «promedio».
Cursos «crudos»: fecha explícita/fuente FX, política coherente de redondeos.
Ausencia de eliminaciones: las revoluciones interempresariales distorsionan los informes.
Frescura opaca: muestra siempre «N actualizado hace minutos».

13) Pseudo-SQL: agregado mensual incremental

sql
-- Recalculate only affected days/months
WITH changed_days AS (
SELECT DISTINCT DATE(event_time_utc) AS d
FROM fact_tx_delta -- new/modified per day
),
daily AS (
SELECT
DATE(event_time_utc) AS d,
brand, country,
SUM(net_revenue_eur) AS net_eur
FROM fact_tx
WHERE DATE(event_time_utc) IN (SELECT d FROM changed_days)
GROUP BY 1,2,3
)
MERGE INTO agg_month_brand_country m
USING (
SELECT DATE_TRUNC('month', d) AS month, brand, country, SUM(net_eur) AS net_eur
FROM daily
GROUP BY 1,2,3
) s
ON (m. month = s. month AND m. brand = s. brand AND m. country = s. country)
WHEN MATCHED THEN UPDATE SET m. net_eur = s. net_eur, m. updated_at = NOW()
WHEN NOT MATCHED THEN INSERT (month, brand, country, net_eur, updated_at)
VALUES (s. month, s. brand, s. country, s. net_eur, NOW());

14) Procesos y operación

1. Diseño: objetivos/audiencias, métricas, jerarquías, moneda/zonas de tiempo.
2. Datos: contratos de fuentes, esquemas, pruebas de calidad.
3. Construcción de escaparates: objetos semánticos, reglas de rollup, eliminaciones.
4. Conciliaciones: informes automáticos de discrepancias, tickets de corrección.
5. Lanzamiento: versión, documentación, formación de usuarios.
6. Monitoreo: frescura, completeness, duplicados, tiempo de respuesta, incidentes.
7. Revisión: comprobación trimestral de definiciones, mappings, políticas FX.

15) Lista de verificación antes de emitir el informe consolidado

• Las definiciones de métricas y jerarquías están documentadas en la capa semántica
• Se han configurado conversiones de divisas y temporizadores; se muestran las unidades y la fecha del curso
• Eliminaciones realizadas de revoluciones intragrupo/NCI (si corresponde)
• Los invariantes y las conciliaciones con fuentes de referencia pasan en tolerancias
• Se incluyen los recuentos incrementales y las partidas
• Los SLO de frescura/disponibilidad se establecen; los estados de actualización se muestran
• RLS/CLS y enmascaramiento PII están configurados; auditoría de exportación habilitada
• Versión/changelog y propietarios especificados; hay incidentes runbook

La agregación y consolidación no es solo un 'GROUP BY', sino un sistema holístico: definiciones coherentes, rollos correctos, multivalor y calendario, eliminaciones y conciliaciones, observabilidad y SLO. Siguiendo la arquitectura descrita, convierte datos heterogéneos en bóvedas confiables para administrar el producto, las finanzas y los riesgos.