Aggregazione e report consolidati

Aggregazione e report consolidati

Aggregazione: conversione di record dettagliati in indicatori riepilogativi per i tagli e i periodi desiderati. Consolidamento: aggregazione di aggregazioni da diverse fonti/entità/prodotti in un unico report con aggiustamenti (valuta, politica di contabilità, eliminazione). Il seguente è l'approccio di sistema, dalla progettazione delle vetrine all'utilizzo dei report.

1) Attività e tipi di consolidamento

Operazioni/prodotti: DAU/WAU/MAU, conversioni, ricavi per paese/canale/piattaforma.
Finanziaria (per esempio). e regolatori) P&L, Cash Flow, Balance Sheet, GGR/Net Gaming Revenue, tasse, rapporti legali.
Rischio/compilazione: antifrode, indicatori RG, SLA/disponibilità, deriva dati/modelli.
Strategico: riepilogo KPI per holding, portafoglio marchi, regioni.

2) Architettura livello aggregazione

Livelli di dati: "raw" "staging" core "(fatti/misurazioni)" marts "(aggregati per rapporti).
Livello semantico: definizioni di metriche, calendario, valute, regole di rollap.
Grano e time-grain: 'event', 'user _ day', 'txn', 'brand _ country _ day', 'user _ day', 'txn', 'brand _ country _ day'.
Identità: chiavi stabili (user/brand/legale _ entity), tabelle di corrispondenza (mapping).

3) Rulli e gerarchie

Gerarchie di misurazione: « », «Canale» Campagna «,» Città-Regione «, Paese-Cluster».
Le regole di sommazione sono additive (importo), semidimensionali (snapshot - media/ultima per il periodo), inadeguate (coefficienti/interessi).
Deduplicazione: utenti e eventi unici per cereali Evitare la doppia contabilità nella fusione delle fonti.

4) Multivaluta, timsons, calendario

Tempo: memorizza «event _ time _ utc» e i tagli locali; calendario delle feste/giorni schiavi.
Valuta: conserva il valore «grezzo» + «base _ ccy» al tasso di cambio alla data dell'operazione (o il tasso medio del periodo con riserva).
Normalizzazione: mostra le unità/valuta/data del corso esplicite.

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) Consolidamento per origine/giurisprudenza

Mapping dei piani di conto: un unico CoA (Chart of Accounts) + macping da piani locali.
Regole di contabilità: IFRS/GAAP/regole fiscali su uno strato di trasformazioni (ad esempio ricavi bruti/netti, riconoscimento di bonus/commissioni).
L'eliminazione delle transazioni tra i legali della holding.
Metodi di consolidamento: completa, quotata (proportionate), contabilità di partecipazione (equity method).
Minori: assegnazione di una quota di azionisti non controllati (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) Qualità e incrociatura

Crocifissi per origine: importo per origine = importo in vetrina (con accesso al corso/ora).
Invarianti: «DAU ≤ MAU», importo giornaliero = totale mensile (per le metriche additive).
Controllo completo: quota NULL, quota di duplicati, ritardo di freschezza.
Report soluzione temporanea: elenco delle non conformità e fasi di risoluzione.

7) Prestazioni e SLO

UNITÀ DI FRESCHEZZA - Unità operative - Lega di 15 mine; diurni fino alle 6:00 locali; mensilità fino a T + 1/T + 3.
Ottimizzazione: pre-aggregazione, conteggio incrementale, partizionamento (per data/marchio/paese), cache per tagli popolari.
Limiti UI: ≤ 12 categorie per grafico; paginazione delle tabelle lazy-load.

8) Gestione di definizioni e versioni

Dizionario metrico: codice, definizione, formula, origine, unità, proprietari, guardrail.
Versioning: «METRIC_vN»; tutte le modifiche → una nuova versione di + backfill e changelog.
Uno strato semantico è una fonte di verità per BI/esperimenti/spedizioni.

9) Sicurezza e accesso

