Kollektiv likvidlik
1) Niyə lazımdır
Yeni klasterlərdə ani likvidlik. Bölgədə/niş - ümumi hovuzu «qarışdırın».
Ən yaxşı uyğunluq və qiymətlər. Dərin bazar → daha az «spread», EPI-dən yuxarı (səmərəli qiymət/seçimi yaxşılaşdırmaq).
Tələb/təklif şokları. Düyünlər arasında yükün axması nasazlığı və növbələri azaldır.
İqtisadiyyat. Orta qiymət artımı ilə yuxarıda fill rate və ARPU; cross-sell imkanı.
2) Kollektiv likvidlik modelləri
3) Memarlıq komponentləri
Orderbook/kataloq: abstraksiya ərizə/offer, status və versiyalar, SLAs və uyğunluq atributları.
SOR (Smart Order Routing): qiymət/keyfiyyət/yurisdiksiya/gizlilik nəzərə alaraq hovuz/təchizatçı seçimi qaydaları.
Uyğunluq: CDC və hadisə jurnalları, 'event _ id' dedupu, kompensasiya əməliyyatları.
Atributlar və billing: kim «sahibi» sövdələşmə/komissiya, Windows iddiaları, reconciliation.
Keyfiyyət və nüfuz: reytinqlər/SLA tərəfdaş, cərimələr, nişanlar.
Gizlilik və lokalizasiya: PD maskalanması, geo-pinning, hadisə ixrac qaydaları.
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) Məlumat müqavilələri (minimum sahələr)
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: qaydalar və psevdokod
Reytinq meyarları:- `score = w_priceprice_improvement + w_slattm_slo + w_qquality + w_geodistance_penalty + w_riskvendor_risk_penalty`
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)Fairness (Ədalət): təchizatçı rotasiyası, dövriyyə payı kvotaları, nüfuzuna görə tie-break və son qazanc.
6) Likvidlik metrikası
Fill rate = qapalı müraciətlər/bütün müraciətlər (seqment/klaster üzrə).
Time-to-match (p50/p95) - seçmə/icraya qədər olan vaxt.
Depth - müəyyən qiymət/keyfiyyət diapazonunda mövcud həcm.
Spread/EPI - effektiv qiymət vs benchmark yaxşılaşdırılması.
Utilization - təklifin yüklənməsi (idle% ↓ - SLA uğursuzluqları olmadan yaxşı).
Integrity - geri çəkilmə/fols-konvertasiyaların payı, reconciliation-da uyğunsuzluq (<ε).
Fairness - bərabər keyfiyyətdə tədarükçülər üzrə dövriyyənin paylanması.
- 'fill _ rate _ month ≥ 92%' ≥ N aktiv offerləri olan bir klasterdə.
- 'p95 _ time _ to _ match ≤ 3s' pik saatlarda.
- `cancel_rate ≤ 1. 5% 'SLA təchizatçı' on-time ≥ 98% '.
7) Müşahidə və sübut bazası
Hadisələr: 'request. sent`, `quote. received`, `match. made`, `settled`, `cancelled`, `refund`.
Tracking: 'trace _ id' SOR → hovuz → təchizatçı vasitəsilə keçir.
Audit: vebhuk imzaları, orderbuk versiyası jurnalı, kotirovkaların «ekran görüntüsü».
Reconciliation: ikitərəfli hesabatlar, dedup, uyğunsuzluqlar <ε, SLA iddiaların bağlanması.
8) Gizlilik, uyğunluq, suverenlik
Geo-pinning: həssas kateqoriyalar/PII icazə bölgədən çıxmır.
Pseudonimization: partnyorlararası mübadilə üçün - yalnız psevdo identifikatorları.
Retention kimi kod: TTL hadisələr, silinmə hüququ, Legal Hold.
DPA/webhucks: imza, anti-replay, sxemlərə nəzarət.
9) Əməliyyat modeli və hesablamalar
Rollar: Market Operator (siz), Pullar/Partnyorlar (supply), Kanallar/Vitrinlər (demand).
Ticarət: RevShare/CPA/minimum zəmanət; «klip» marşrutlaşdırma/qiymət yaxşılaşdırılması üçün.
Kreditlər/cərimələr: SLA-nın pozulmasına, saxta offerlərə, hesabatların uyğunsuzluğuna görə.
Settlement: T + N tezliyi, saxlama, chargebacks, hesabat.
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) İnteqrasiya nümunələri
Time Box (idempotency-key) ilə Pull-quote API.
Webhooks tərəfindən 'match üçün imzalanmışdır. made '/' settled '(eksponent ilə retralar).
CDC orderbook və analitika (hadisə versiyası) üçün Event bus.
Batch-recon (gündəlik SFTP/Blob + nəzarət məbləğləri).
Outbox/Inbox hər iki tərəfdə + dedup.
Sxemlərin versiyalaşdırılması/SDK, uyğunluq pəncərəsi.
11) Həddindən artıq yükləmə və yelləncəyin idarə edilməsi
Anti-konqestiya: limitlər, növbələr, VIP/mürəkkəb halların prioritetləşdirilməsi, surge əmsalları.
Anti-arbitraj (zəhərli): aşağı qiymət/keyfiyyət «özünü icra» qadağaları, «ping-pong» sorğuların monitorinqi.
Anti-frod: device/davranış işarələri, honey-tokens, gecikmiş kvalifikasiya (cool-off).
Şərəflə deqradasiya: yerli hovuza fallback, şəffaf pisləşmə ilə «best-effort».
12) Məntiq nümunələri (eskizlər)
12. 1 Yurisdiksiya və SLO ilə marşrutlaşdırma
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 Ədalət siyasəti (Rego ideya)
rego package fairness deny["overexposed vendor"] {
usage. share[input. vendor] > 0. 45 input. vendor. tier == "silver"
}12. 3 Orderbukun konvergensiya testi
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 signal13) Yetkinlik metrikası
Coverage: ≥ X aktiv offerlərin olduğu seqmentlərin/bölgələrin payı.
Elasticity: tez fill rate tələb + Δ ilə bərpa olunur.
EPI/Spread-improvement: solo-hovuz vs aqreqasiya fayda.
Fair-distribution: dövriyyə payının gözlənilən keyfiyyətdən kənara çıxması.
Recon-health: uyğunsuzluqların tezliyi/bağlanış müddəti.
Privacy-score: siyasətdən kənarda PD çıxarmadan marşrutların payı.
14) Anti-nümunələr
SOR və keyfiyyət qaydaları olmadan çılpaq federasiya → parçalanma, ləğv.
«Şüşə bazarı»: hər kəsə hər şeyi açırsınız - frod və qiymət müharibəsinin artması.
Heç bir atributlar və reconciliation → əbədi mübahisələr və dondurulmuş ödənişlər.
Hovuzlar arasında sərt sinxron → kaskad gecikmə/uğursuzluqlar.
Müxtəlif seqmentlər üçün eyni qaydalar → premium/yerli nişlərdə təcrübənin deqradasiyası.
TTL offerləri → «köhnəlmiş» şərtlər üzrə sövdələşmələrə məhəl qoymayın.
Bütün bazarda vahid şifrələmə açarı → məlumatları nöqtəli şəkildə «silmək» mümkün deyil.
15) Memarın yoxlama siyahısı
1. Müəyyən model (ümumi hovuz/federasiya/hub) və suverenlik məhdudiyyətləri?
2. Məlumat müqaviləsi (sxemlər, versiyalar, TTL, imzalar) və uyğunluq pəncərəsi varmı?
3. SOR fairness və backomps, SLO likvidliyi və daşbordları ilə həyata keçirilmişdir?
4. Billing/atributlar, iddia pəncərələri, kreditlər/cərimələr?
5. Anti-konqestiya/anti-frod/anti-arbitraj və deqradasiya rejimi daxili?
6. reconciliation və artefaktlar «sübut sövdələşmə»?
7. Gizlilik: psevdonimization, geo-pinning, retenshen, silinmə hüququ?
8. Təlimlər: tələbin stress zirvələri/hovuzun düşməsi/orderbukun rasinxronizasiyası?
9. FinOps: büdcə egress, marşrutlaşdırma dəyəri, hədəf EPI?
10. Governance: eşik payları, tərəfdaşların sertifikatlaşdırılması, audit.
Nəticə
Kollektiv likvidlik «başqa tərəfdaş qoşmaq» deyil, bazarı layihələndirməkdir: vahid müqavilələr və hadisələr, şəffaf marşrutlaşdırma və ədalət qaydaları, güclü müşahidə və hesablamalar, gizlilik və yurisdiksiya «kod kimi». Beləliklə, dağınıq mənbələrdən vahid, dərin və davamlı tələb və təklif hovuzu yaranır - istifadəçilər üçün ən yaxşı təcrübə və bütün ekosistem üçün proqnozlaşdırıla bilən iqtisadiyyat.