सामूहिक तरलता

1) आपको इसकी आवश्यकता क्यों है

नए समूहों में त्वरित तरलता। क्षेत्र/आला में लॉन्च - "मिक्स" सामान्य पूल।

बेहतर मैच और कीमतें। गहरे बाजार - कम प्रसार, ईपीआई (प्रभावी मूल्य/चयन में सुधार) के ऊपर।

आपूर्ति/मांग झटके। नोड्स के बीच ओवरफ्लो लोड विफलता और कतारों को कम करता है।

अर्थशास्त्र। मध्यम लागत वृद्धि के साथ भरण दर और एआरपीयू से ऊपर; क्रॉस-सेल क्षमता।

2) सामूहिक तरलता मॉडल

3) वास्तुशिल्प घटक

ऑर्डरबुक/कैटलॉग: एप्लिकेशन/पेशकश अमूर्त, स्थिति और संस्करण, एसएलए और संगतता विशेषताएं।

SOR (स्मार्ट ऑर्डर रूटिंग): मूल्य/गुणवत्ता/अधिकार क्षेत्र/विलंबता को ध्यान में रखते हुए एक पूल/आपूर्तिकर्ता का चयन करने के नियम।

स्थिरता: सीडीसी और इवेंट लॉग, इवेंट _ आईडी डेडअप, क्षतिपूर्ति लेनदेन।

एट्रिब्यूशन और बिलिंग: कौन लेनदेन/कमीशन का "मालिक" है, खिड़कियों का दावा करता है, सुलह करता है।

गुणवत्ता और प्रतिष्ठा: साझेदार रेटिंग/एसएलए, दंड, बैज।

गोपनीयता और स्थानीयकरण: पीडी मास्किंग, जियो-पिनिंग, इवेंट निर्यात नियम।

mermaid flowchart LR
U [Demand] --> GW [Routing Gateway]
P1 [Pool A] --- GW
P2 [Pool B] --- GW
P3 [Partner C] --- GW
GW --> SB[Settlement/Billing]
GW --> OBS[Observability/SLO]

4) डेटा अनुबंध (न्यूनतम क्षेत्र)

yaml offer. v1:
id: uuid kind: product    slot    capacity price: {amount: decimal, currency: ISO4217}
quality: {rating: 0..5, sla_ttm_ms: int}
geo: {region: "EU", city: "Tallinn"}
vendor: {id: "partner-123", tier: "gold"}
terms: {ttl_s: 60, cancellation: "window:15m"}
version: 7 request. v1:
id: uuid constraints: {geo, time, price_ceiling, compliance}
qos: {max_ttm_ms: 500, min_rating: 4. 0}
trace_id: uuid consent: {...}

5) SOR: नियम और स्यूडोकोड

• 'score = + + + + + +

python def route(request, pools):
candidates = []
for pool in pools:
if not compliant(request, pool):
continue quotes = pool. quote (request) # timebox, idempotent for q in quotes:
s = score(q, request)
candidates. append((s, pool, q))
ordered = sorted(candidates, key=lambda x: -x[0])
return best_feasible(ordered, fairness=request. fairness)

निष्पक्षता: आपूर्तिकर्ता रोटेशन, टर्नओवर शेयर कोटा, प्रतिष्ठा पर टाई-ब्रेक और हाल की जीत।

6) तरलता मैट्रिक्स

भरें दर = बंद अनुप्रयोग/सभी अनुप्रयोग (खंड/क्लस्टर द्वारा)।

समय से मिलान (p50/p95) - चयन/निष्पादन का समय।

निर्दिष्ट मूल्य/गुणवत्ता सीमा में गहराई उपलब्ध मात्रा।

स्प्रेड/ईपीआई - प्रभावी मूल्य बनाम बेंचमार्क में सुधार।

उपयोग - वाक्य लोड करना (निष्क्रिय% ↓ - अच्छा अगर SLA विफलताओं के बिना)।

अखंडता - रद्दीकरण/सिलवटों का अनुपात, सामंजस्य में विसंगति (<)।

निष्पक्षता - समान गुणवत्ता वाले आपूर्तिकर्ताओं को बिक्री का वितरण।