RLS/CLS: accesso a ruoli (paese/marchio/giurista), maschera PII.
Controllo: chi ha scaricato e quale rapporto; Controllo dell'esportazione (scadenze, token).
Minimizzazione: rilasciare aggregazioni, non dati PII crudi.

10) Apparecchiature e visualizzazioni tipiche

Prodotto: vortici (step-bars), coorti (heatmap), ritenzione D7/D30, ARPU/ARPPU, GGR/Net.
Finanza: P&L per gerarchia, cascata (bridge) fattori, struttura dei ricavi per regione, dinamica G & A.
Operazioni/ML: SLA, latency p95/p99, PR- AUC/Recall@FPR≤x%, PSI-heatmap deriva.

11) Passaporto report consolidato (modello)

Codice/versione: 'CONSOL _ PNL _ v3'

Assegnazione P&L manageriale per gruppo di marchi, multivaluta e valuta base EUR

Copertura: tutti i legali del gruppo; Metodo di consolidamento completo NCI - Evidenziazione

Sorgente/livello: 'mart _ fin _ pnl _ v3' (basato sù fact _ tx _ v2 ',' dim _ legale ',' dim _ fx _ rates ')

Granularità mese (Rollap giorno)

Elimitazioni: «intercompany = true» - Esclusi giri intra-gruppo

SLO: T + 1 06:00; Disponibilità ≥ 99. 9%

Report di contabilità «BK _ PNL _ T + 1», soluzione temporanea 0. 3%

Proprietari: Finance Analytics, Data Platform

Guardrails: tabella FX non superiore a 24 ore; coverage transazioni ≥ 99. 5%

12) Errori frequenti e come evitarli

Modifiche silenziose alle formule, sempre attraverso versioni e changelog.
Doppia contabilità: immagini sorgenti/gioielli - Controlla chiavi e grano.
Combinazione di zone temporanee: calendario centralizzato e storage UTC.
Interessi errati: aggregare il numeratore/denominatore anziché il «medio».
Corsi crudi: data/origine FX esplicita, criterio di arrotondamento consistente.
L'assenza di elimitazioni: le rotazioni tra i gruppi distorcono i rapporti.
Freschezza opaca: mostra sempre «aggiornato N minuti fa».

13) Pseudo-SQL: aggregazione mensile incrementale

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) Processi e operazioni

1. Design: obiettivi/pubblico, metriche, gerarchie, valuta/timesone.
2. I dati sono contratti di origine, schemi, test di qualità.
3. Creazione di vetrine: oggetti semantici, regole di rollap, eliminazione.
4. Scorciatoie: rapporti automatici di soluzione temporanea, ticket di correzione.
5. Versione, documentazione, formazione degli utenti.
6. Monitoraggio: freschezza, completeness, duplicati, tempi di risposta, incidenti.
7. Revisione: verifica trimestrale delle definizioni, dei mapping, dei criteri FX.

15) Foglio di assegno prima di rilasciare un report consolidato

• Definizioni di metriche e gerarchie documentate in un livello semantico
• La conversione delle valute e i timsons sono configurati; visualizza le unità e la data del corso
• Elimitazioni di rotazione/NCI (se applicabile)
• Gli invarianti e le ricomposizioni con le sorgenti arbitrali vengono eseguiti nelle tolleranze
• Conteggio incrementale e partizionamento inclusi
• SLO di freschezza/disponibilità impostati; gli stati di aggiornamento vengono visualizzati
• RLS/CLS e la maschera PII sono configurati; controllo di esportazione attivato
• Versione/changelog e proprietari specificati; ci sono incidenti runbook

Totale

Aggregazione e consolidamento non sono solo «GROUP BY», ma un sistema olistico: definizioni coerenti, roll corretti, multivaluta e calendario, elimitazioni e compressioni, osservabilità e SLO. In base all'architettura descritta, i dati eterogenei vengono trasformati in dati affidabili per la gestione del prodotto, della finanza e dei rischi.