विश्लेषणात्मक डेटा का तुल्यकालन

1) पारिस्थितिकी तंत्र को एनालिटिक्स सिंक्रनाइज़ेशन की आवश्यकता क्यों है

नेटवर्क ऑपरेटरों, स्टूडियो/आरजीएस, सहयोगी, पीएसपी/एपीएम, केवाईसी/एएमएल प्रदाताओं और मीडिया को एक साथ लाता है। एक एकल चित्र (फ़नल्स CR→FTD→ARPU/LTV, आरजी/अनुपालन, परिवहन एसएलओ, वित्त/रेवशेयर) को देखने के लिए, पारिस्थितिकी तंत्र को परिवर्तन और लागत नियंत्रण के स्पष्ट इतिहास के साथ "दो सत्य" के बिना, श्रृंखला और समय पर डेटा सिंक्रीकरण की जरूरत होती है।

2) ऑन्कोलॉजी और डेटा अनुबंध

: 'EventId', 'traceId', 'parthantId', 'रोल' (ऑपरेटर/स्टूडियो/सहबद्ध/psp/kyc/stream), 'क्षेत्राधिकार', 'bandId', 'apmId', 'gamIId', 'मुद' मुद्रा 'स्कीमासंस्करण', ' संस्करण'।

• 'क्लिक', 'सत्र _ स्टार्ट', 'पंजीकरण', 'kyc _ station', 'ftd', 'bet/spin', 'reverd _ vide', 'postback _ send/geated', 'rg _ gardrail _ hit', 'stregit _ streage _ sli'।

• स्कीमा रजिस्ट्री में स्कीमा (सेवर, क्षेत्र संगतता)
• मालिक, एकत्रीकरण खिड़कियां, ताजगी और पूर्णता एसएलए;
• त्रुटि नीति (nullable/stubs), निर्देशिका (मुद्राएं, स्थान, RTP प्रोफाइल)।

मेट्रिक स्टोर: सूत्र संस्करण (जीजीआर/नेटरेव/सीआर/एआरपीयू/एलटीवी, के-कारक), उनके मालिक और प्रवेश की तारीख - सूत्र हमेशा रिपोर्ट में लात मारी जाती है।

3) टेम्पोरल शब्दार्थ और खिड़कियां

घटना समय बनाम प्रसंस्करण समय: एकत्रीकरण घटना समय पर आधारित होना चाहिए, न कि प्रसंस्करण समय पर।

वाटरमार्क: "देर से" घटनाओं की निगरानी करने के लिए; स्वीकृति नीति (उदाहरण के लिए, T + 24h)।

विंडोज़: स्लाइडिंग/पंचांग, ओवरलोड के दौरान पुनर्गणना के साथ।

मीट्रिक के रूप में विलंब: 'ingest _ lag' और 'problish _ lag' प्रत्येक शोकेस के लिए प्रकाशित होते हैं।

4) परिवहन और तुल्यकालन मोड

1. सीडीसी/स्ट्रीमिंग (वास्तविक समय):

इवेंट बस (EDA), 'traceId/partnantId' द्वारा भागीदारी;

उपभोक्ता पहचान और शरीर हैश के माध्यम से "बिल्कुल एक बार अर्थ";

क्यूरेटेड विषय: कच्ची घटनाएं, सामान्यीकृत, समुच्चय/oracles।

2. बैच/माइक्रोबैच:

कर्सर पगिनेशन (अस्थायी/लॉग कर्सर) के साथ वृद्धिशील अपलोड;

प्रारूप: स्कीमा के साथ Parquet/Avro; पार्टी घोषणापत्र।

3. एपीआई/वेबहूक:

'/vN/events 'कर्सर और' Idempotency-Key 'के साथ;

वेबहूक ने हस्ताक्षर किए (JWS/HMAC), रीप्ले रजिस्ट्री, बैकऑफ + जिटर।

4. एसेट-सिंक:

निर्देशिका/लोकेल/गेम के कैटलॉग के रूप में वर्शन बंडल (हैश, टीटीएल)।

5) आइडेम्पोटेंस, डेडअप और लेट इवेंट्स

महत्वपूर्ण रास्तों (भुगतान/पोस्टबैक) पर आइडेम्पोटेंसी-की और बॉडी हैश।

Deduplication: windown 5 मिनट/वॉटरमार्क; "देखा" हैश का भंडारण।

देर से घटनाएं: अपसर्ट/बैककाउंट नीति; चेंजलोग स्टोरफ्रंट।

वास्तव में एक बार व्यावसायिक अर्थ में: हमें "ब्रोकर जादू" की आवश्यकता नहीं है, हमें उपभोक्ता की पहचान और योजनाओं के निर्धारणवाद की आवश्यकता है।

6) विशेषताओं और सूत्रों का सामंजस्य

एट्रिब्यूशन: चैनल/न्यायालयों द्वारा खिड़कियों के साथ अंतिम वैकल्पिक स्पर्श नियम, क्रॉस-डिवाइस - केवल टोकन के माध्यम से (कच्चे पीडी के बिना)।