• ≥ N सक्रिय ऑफ़ र के साथ एक क्लस्टर में 'फिल _ रेट _ महीना ≥ 92%'।
• पीक ऑवर्स के दौरान 'p95 _ time _ to _ match ≤ 3s'।
• 'कैंसल _ रेट ≤ 1। 5% 'विक्रेता SLA' ऑन-टाइम ≥ 98% 'के साथ।

7) अवलोकन और साक्ष्य आधार

घटनाएँ: 'अनुरोध। भेजा ',' उद्धरण। प्राप्त ',' मैच। बनाया ',' बसा ',' रद्द ',' वापसी '।

ट्रेस: SOR → पूल → प्रदाता के माध्यम से 'ट्रेस _ id'।

ऑडिट: वेबहुक के हस्ताक्षर, ऑर्डरबुक संस्करणों का लॉग, उद्धरण का "स्क्रीनशॉट"।

सुलह: द्विपक्षीय रिपोर्ट, डीडअप, विसंगतियां <, दावा SLA को बंद करना।

8) गोपनीयता, अनुपालन, संप्रभुता

भू-पिनिंग: संवेदनशील श्रेणियां/पीआईआई अनुमत क्षेत्र को नहीं छोड़ ती हैं।

छद्म नाम: अंतर-भागीदार विनिमय के लिए - केवल छद्म-पहचानकर्ता।

कोड के रूप में प्रतिधारण: टीटीएल घटनाएँ, हटाने का अधिकार, कानूनी पकड़।

DPA/वेबहूक: हस्ताक्षर, एंटी-रिप्ले, स्कीमा नियंत्रण।

9) ऑपरेटिंग मॉडल और गणना

भूमिकाएँ: मार्केट ऑपरेटर (आप), पूल/पार्टनर्स (आपूर्ति), चैनल/शोकेस (मांग)।

वाणिज्य: RevShare/CPA/न्यूनतम वारंटी; रूटिंग/मूल्य सुधार के लिए "क्लिप"।

क्रेडिट/दंड: SLA व्यवधान, झूठी पेशकश, रिपोर्ट की असंगति के लिए।

सेटलमेंट: टी + एन फ्रीक्वेंसी, होल्ड, चार्जबैक, रिपोर्टिंग।

yaml partner_id: "pool-A"
sla:
fill_rate: ">= 90%"
on_time: ">= 98%"
quote_ttl_s: 2 limits:
rps: 200 region: ["EU","TR"]
commercials:
model: "revshare: 20% of net"
security:
webhook_signature: "Ed25519"

10) एकीकरण पैटर्न

टाइम-बॉक्स (पहचान-कुंजी) के साथ पुल-उद्धरण एपीआई।

'मैच' के लिए वेबहुक पर हस्ताक्षर किए। बनाया '/' सेटलमेंट '(घातांक के साथ रेट्राई)।

सीडीसी ऑर्डरबुक और एनालिटिक्स (घटना संस्करण) के लिए घटना बस।

बैच-रिकॉन (दैनिक SFTP/ब्लॉब + चेकसम)।

आउटबॉक्स/इनबॉक्स दोनों तरफ + डीडअप।

स्कीमा/एसडीके वर्शनिंग, संगतता विंडो।

11) ओवरलोड और स्विंग नियंत्रण

एंटी-कंजेस्टी: लिमिटर, कतारें, वीआईपी/जटिल मामले प्राथमिकता, वृद्धि कारक।

एंटी-आर्बिट्रेज (विषाक्त): कम कीमत/गुणवत्ता पर "स्व-निष्पादन" का निषेध, "पिंग-पोंग" अनुरोधों की निगरानी।

एंटी-फ्रॉड: डिवाइस/व्यवहार संबंधी हस्ताक्षर, शहद-टोकन, विलंबित योग्यता (कूल-ऑफ)।

सम्मान के साथ गिरावट: स्थानीय पूल में गिरावट, पारदर्शी गिरावट के साथ "सबसे अच्छा प्रयास"।

12) तर्क के उदाहरण (रेखाचित्र)

12. 1 क्षेत्राधिकार और एसएलओ राउटिंग

python def compliant(req, pool):
return (req. constraints. geo in pool. regions and pool. sla. quote_ttl_s <= 2 and pool. vendor_tier in {"gold","silver"})

