Kolektif likidite
1) Neden ihtiyacınız var
Yeni kümelerde anında likidite. Bölgede/nişte başlatın - genel havuzu "karıştırın".
Daha iyi maç ve fiyatlar. Derin piyasa - EPI'nin üzerinde daha az yayılma (etkili fiyat/seçimde iyileşme).
Arz/talep şokları. Düğümler arasındaki yük taşması arızayı ve kuyrukları azaltır.
Ekonomi. Orta maliyet artışları ile doldurma oranı ve ARPU üzerinde; çapraz satış yeteneği.
2) Kolektif likidite modelleri
3) Mimari bileşenler
Sipariş defteri/katalog: uygulama/teklif soyutlamaları, durum ve sürümler, SLA'lar ve uyumluluk özellikleri.
SOR (Akıllı Sipariş Yönlendirme): Fiyat/kalite/yargı/gecikme dikkate alınarak bir havuz/tedarikçi seçmek için kurallar.
Tutarlılık: CDC ve olay günlükleri, event _ id dedup, telafi işlemleri.
Atıf ve faturalandırma: işlemin/komisyonun "sahibi'kim, talep pencereleri, uzlaşma.
Kalite ve itibar: ortak derecelendirmeleri/SLA'lar, cezalar, rozetler.
Gizlilik ve yerelleştirme: PD maskeleme, coğrafi sabitleme, olay dışa aktarma kuralları.
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) Veri sözleşmeleri (minimum alanlar)
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: kurallar ve sözde kod
Sıralama kriterleri:- '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)Adalet: tedarikçi rotasyonu, ciro payı kotaları, itibar ve son kazançlarda tie-break.
6) Likidite metrikleri
Dolgu oranı = kapalı uygulamalar/tüm uygulamalar (segment/kümeye göre).
Maç zamanı (p50/p95) - seçim/yürütme zamanı.
Derinlik - belirtilen fiyat/kalite aralığında mevcut hacim.
Spread/EPI - etkili fiyat vs benchmark iyileştirilmesi.
Kullanım - bir cümle yükleme (boşta % ↓ - SLA hataları olmadan iyi).
Bütünlük - iptal/katlama dönüşümlerinin oranı, mutabakattaki tutarsızlık (<ε).
Adalet - Satışların eşit kalitede tedarikçilere dağıtılmasının varyansı.
- 'fill _ rate _ month ≥ %92', ≥ N etkin teklifli bir kümede.
- Yoğun saatlerde 'p95 _ time _ to _ match ≤ 3s'.
- 'cancel _ rate ≤ 1. 5 % 'satıcı SLA ile' zamanında ≥ 98 % '.
7) Gözlemlenebilirlik ve kanıt tabanı
Olaylar: 'Talep. gönderilmiş ', alıntı. Alınan ',' maç. made ',' yerleşmiş ',' iptal edilmiş ',' geri ödeme '.
İzler: SOR üzerinden 'trace _ id' - havuz - sağlayıcı.
Denetim: Web kitaplarının imzaları, sipariş defteri sürümlerinin günlüğü, alıntıların "ekran görüntüsü".
Uzlaşma: ikili raporlar, tekdüzelik, tutarsızlıklar <ε, kapanış SLA iddiaları.
8) Gizlilik, uyum, egemenlik
Coğrafi sabitleme: hassas kategoriler/PII izin verilen bölgeyi terk etmez.
Takma ad: ortaklar arası değişim için - sadece sözde tanımlayıcılar.
Kod olarak saklama: TTL olayları, silme hakkı, Yasal Bekletme.
DPA/webhooks: imza, anti-replay, şema kontrolü.
9) Çalışma modeli ve hesaplamalar
Roller: Piyasa Operatörü (siz), Havuzlar/Ortaklar (arz), Kanallar/Vitrinler (talep).
Ticaret: RevShare/EBM/minimum garantiler; Yönlendirme/fiyat iyileştirme için "klip".
Krediler/cezalar: SLA bozulması, yanlış teklifler, raporların tutarsızlığı için.
Yerleşim: T + N frekansı, tutar, ters ibrazlar, raporlama.
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) Entegrasyon kalıpları
Zaman kutusu (idempotency-key) ile Pull-quote API.
Maç için Webhooks'u imzaladı. made'/' settled '(üslü retrai).
CDC sipariş defteri ve analitik için etkinlik otobüsü (etkinlik sürümleri).
Toplu keşif (günlük SFTP/Blob + checksums).
Her iki taraftaki Giden Kutusu/Gelen Kutusu + dedup.
Şema/SDK sürüm oluşturma, uyumluluk penceresi.
11) Aşırı yük ve salınım kontrolü
Anti-congestie: sınırlayıcılar, kuyruklar, VIP/karmaşık vaka önceliklendirmesi, dalgalanma faktörleri.
Anti-arbitraj (toksik): Düşük fiyat/kalitede "kendi kendini yürütme" yasakları, "pinpon" taleplerinin izlenmesi.
Anti-dolandırıcılık: cihaz/davranışsal imzalar, bal belirteçleri, gecikmeli yeterlilik (soğuma).
Onur ile bozulma: yerel havuza geri dönüş, şeffaf bozulma ile'en iyi çaba ".
12) Mantık örnekleri (eskizler)
12. 1 Yargı Alanı ve SLO Yönlendirme
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 Adalet Politikası (Rego-idea)
rego package fairness deny["overexposed vendor"] {
usage. share[input. vendor] > 0. 45 input. vendor. tier == "silver"
}12. 3 Sipariş defteri yakınsama 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) Olgunluk metrikleri
Kapsam: ≥ X etkin tekliflerinin bulunduğu segmentlerin/bölgelerin payı.
Esneklik: + Δ talepte dolum oranının ne kadar hızlı geri kazanıldığı.
EPI/Spread-improvement: toplama ve solo havuzdan yararlanın.
Adil dağıtım: Kalite açısından ciro payının beklenenden sapması.
Keşif-sağlık: tutarsızlıkların kapatılması sıklığı/zamanlaması.
Gizlilik puanı: PD'nin politika sınırlarının ötesinde kaldırılmadığı rotaların payı.
14) Anti-desenler
SOR ve kalite kuralları olmadan çıplak federasyon - parçalanma, iptal.
"Cam pazarı": Herkese her şeyi açın - bir dolandırıcılık ve fiyat savaşı sıçraması.
Atıf ve uzlaşma yok - ebedi anlaşmazlıklar ve dondurulmuş ödemeler.
Havuzlar arasında sabit senkronizasyon - basamaklı gecikme/arızalar.
Farklı segmentler için aynı kurallar - premium/yerel nişlerde deneyimin bozulması.
TTL tekliflerini görmezden gelmek - "çürük" koşullar altında fırsatlar.
Tüm pazar için tek bir şifreleme anahtarı nokta nokta "silinemez".
15) Mimar kontrol listesi
1. Model (paylaşılan havuz/federasyon/merkez) ve egemenlik kısıtlamaları tanımlanmış mı?
2. Bir veri sözleşmesi (şemalar, sürümler, TTL, imzalar) ve bir uyumluluk penceresi var mı?
3. SOR'u adalet ve kompozisyonlar, likidite SLO ve gösterge tabloları ile uyguladınız mı?
4. Fatura/atıf, talep pencereleri, krediler/para cezaları kayıtlı mı?
5. Anti-congestie/anti-fraud/anti-arbitraj ve bozulma modunda yerleşik?
6. Uzlaşma ve "anlaşma kanıtı" eserleri kuruldu mu?
7. Gizlilik: takma ad, coğrafi sabitleme, saklama, silme hakkı?
8. Matkap: Talep Stres Zirveleri/Havuz Bırakma/Sipariş Kitabı Senkronizasyon Dışı mı?
9. FinOps: çıkış bütçesi, yönlendirme maliyeti, hedef EPI?
10. Yönetim: eşik payları, ortak sertifikasyonu, denetim.
Sonuç
Kolektif likidite "başka bir ortağa bağlanmak'değil, piyasayı tasarlamaktır: tekdüze sözleşmeler ve olaylar, şeffaf yönlendirme ve adalet kuralları, güçlü gözlemlenebilirlik ve hesaplamalar, gizlilik ve yargı bölgeleri" kod gibi. Böylece, farklı kaynaklardan, kullanıcılar için en iyi deneyime ve tüm ekosistem için öngörülebilir bir ekonomiye sahip tek, derin ve sürdürülebilir bir arz ve talep havuzu doğar.