मीट्रिक सूत्र: प्रत्येक प्रविष्टि संदर्भ ' संस्करण'; मेजर परिवर्तनों को 'डेटा _ फॉर्मूला _ चेंज' के रूप में प्रकाशित किया जाता है।

नियमों के अनुसार बैकफिल: सूत्र को बदलते समय, संक्रमण अवधि (जमे हुए अवधि) में दोहरे प्रकाशन (पुराने/नए) की अनुमति है।

7) डेटा क्वालिटी: SLI/SLO और अनुरूपता परीक्षण

• ताजगी (publish_lag p95),
• पूर्णता (घटनाओं बनाम संदर्भ का अनुपात),
• विशिष्टता (डुप्लिकेट्स का अनुपात),
• संगति (मुद्रा/लोकेल/आईडी),
• सटीकता (चेकसम/oracles),
• समय रैखिकता (गलियारे में देर से होने वाली घटनाएं)।

• publish_lag p95 ≤ 1-5 एस (ऑपरेटिंग पैनल), ≤ 15 मिनट (फिन)। इकाइयाँ);
• पूर्णता ≥ 99। T + 15 मिनट पर 5%, ≥ 99। T + 24h में 9%;
• डुप्लिकेट ≤ 0। 1‰; ओरेकल विसंगति ≤ 0। 1–0. 3%.

अनुरूपता परीक्षण: योजनाएँ, अनिवार्य क्षेत्र, निर्देशिका, वेबहुक हस्ताक्षर, अंतराल के बिना संकेतक अपलोड.

8) वंश, ऑडिटिंग और oracles

वंश: स्टोरफ्रंट/डैशबोर्ड से प्राथमिक सेट (स्कीमैटिक्स/संस्करण/मालिक) तक।

WORM ऑडिट: अपरिवर्तनीय स्कीमा/सूत्र/कुंजी/अपवाद लॉग।

Oracles (हस्ताक्षरित सारांश): GGR/NetRev/SLO/RG के साथ 'संस्करण', 'हैश (इनपुट)', 'बच्चा', 'traceId' - चालान और अपील के लिए सच्चाई का एक स्रोत्रोत।

परीक्षण "ट्रेस पैकेज": SLA 60-90 s P1/P2 घटनाओं के लिए।

9) गोपनीयता, स्थानीयकरण और सुरक्षा

PII-कम से कम: 'प्लेयर आईडी' का टोकन, लॉग/शोकेस में व्यक्तिगत डेटा का निषेध, केवल सुरक्षित क्षेत्रों में डिटोकेनाइजेशन।

स्थानीयकरण: न्यायालयों के नक्शे (जहां हम डेटा वर्गों को संग्रहीत/संसाधित करते हैं)।

जीरो ट्रस्ट: एमटीएलएस, अल्पकालिक टोकन, एग्रेस-अनुमति-सूची, कुंजी रोटेशन/जेडब्ल्यूकेएस।

ABAC/ReBAC/SoD: "उनकी देखें और सहमत हों" पहुंच; "माप ≠ प्रभाव ≠ परिवर्तन"।

10) वित्तीय सुलह और निपटान

[
NetRev = GGR - BonusCost - Jakpot/PoolShare -  Fex - Chargebacks - Tax/Levy - Seetworks
]

• कर्सर अपलोड, "ors" (हस्ताक्षरित समुच्चय), चेकसम;
• चालान स्टेटस, विसंगति कार्य, और पार्सिंग एसएलए;
• एफएक्स नियम, NET7/14/30, होल्ड और क्लाउ-बैक।

11) सिंक्रोनाइज़ेशन लागत प्रबंधन

कार्डिनैलिटी नीतियां: लेबल में 'userId '/कच्चे URL का निषेध; 'RouteId/अभियान Id' lowed।

डाउनसैम्पलिंग/रोल-अप: 1с→1м→5м; रॉ डेटा छोटा रहता है, कुल लंबे समय तक रहता है।

निशान का अनुकूली नमूना: त्रुटियों/धीमे पथ/नए संस्करणों के लिए आधार प्रतिशत + प्राथमिकता।

SLO-first: केवल वही इकट्ठा करें जो समाधान (SLO/Finance/RG) का समर्थन करता है।

12) सिंक्रोनाइज़ेशन डैशबोर्ड

डेटा सिंक अवलोकन: publish_lag, पूर्णता, डुप्लिकेट, देर से अनुपात, स्कीमा बहाव, अनुरूप त्रुटियां।

एट्रिब्यूशन हेल्थ: पोस्टबैक की समयबद्धता, डेडअप विंडो, विवादास्पद मामले।

वित्त/ओरेकल: समुच्चय और oracles के बीच विसंगति, चालान स्टेटस।

क्षेत्राधिकार मानचित्र: स्थान/पीडी प्रवाह, डीपीए/डीपीआईए अनुपालन।

13) संचालन, घटनाएं, आरसीए

अलर्ट: ताजगी/पूर्णता में जलने की दर, योजनाओं का बहाव, डुप्लिकेट की वृद्धि।

