Συγκεντρωτικές και ενοποιημένες εκθέσεις

Συγκέντρωση και ενοποιημένη παροχή στοιχείων

Ομαδοποίηση είναι η μετατροπή λεπτομερών αρχείων σε συνοπτικούς δείκτες για τα απαιτούμενα τμήματα και περιόδους. Ενοποίηση - συνδυασμός συγκεντρωτικών μεγεθών από διάφορες πηγές/νομικές οντότητες/προϊόντα σε μια ενιαία έκθεση με προσαρμογές (νόμισμα, λογιστική πολιτική, εξάλειψη). Ακολουθεί μια συστηματική προσέγγιση: από το σχεδιασμό παραθύρων καταστημάτων έως τη λειτουργία υποβολής εκθέσεων.

1) Καθήκοντα και είδη ενοποίησης

Λειτουργική/προϊόν: DAU/WAU/MAU, μετατροπές, έσοδα ανά χώρα/κανάλι/πλατφόρμα.
Χρηματοοικονομικά (πρώην ρυθμιστικά): P&L, ταμειακές ροές, ισολογισμός, GGR/καθαρά έσοδα τυχερών παιχνιδιών, φόροι, εκθέσεις νομικών οντοτήτων.
Κίνδυνος/συμμόρφωση: καταπολέμηση της απάτης, δείκτες RG, SLA/διαθεσιμότητα, μετατόπιση δεδομένων/μοντέλου.
Στρατηγική: ενοποιημένη ΚΔΕ με συμμετοχή, χαρτοφυλάκιο εμπορικών σημάτων, περιφέρειες.

2) Αρχιτεκτονική του στρώματος συγκέντρωσης

Επίπεδα δεδομένων: «ακατέργαστο» → «στάδιο» → «πυρήνας» (γεγονότα/διαστάσεις) → «μαρτ» (συγκεντρωτικά μεγέθη εκθέσεων).
Σημασιολογικό στρώμα: μετρικοί ορισμοί, ημερολόγιο, νομίσματα, κανόνες ανατροπής.
Σιτηρά και χρονόσποροι: «event», «user _ day», «txn», «brand _ country _ day» → περαιτέρω ανατροπές μέχρι την εβδομάδα/μήνα/τρίμηνο.
Ταυτότητες: σταθερά κλειδιά (user/brand/legal_entity), πίνακες χαρτογράφησης).

3) Ανατροπές και ιεραρχίες

Οι ιεραρχίες διάστασης είναι Game → Category → Provider, Channel → Campaign → Creative, City → Region → Country → Cluster.
Κανόνες άθροισης: πρόσθετο (άθροισμα), ημιπρόσθετο (στιγμιότυπο - μέσος/τελευταίος για την περίοδο), μη πρόσθετο (συντελεστές/ποσοστά).
Απεμπλοκή - μοναδικοί χρήστες και συμβάντα σιτηρών. να αποφεύγεται η διπλή μέτρηση κατά τη συγχώνευση πηγών.

4) Πολυκρατικό νόμισμα, χρονικές ζώνες, ημερολογιακό πρόγραμμα

Ώρα: αποθήκευση 'event _ time _ utc' και τοπικές φέτες. ημερολογιακό πρόγραμμα των αργιών/εργάσιμων ημερών.
Νόμισμα: Διατηρήστε το «ακατέργαστο» ποσό + 'base _ ccy' στη συναλλαγματική ισοτιμία κατά την ημερομηνία συναλλαγής (ή τη μέση συναλλαγματική ισοτιμία της περιόδου με ένα σπήλαιο).
Κανονικοποίηση: Εμφάνιση ρητών μονάδων/νομίσματος/ημερομηνίας συναλλαγματικής ισοτιμίας.

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) Ενοποίηση κατά πηγή/νομική οντότητα

