Маълумот дар бораи ҳодиса ва вақти воқеӣ
(Қисм: Технология ва инфрасохтор)
Хулосаи мухтасар
Event-Streaming коркард ва таҳвили чорабиниҳо ҳангоми пайдо шудани онҳо мебошад. Барои IGaming, ин маънои вокуниши фаврӣ ба гаравҳо, амонатҳо, сигналҳои зидди қаллобӣ, маҳдудиятҳои масъулияти бозӣ, мизҳои мусобиқа ва пешниҳодҳои шахсиро дорад. Хиштҳои асосӣ: Автобуси рӯйдодҳо (Кафка/Пулсар), муҳаррики ҷараён (Flink/ksqL/Spark Structured Streaming), CDC аз пойгоҳи додаҳои транзаксионӣ (Debezium), Дӯкони хусусият барои онлайн ML ва таҳлили вақти воқеӣ (назари моддӣ, OLAP)
Дар IGaming дар куҷо муҳим аст
Анти-қаллобӣ ва хатар: баҳодиҳии амалиётҳо дар <100-300 мс, таносуби шакли рафтор, бастан ва шиддат.
Бозии масъулиятнок: маҳдудияти назорат, меъёри талафот, рафтори ғайримуқаррарӣ - ҳушдорҳо ва маҳдудиятҳои автомобилӣ дар вақти воқеӣ.
Пардохтҳо: клапанҳои вазъият, веб-китобҳои PSP, интеллектуалӣ, пешгӯиҳои тавозун, SLA "вақт ба ҳамён".
Чорабиниҳои бозӣ: ҳисобкунии пешвоёни мусобиқа (тирезаҳои лағжанда), даври бозиҳои зинда, каналҳои вақти воқеӣ барои CRM/маркетинг.
Фардикунонӣ: хусусиятҳои онлайн (RFM, майл) → маъракаҳои триггер, тела/почтаи электронӣ дар тӯли сонияҳо.
Таҳлили амалиётӣ: таъхири p95/p99, табдили қадами ҳалқа, сигналҳои саломатии платформа.
Моделҳои меъморӣ
Ламбда vs Каппа
Ламбда: партия (DWH/ETL) + ҷараён (фаврӣ). Плюс - чандирӣ ва "арзон"; минус мантиқи дугона аст.
Каппа: ҳама чиз ба монанди ҷараён аз маҷалла аст (Кафка). Плюс - рамзи ягона, такрори ҳодисаҳо; минус - талаботи сахттари инфрасохтор.
Амал: барои контурҳои муҳим дар вақти воқеӣ - Каппа; барои гузориш додан/омӯзиши ML - як схемаи иловагӣ.
Лӯлаи ҳодиса (истинод)
1. Истеҳсолкунандагон: хидматҳои букмекерӣ/пардохт чорабиниҳои домейниро нашр мекунанд (outbox → Kafka).
2. Автобус: Кафка бо қисмҳо аз рӯи калидҳо ('player _ id', 'bet _ id').
3. CDC: Debezium тағиротро аз OLTP (тавозун, маҳдудиятҳо) ҷараён медиҳад.
4. Сюзан: Flink/ksqlDB/Spark - агрегатҳо, тирезаҳо, CEP, ҳамроҳ шавед.
5. Пешгӯиҳо: ҷадвалҳои материализатсияшуда (Дӯкони давлатии Kafka Streams/Ҷадвалҳои ksql
6. Истеъмолкунандагон: зидди қаллобӣ, CRM, огоҳиномаҳо, панелҳо, ҷараёнҳои корӣ.
Шартномаҳо ва схемаҳои маълумот
Феҳристи Avro/Protobuf + Schema: шартномаҳои қатъӣ, муҳоҷирати ба қафо мувофиқ.
Версия: 'домен. ҳодиса. v {n} '; манъ кардани тағирот.
PII: токенизатсия/рамзгузорӣ, ниқоб, маҳдудияти мақсад (GDPR).
Семантикаи таҳвил ва idempotency
Ҳадди аққал як маротиба стандарти воқеӣ аст (нусхабардорӣ имконпазир аст) → коркарди idempotent лозим аст.
Маҳз як маротиба дар ҷараён: Истеҳсолкунандагони транзаксияи Kafka + EOS дар Flink/Streams; гаронтар, нуқтаи татбиқшаванда (пул/тавозун).
Outbox + CDC: манбаи ягонаи ҳақиқат аз пойгоҳи додаҳо, муҳофизати дукарата.
Dedup: калид ('idempotency _ key'), ҷадвали тақсимкунӣ бо TTL, upsert/merge.
Тирезаҳои вақт ва маълумоти "дер"
Тирезаҳо:- Tumbling - ҷойҳои собит (масалан, як дақиқаи инқилоб).
- Паридан - лағжиши афзоиш (масалан, равзанаи 5 дақиқа бо афзоиши 1 дақиқа).
- Сессия - аз рӯи ғайрифаъол (ҷаласаҳои бозингар).
- Нишонаҳои обӣ: коркарди вақти ҳодиса, дермонӣ, эвакуатсияи DLQ/тарафҳо.
- CEP (Коркарди чорабиниҳои мураккаб): намунаҳои "A пас B дар 3 дақиқа", "Ҳодисаҳои N дар M сония", "бекоркунӣ/ҷуброн".
Ҳолат ва миқёс
Операторҳои давлатӣ: агрегатҳо/joynes ҳолати худро нигоҳ медоранд (пуштибонии давлати Rocks
Мавзӯъҳои Changelog: эътимоднокӣ ва барқароркунии давлат.
Backpressure: назорати худкори суръат, маҳдудиятҳои sink/外 система.
Тақсимоти калидӣ: хиттерҳои вазнин → намаки калидӣ, кам кардани skew.
Мониторинг ва SLO
Ҷараёни SLO: p99 таъхири ниҳоӣ (масалан, ≤ 2 с), ақибмонии истеъмолкунандагон, дастрасӣ ≥ 99. 9%.
Нишондиҳандаҳо: гузариш, ақибмонӣ аз ҷониби ҳизб, таъхири нишонаи об, таносуби тарки/дер, бозгашт, операторони вақти банд, GC/JVM.
Огоҳӣ: Афзоиши DLQ, ақибмонии нишонаи об, нокомии нуқтаи гузаргоҳи EOS, хусусиятҳои онлайн/офлайнӣ.
Пайгирӣ: ID-ҳои corelational ('trace _ id', 'message _ id') тавассути истеҳсолкунанда-ҷараён-истеъмолкунанда.
Бехатарӣ ва риояи
TLS/MTLS, ACL/RBAC дар мавзӯъҳо/ҷадвалҳо, тақсимоти доменҳои ҳассос (пардохтҳо/CCM).
Рамзгузории PII дар транзит/дар диск; асрори Vault/SOPS.
Нигоҳдории маълумот ва маҳал: нигоҳдорӣ аз рӯи минтақа (ИА, Туркия, Латам), сиёсати бартарафсозӣ.
Аудит: кӣ нашр/хондааст, таҷдиди скриптҳо.
Дастрасии баланд ва DR
Кафка: 'нусхабардорӣ. омили ≥ 3 ',' мин. insync. нусхаҳои ',' acks = all ', нусхабардории байниминтақавӣ (MM2) барои DR.
Flink/Ҷараёнҳо: нуқтаи гузаргоҳи даврӣ + нуқтаи нигоҳдорӣ барои релизҳои назоратшаванда; Менеҷери HA-Job.
OLAP: такрори сегмент, нусхаҳои хондан; санҷишҳои нокомӣ (рӯзи бозӣ).
Иҷро ва танзими
Истеҳсолкунандагон: қассобӣ ('дароз. ms ',' партия. андоза '), фишурдасозӣ (lz4/zstd).
Истеъмолкунандагон: дуруст 'макс. пурсиш. фосила ', таваққуфи тарафҳо ҳангоми бозгашт.
Тақсимот: Ҳисобкунии тарафҳо аз TPS-и мақсаднок ва параллелизм.
Давлат: Параметрҳои Rocks-DB (блоки кэш/навиштани буфер), NVM .e/IOPS, пиндор.
Шабака: 10/25G, танзими TCP, нигоҳ доштани дархости танӯраи n + 1.
Татбиқ: Технологияҳои асосӣ
Шина: Апач Кафка (алтернативаҳо: Пулсар, Редпанда).
Ҷараён: Apache Flink, Kafka Streams, ksqlDB, Spark Structured Streaming
CDC: Debezium (My-SQL/Postgres), Пайвасткунакҳои Outbox.
Анборҳои проексия: ҷадвалҳои ksql-DB, мағозаи давлатии Kafka Streams, Redis барои таъхири кам, Click-House/Druid/Pinot барои OLAP.
Fichestor: Фест ё худ - онлайн (Redis) + офлайн (Parquet/Калони Query), кафолати пайдарҳамӣ.
Намунаҳои тарроҳӣ
Outbox → Kafka: ҳар як чорабинии домейн аз муомилоти DB.
Sagas: Ҷубронпулӣ тавассути рӯйдодҳо; оркестр тавассути ҷараён.
Фан-офф: як чорабинӣ → зидди қаллобӣ, CRM, таҳлил, огоҳиҳо.
Назари материализатсияшуда: лидерҳо, мувозинатҳо, маҳдудиятҳо - дар шакли ҷадвалҳо, ки аз ҷараён нав карда мешаванд.
Коркард: таҷдиди мавзӯъҳо барои аз нав ҳисоб кардани агрегатҳо/таҳлили ретро.
Намунаҳо (мафҳумҳо)
ksqlDB: пешвоёни мусобиқа (равзанаи слайд)
sql
CREATE STREAM bets_src (
bet_id VARCHAR KEY,
player_id VARCHAR,
amount DOUBLE,
ts BIGINT
) WITH (KAFKA_TOPIC='bets. placed. v1', VALUE_FORMAT='AVRO', TIMESTAMP='ts');
CREATE TABLE leaderboard AS
SELECT player_id,
SUM(amount) AS total_stake,
WINDOWSTART AS win_start,
WINDOWEND AS win_end
FROM bets_src
WINDOW HOPPING (SIZE 10 MINUTES, ADVANCE BY 1 MINUTE)
GROUP BY player_id
EMIT CHANGES;Флинк (псевдокод): баҳодиҳии зидди қаллобӣ бо рӯйдодҳои дер
java stream
.assignTimestampsAndWatermarks(WatermarkStrategy. forBoundedOutOfOrderness(Duration. ofSeconds(10)))
.keyBy(e -> e. playerId)
.window(SlidingEventTimeWindows. of(Time. minutes(5), Time. minutes(1)))
.aggregate(scoreFunction, processWindow)
.sideOutputLateData(lateTag)
.addSink(riskTopic);Санҷиши сифати ришта
Санҷишҳои шартномавии схемаҳо ва эволютсия (Феҳристи схема).
Боркунӣ: TPS-и мақсаднок, p99, рафтори таназзули ғарқшуда.
Нокомӣ/бетартибӣ: тарки брокерҳо/гиреҳҳо, таъхири шабака, тақсим кардани майна.
Такрори детерминистӣ-Мавзӯъҳоро аз нав иҷро мекунад → ҳамон натиҷаҳо.
Ҷараёнҳои канарӣ: ҳалқа барои санҷиши таъхир ва якпорчагӣ.
Рӯйхати назоратии татбиқ
1. SLO-ро муайян кунед (p99 X c, ақибмонӣ Y, мавҷудият Z).
2. Стандартикунонии схемаҳо ва калидҳо (player_id/bet_id).
3. Меъмориро интихоб кунед (Каппа барои ҳалқаҳои интиқодӣ).
4. Танзимоти outbox + CDC ва ҷудо кардани PII.
5. Тирезаҳо, нишонаи обӣ, сиёсати дер ва DLQ/баромадҳои тарафиро танзим кунед.
6. Даргиронидани EOS/idempotency дар роҳҳои пулӣ.
7. Ҷорӣ намудани мониторинг ва огоҳиҳо барои ақибмонӣ, нишонаи обӣ, DLQ.
8. Таъмини тартиби HA/DR ва коркард.
9. Store Feature Store ва ҳамоҳангсозии онлайн/офлайн.
10. Рӯзи бозиро гузаронед: кор кардани нокомӣ ва барқароршавӣ.
Анти-намунаҳо
Омезиши вақти ҳодиса ва вақти коркард бидуни сиёсати огоҳона.
Набудани идоракунии схема → нашри "шикастан".
Нодида гирифтани маълумоти дер ва калидҳои гарм.
Набудани стратегияи такрорӣ ва таҳрири мавзӯъҳо.
Нархҳо/пардохтҳо бидуни idempotency ва EOS.
Хулоса
Ҷараёни вақти воқеӣ ин "нақлиёти дигар" нест, балки роҳи тафаккур: рӯйдодҳои домейн, SLO-ҳои равшан, шартномаҳои маълумот, тирезаҳо ва вазъ, амният ва мушоҳида. Барои IGaming, маҷмӯи устувори он Kafka + Flink/ksqlDB + Debezium + Materialized Views + Store Feature мебошад. Вақте ки сарборӣ меафзояд, аксуламалҳои миллисекундӣ, мувофиқати таҳлили онлайн/офлайнӣ ва мураккабии назоратшавандаро медиҳад.