Жамааттык ликвиддүүлүк
1) Эмне үчүн керек
Жаңы кластерлерде тез ликвиддүүлүк. Региондо/нишада - жалпы бассейнди "аралаштырыңыз".
Мыкты шайкештик жана баалар. Deep Market → аз "spread", жогору EPI (натыйжалуу баа/тандоо жакшыртуу).
Суроо-талаптын/сунуштун таасирлери. Түйүндөрдүн ортосундагы жүктүн агып чыгышы мүчүлүштүктөрдү жана кезектерди азайтат.
Экономика. Жогору fill rate жана ARPU орточо өсүшү менен; cross-sell мүмкүнчүлүгү.
2) Жамааттык ликвиддүүлүктүн моделдери
3) архитектуралык компоненттери
Ордербук/каталог: абстракция арыз/offer, статус жана версиялар, SLAs жана шайкештик атрибуттары.
SOR (Smart Order Routing): баа/сапат/юрисдикция/жашыруун эске алуу менен бассейн/берүүчүнү тандоо эрежелери.
Ырааттуулук: CDC жана окуялар журналдары, дедуп 'event _ id', компенсациялык транзакциялар.
Атрибуция жана биллинг: ким "ээси" бүтүм/комиссия, терезе дооматтар, reconciliation.
Сапаты жана кадыр-баркы: рейтинги/SLA өнөктөш, айып, төш белгилер.
Купуялык жана локалдаштыруу: PD жашыруу, гео-пиннинг, иш-чараларды экспорттоо эрежелери.
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 = 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 (адилеттүүлүк): берүүчүлөрдүн айлануусу, жүгүртүү үлүшүнө квоталар, репутация жана акыркы утуштар боюнча tie-break.
6) Ликвиддүүлүк метрикасы
Fill rate = жабык арыздар/бардык арыздар (сегмент/кластер боюнча).
Time-to-match (p50/p95) - тандоого/аткарууга чейинки убакыт.
Depth - белгиленген баа/сапат диапазонунда жеткиликтүү көлөмү.
Spread/EPI - натыйжалуу бааны жакшыртуу vs эталон.
Utilization - сунуштарды жүктөп алуу (idle% ↓ - эгер SLA ийгиликсиз болсо жакшы).
Integrity - reconciliation (<ε).
Fairness - бирдей сапатта берүүчүлөр боюнча жүгүртүүнү бөлүштүрүү дисперсиясы.
- 'fill _ rate _ month ≥ 92%' ≥ N активдүү оффералары бар кластерде.
- 'p95 _ time _ to _ match ≤ 3s' эң жогорку сааттарда.
- `cancel_rate ≤ 1. 5% 'менен SLA жөнөтүүчү' on-time ≥ 98% '.
7) Байкоо жана далил базасы
Окуялар: 'request. sent`, `quote. received`, `match. made`, `settled`, `cancelled`, `refund`.
Tracking: 'trace _ id' аркылуу SOR → бассейн → жеткирүүчү.
Аудит: вебхуктардын кол тамгалары, ордербук версияларынын журналы, цитаталардын "скриншоту".
Reconciliation: эки тараптуу отчеттор, дедуп, айырмачылыктар <ε, SLA жабуу дооматтар.
8) Купуялык, комплаенс, суверенитет
Geo-pinning: сезгич категориялары/PII уруксат аймактан чыгып эмес.
Псевдоним: өнөктөштөр аралык алмашуу үчүн - псевдо-идентификаторлор гана.
Retention коду катары: TTL окуялар, алып салуу укугу, Юридикалык Hold.
DPA/Webhucks: кол коюу, анти-replay, схемаларды көзөмөлдөө.
9) Операциялык модель жана эсептөөлөр
Ролдору: Market Operator (сиз), Pool/Partners (supply), Channels/Display (demand).
Соода: RevShare/CPA/минималдуу кепилдиктер; "клип" багыттоо/бааны жакшыртуу үчүн.
Кредиттер/айыптар: SLA үзгүлтүккө учураткандыгы, жалган оффералар, отчеттордун шайкеш эместиги үчүн.
Settlement: мезгилдүүлүк T + N, кармоо, chargebacks, отчеттуулук.
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) Интеграция үлгүлөрү
убакыт-бокс (idempotency-key) менен Pull-quote API.
Кол коюлган Webhooks үчүн 'match. made '/' settled '(экспонент менен ретрайлер).
CDC ордербука жана аналитика (окуялардын нускасы) үчүн Event bus.
Batch-recon (күнүмдүк SFTP/Blob + контролдук суммасы).
Outbox/Inbox эки тарапта + дедуп.
Схемаларды версиялоо/SDK, шайкештик терезеси.
11) Ашыкча жүктөө жана селкинчек башкаруу
Анти-конгестия: лимиттери, кезек, VIP/татаал учурларда артыкчылыктуу, surge-коэффициенттери.
Анти-арбитраж (уулуу): арзандатылган баа/сапат боюнча "өзүн-өзү аткаруу" тыюу, мониторинг "ping-pong" суроо.
Анти-Frod: device/жүрүм-турум белгилери, honey-tokens, кийинкиге калтырылган квалификация (cool-off).
Абийир менен деградация: жергиликтүү көлмөгө fallback, ачык-айкын начарлоо менен "best-effort".
12) Логика мисалдары (эскиздер)
12. 1 Юрисдикция жана SLO эске алуу менен роутинг
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-идея)
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 signal13) Жетилүү метрикасы
Coverage: ≥ X активдүү offers бар сегменттердин/региондордун үлүшү.
Elasticity: тез fill rate + Δ суроо-талап менен калыбына келет.
EPI/Spread-improvement: топтоо пайда vs соло-бассейн.
Fair-distribution: сапаты боюнча күтүлгөн жүгүртүү үлүшү четтөө.
Recon-health: айырмачылыктарды жабуу жыштыгы/мөөнөтү.
Privacy-score: PD саясаттын чегинен тышкары алып туруп маршруттар үлүшү.
14) Анти-үлгүлөрү
SOR жана сапат эрежелери жок жылаңач Киргизия → үзүндү, жокко чыгаруу.
"Айнек базар": баарын ачасыз - фрод жана баа согушу.
Эч кандай атрибуция жана reconciliation → түбөлүк талаш-тартыштар жана тоңдурулган төлөмдөр.
Пулдардын ортосундагы катуу синхрондоштуруу → каскаддык латенттүүлүк/мүчүлүштүктөр.
Ар кандай сегменттер үчүн бирдей эрежелер → премиум/жергиликтүү уячаларда тажрыйбанын бузулушу.
TTL көз жаздымда → "өчүп" шарттары боюнча бүтүм.
Бүткүл рынок үчүн бирдиктүү шифрлөө ачкычы → маалыматтарды так "өчүрүү" мүмкүн эмес.
15) Архитектордун чек тизмеси
1. Аныкталган модель (жалпы бассейн/Киргизия/хаб) жана эгемендүүлүк чектөөлөр?
2. Маалымат келишими (схемалар, версиялар, TTL, кол тамгалар) жана шайкештик терезеси барбы?
3. SOR fairness жана бэкомптор, SLO ликвиддүүлүк жана дашборддор менен ишке ашырылган?
4. Биллинг/атрибуция, доомат терезелери, кредиттер/айыптар жазылган?
5. Анти-конгестия/анти-frod/анти-арбитраждык жана деградация режими курулган?
6. reconciliation жана artefacts "бүтүм далили" түзүлгөн?
7. Купуялык: псевдонимизация, geo-pinning, retenshen, алып салуу укугу?
8. Машыгуулар: суроо-талаптын стресс-туу чокулары/көлмөнүн кулашы/ордербукту кайра синхрондоштуруу?
9. FinOps: egress бюджет, багыттоо наркы, максаттуу EPI?
10. Governance: босого үлүштөрү, өнөктөштөрдү тастыктоо, аудит.
Корутунду
Жамааттык ликвиддүүлүк - бул "дагы бир өнөктөштү туташтыруу" эмес, рынокту долбоорлоо: бирдиктүү контракттар жана окуялар, багыттоонун жана адилеттүүлүктүн ачык-айкын эрежелери, күчтүү байкоо жана эсептешүүлөр, купуялуулук жана юрисдикция "код катары". Ошентип, чачыранды булактардан суроо-талап менен сунуштун бирдиктүү, терең жана туруктуу бассейни - колдонуучулар үчүн мыкты тажрыйбасы жана бүткүл экосистема үчүн болжолдуу экономикасы бар.