Χαρτογραφήσεις λογαριασμών: ενιαία CoA (διάγραμμα λογαριασμών) + χαρτογράφηση από τοπικά σχέδια.
Λογιστικές πολιτικές: ΔΠΧΑ/ΓΑΛΑ/φορολογικοί κανόνες → επίπεδο μετατροπής (για παράδειγμα, ακαθάριστα/καθαρά έσοδα, αναγνώριση πριμοδοτήσεων/προμηθειών).
Εξάλειψη του κύκλου εργασιών εντός του ομίλου: εξαίρεση των συναλλαγών μεταξύ νομικών οντοτήτων του χαρτοφυλακίου.
Μέθοδοι ενοποίησης: πλήρης, αναλογική, μέθοδος της καθαρής θέσης.
Μειοψηφούντες μέτοχοι: κατανομή μη ελέγχουσας συμμετοχής (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) Ποιότητα και συμφιλίωση

Συμφωνίες πηγής: ποσό ανά πηγή = ποσό στην έκθεση (με συναλλαγματική ισοτιμία/ανοχή χρόνου).
Αναλλοίωτες: 'DAU ≤ MAU', άθροισμα ημερών = μηνιαίο σύνολο (για πρόσθετες μετρήσεις).
Έλεγχος πληρότητας: μερίδιο της NULL, μερίδιο των αντιγράφων, υστέρηση της φρεσκάδας.
Έκθεση διαφορών - Κατάλογος διαφορών και μέτρων αποκατάστασης.

7) Επιδόσεις και SLO

Νωπότητα SLO: επιχειρησιακές μονάδες - υστέρηση ≤ 15 λεπτά. ημέρα - έως τις 06:00 τοπική ώρα, μηνιαίως - έως T + 1/T + 3.
Βελτιστοποίηση: προ-συγκεντρώσεις, επαυξητικοί επανυπολογισμοί, κατάτμηση (κατά ημερομηνία/μάρκα/χώρα), κρύπτη για δημοφιλείς φέτες.
Περιορισμοί UI: ≤ 12 κατηγορίες ανά χρονοδιάγραμμα. σελιδοποίηση πινάκων· τεμπέλης-φορτίο.

8) Διαχείριση ορισμών και εκδόσεων

Λεξικό μετρήσεων: κώδικας, ορισμός, τύπος, πηγή, μονάδες, ιδιοκτήτες, φρουροί.
Έκδοση: 'METRIC _ vN', τυχόν επεξεργαστές → νέα έκδοση + backfill και changelog.
Σημασιολογικό στρώμα: μια πηγή αλήθειας για ΔΙ/πειράματα/αποστολές.

9) Ασφάλεια και πρόσβαση

RLS/CLS: πρόσβαση ανά ρόλο (χώρα/εμπορικό σήμα/νομική οντότητα), συγκάλυψη PII.
Έλεγχος: ποιος ανέβασε την έκθεση. έλεγχος των εξαγωγών (προθεσμίες, μάρκες).
Ελαχιστοποίηση: έκδοση συγκεντρωτικών στοιχείων αντί ακατέργαστων δεδομένων PII.

10) Τυπικά συγκεντρωτικά μεγέθη και οπτικοποιήσεις

Προϊόν: χοάνες (step-bars), ομάδες (heatmap), κατακράτηση D7/D30, ARPU/ARPPU, GGR/Net.
Χρηματοδότηση: P&L ανά ιεραρχία, παράγοντες καταρράκτη (γέφυρα), διάρθρωση εσόδων ανά περιφέρεια, δυναμική G&A.
Λειτουργίες/ML: SLA, καθυστέρηση p95/p99, PR- AUC/Recall@FPR≤x%, μετατόπιση χάρτη θερμότητας PSI.

11) Διαβατήριο της ενοποιημένης έκθεσης (υπόδειγμα)

Κωδικός/έκδοση: 'CONSOL _ PNL _ v3'

Σκοπός: Διαχείριση P&L ανά όμιλο εμπορικών σημάτων, πολυεθνικό νόμισμα → βασικό νόμισμα ευρώ

Κάλυψη: όλες οι νομικές οντότητες του ομίλου. μέθοδος - πλήρης ενοποίηση· NCI - Επισημάνθηκε

Πηγή/στρώμα: 'mart _ fin _ pnl _ v3' (βάσει 'fact _ tx _ v2', 'dim _ legal', 'dim _ fx _ rates')

Κοκκία: μήνας (rollup for day)

Εξάλειψη: «intercompany = true» - αποκλείεται ο κύκλος εργασιών εντός του ομίλου