युद्ध-कक्ष: टायर/वेबहूक/सीडीसी/स्टोरफ्रंट के लिए तैयार प्लेबुक; एकत्रीकरण/सूत्रों के लिए बटन बंद करें

आरसीए "खोज दोषी के बिना": faktgipotezaexperimentvyvoddeystviye; पोस्टमार्टम एसएलओ।

14) एंटी-पैटर्न

मैट्रिक्स/सूत्रों और परिग्रहण तिथियों द्वारा "दो सत्य"।

लोड के तहत इतिहास का ऑफसेट पृष्ठभूमि (केवल संकेतक)।

लॉग/शोकेस में कच्चा व्यक्तिगत डेटा; कोई टोकन नहीं।

हस्ताक्षर और पहचान के बिना पोस्टबैक चिड़ियाघर → युगल/छेद।

एकत्रीकरण में घटना/प्रसंस्करण समय का मिश्रण।

कोई वॉटरमार्क और कोई देर से घटनाओं की नीति नहीं।

oracles के बजाय मैनुअल सामंजस्य (एक्सेल/मैनुअल अपलोड)।

लेबल की असीमित कार्डिनैलिटी के साथ एकल बड़ी तालिकाएं।

15) चेकलिस्ट

डिजाइन

• ऑन्कोलॉजी, स्कीमा रजिस्ट्री, मालिक, संदर्भ पुस्तकें।
• मीट्रिक स्टोर ' संस्करण' फ्रोजन-पीरियड मेजर।
• समय शब्दार्थ (घटना समय, वॉटरमार्क), देर से घटना नीति।
• परिवहन: EDA/CDC, API/हस्ताक्षरित वेबहूक, कर्सर, पहचान।
• डेटा गुणवत्ता SLI/SLO, अनुरूप परीक्षण, अलर्ट।
• गोपनीयता/स्थानीयकरण (DPIA/DPA), जीरो ट्रस्ट, ABAC/ReBAC/SoD।
• Oracles और सुलह नियम।

प्रारंभ क

• सैंडबॉक्स और लोड/कैओस-बस रन/डिस्प्ले केस।
• रेलिंग के साथ कैनरी तुल्यकालन -%।
• डैशबोर्ड -।
• सूत्रों और प्रभावी तिथियों का प्रलेखन; रिलीज-नोट्स 'डेटा _ फॉर्मूला _ चेंज'।

ऑपरेशन

• साप्ताहिक डीक्यू रिपोर्ट; SLO/रेलिंग संशोधन।
• योजनाओं/सूत्रों/पहुँच के मासिक बदलाव।
• ब्रोकर/ingestors/storefronts के लिए नियमित DR/xaoc।

16) परिपक्वता रोडमैप

v1 (फाउंडेशन): एकीकृत योजनाएं, बुनियादी सीडीसी/बैच, कर्सर, डीक्यू-एसएलआई, मैनुअल सामंजस्य।

v2 (एकीकरण): वॉटरमार्क और लेट इवेंट पॉलिसी, ऑर्कल्स, सिंक्रनाइज़ेशन डैशबोर्ड, ऑटो रिट्रेस जिटर के साथ।

v3 (स्वचालन): पूर्वानुमानित ताजगी/पूर्णता निगरानी, स्मार्ट-सामंजस्य, ऑटो-री-इंडेक्सिंग, अनुकूली नमूना।

v4 (नेटवर्क शासन): oracles/गुणवत्ता संकेतों का अंतर-श्रृंखला विनिमय, सूत्रों के DAO नियम और पारदर्शी खजाने।

17) सफलता मेट्रिक्स

डेटा गुणवत्ता: publish_lag p95, पूर्णता%, डुप्लिकेट ‰, देर से%, स्कीमा बहाव दर।

एकरूपता: एक निश्चित 'संस्करण' के साथ रिपोर्टों का अनुपात, घटनाओं के बिना सीबीएसएस की संख्या।

वित्त: oracles के साथ विसंगति, ऑटो-सामंजस्य का हिस्सा, विवाद

संचालन: MTTD/MTTR तुल्यकालन की घटनाएं, ऑटो-स्टॉप/रोलबैक का हिस्सा।

अनुपालन: 0 पीडी लीक, सफल डीपीआईए/डीपीए जांच, WORM लॉग की 100% उपलब्धता।

अवलोकन अर्थशास्त्र: लागत से सिंक प्रति आरपीएस/घटना, कार्डिनैलिटी अनुपालन।

संक्षिप्त सारांश

विश्लेषणात्मक डेटा का सिंक्रनाइज़ेशन तालिकाओं की नकल नहीं कर रहा है, लेकिन विश्वास और समय का एक प्रोटोकॉल: योजनाओं और सूत्रों का कैनन, वाटरमार्क, कर्सर और मूर्खता के साथ घटना-समय, डीक्यू-एसएलओ और देर की घटनाएं, गोपनीति और स्मीकरण। इस ढांचे का पालन करके, पारिस्थितिकी तंत्र को एकीकृत, ताजा और सिद्ध विश्लेषिकी प्राप्त होती है - तेजी से समाधान, ईमानदार गणना और स्केलेबल नेटवर्क विकास का आधार।