12. 2 न्याय नीति (रेगो-विचार)

rego package fairness deny["overexposed vendor"] {
usage. share[input. vendor] > 0. 45 input. vendor. tier == "silver"
}

12. 3 ऑर्डरबुक कन्वर्जेंस टेस्ट

sql
SELECT offer_id, MAX(version)-MIN(version) AS drift
FROM orderbook_events
WHERE ts >= now() - interval '5 minutes'
GROUP BY 1
HAVING MAX(version)-MIN(version) > 1; -- fragmentation signal

13) परिपक्वता मैट्रिक्स

कवरेज: खंडों/क्षेत्रों का हिस्सा जहां ≥ X सक्रिय प्रस्ताव हैं।

लोच: + की मांग पर दर कितनी जल्दी ठीक हो जाती है।

EPI/स्प्रेड-सुधार: एकत्रीकरण बनाम एकल पूल से लाभ।

निष्पक्ष वितरण: गुणवत्ता के मामले में अपेक्षित से टर्नओवर शेयर का विचलन।

रीकॉन-हेल्थ: विसंगतियों को बंद करने की आवृत्ति/समय।

गोपनीयता-स्कोर: नीति सीमाओं से परे पीडी हटाने के बिना मार्गों का हिस्सा।

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

एसओआर और गुणवत्ता नियमों के बिना नग्न महासंघ - विखंडन, रद्द।

"ग्लास मार्केट": सभी के लिए सब कुछ खोलें - धोखाधड़ी और मूल्य युद्ध का एक छींटा।

कोई विशेषता और सामंजस्य नहीं - शाश्वत विवाद और जमे हुए भुगतान।

पूल → कैस्केडेड विलंबता/विफलताओं के बीच कठोर समकालिकता।

विभिन्न खंडों के लिए समान नियम - प्रीमियम/स्थानीय निचे में अनुभव का क्षरण।

TTL की अनदेखी "सड़ेहुए" स्थितियों के तहत → सौदे प्रदान करता है।

पूरे → बाजार के लिए एक एकल एन्क्रिप्शन कुंजी बिंदु द्वारा "मिटाया" बिंदु नहीं जा सकता है।

15) आर्किटेक्ट चेकलिस्ट

1. मॉडल (साझा पूल/महासंघ/हब) और संप्रभुता की बाधाओं को परिभाषित किया गया है?
2. क्या कोई डेटा अनुबंध (स्कीमा, संस्करण, टीटीएल, हस्ताक्षर) और एक संगतता विंडो है?
3. निष्पक्षता और कंप्स, तरलता एसएलओ और डैशबोर्ड के साथ एसओआर लागू किया गया?
4. बिलिंग/एट्रिब्यूशन, क्लेम विंडो, क्रेडिट/जुर्माना पंजीकृत हैं?
5. एंटी-कंजेस्टी/एंटी-फ्रॉड/एंटी-आर्बिट्रेज और क्षरण मोड में निर्मित?
6. "सौदे के सबूत" के सामंजस्य और कलाकृतियों की स्थापना?
7. गोपनीयता: छद्म नाम, भू-पिनिंग, प्रतिधारण, हटाने का अधिकार?
8. ड्रिल: तनाव चोटियों/पूल ड्रॉप/ऑर्डरबुक सिंक से बाहर की मांग?
9. FinOps: बजट, रूटिंग लागत, लक्ष्य EPI?

10. शासन: दहलीज शेयर, साझेदार प्रमाणन, ऑडिट।

निष्कर्ष

सामूहिक तरलता "दूसरे भागीदार को जोड़ ने" के लिए नहीं है, बल्कि बाजार को डिजाइन करने के लिए है: समान अनुबंध और घटनाएं, रूटिंग और निष्पक्षता के पारदर्शी नियम, मजबूत अवलोकन और गणना, गोपनीयता और क्षेत्राधिकार "जैसे। "इस प्रकार, असमान स्रोतों से, आपूर्ति और मांग का एक एकल, गहरा और स्थायी पूल पैदा होता है - उपयोगकर्ताओं के लिए सबसे अच्छा अनुभव और पूरे पारिस्थितिकी तंत्र के लिए एक पूर्वानुमानित अर्थव्