SLO: T + 1 06:00 κλειδαριά; διαθεσιμότητα 99 ευρώ. 9%

Συμφωνίες - λογιστική έκθεση 'BK _ PNL _ T + 1', διακύμανση ≤ 0. 3%

Ιδιοκτήτες: Finance Analytics, Πλατφόρμα Δεδομένων

πίνακας FX όχι μεγαλύτερος των 24 ωρών· συναλλαγές κάλυψης 99 ευρώ. 5%

12) Συχνά λάθη και τρόπος αποφυγής τους

Η ήσυχη φόρμουλα αλλάζει: πάντα μέσω εκδόσεων και changelog.
Διπλή μέτρηση: Διπλά ελατήρια/joynes - κλειδιά ελέγχου και κόκκοι.
Ζώνες ώρας ανάμειξης: κεντρική αποθήκευση ημερολογίου και UTC.
Εσφαλμένα ποσοστά: Συνολικός αριθμητής/παρονομαστής, όχι «μέσος όρος».
«Ακατέργαστοι» συντελεστές: ρητή ημερομηνία/πηγή FX, συνεπής πολιτική στρογγυλοποίησης.
Καμία εξάλειψη: διεπιχειρησιακοί κύκλοι εργασιών.
Αδιαφανής φρεσκάδα: Πάντα να δείχνεις «ενημερωμένο Ν λεπτά πριν».

13) Ψευδο- SQL: Προσαυξητικό μηνιαίο σύνολο

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) Διαδικασίες και λειτουργία

1. Σχεδιασμός: στόχοι/ακροατήρια, μετρήσεις, ιεραρχίες, νόμισμα/χρονικές ζώνες.
2. Δεδομένα: συμβάσεις πηγής, συστήματα, δοκιμές ποιότητας.
3. Κατασκευή παραθύρων: σημασιολογικά αντικείμενα, κανόνες ανατροπής, αποκλεισμοί.
4. Συνδυασμοί: αυτόματες αναφορές διαφορών, διορθωτικά εισιτήρια.
5. Έκδοση, τεκμηρίωση, κατάρτιση των χρηστών.
6. Παρακολούθηση: φρεσκάδα, πληρότητα, αντίγραφα, χρόνος απόκρισης, συμβάντα.
7. Αναθεώρηση: τριμηνιαία επαλήθευση των ορισμών, των χαρτογραφήσεων, των πολιτικών FX.

15) Προκαταρκτικός κατάλογος ελέγχου ενοποιημένης δήλωσης

• Ορισμοί μέτρησης και ιεραρχίας τεκμηριωμένοι σε σημασιολογικό επίπεδο
• Καθορίζονται η μετατροπή νομισμάτων και οι χρονικές ζώνες. παρουσιάζει τις μονάδες και την ημερομηνία του μαθήματος
• Επαναστάσεις εντός του ομίλου/Εξάλειψη του NCI (κατά περίπτωση)
• Οι αναλλοίωτες και οι συμβατότητες με τις πηγές αναφοράς πραγματοποιούνται σε ανοχές
• Επιτρεπόμενοι προσαυξητικοί επανυπολογισμοί και διαχωρισμός
• καθορίζονται SLO νωπότητας/διαθεσιμότητας· εμφανίζονται καταστάσεις επικαιροποίησης
• Η μάσκα RLS/CLS και PII είναι διαμορφωμένες. Επιτρεπόμενος έλεγχος εξαγωγών
• Προσδιορισμός της έκδοσης/του changelog και των ιδιοκτητών· έχουν συμβάντα στο πλαίσιο του runbook

Σύνολο

Η ομαδοποίηση και η ενοποίηση δεν είναι μόνο «ΟΜΑΔΑ BY», αλλά ένα ολιστικό σύστημα: συνεκτικοί ορισμοί, ορθές ανατροπές, πολλαπλά νομίσματα και ημερολογιακό πρόγραμμα, εξαλείψεις και συμφωνίες, παρατηρησιμότητα και SLO. Ακολουθώντας την περιγραφόμενη αρχιτεκτονική, μετατρέπετε τα ετερογενή δεδομένα σε αξιόπιστα θησαυροφυλάκια για τη διαχείριση προϊόντων, οικονομικών και κινδύνων.