İş Akışı Motoru
1) Neden bir motora ihtiyacınız var?
IGaming'de birçok uçtan uca prosedür vardır: para yatırma/çekme, KYC/AML, bahis/ödeme işleme, kazananlara yapılan ödemeler, dolandırıcılık karşıtı soruşturmalar, bonus kampanyaları, olay yönetimi. Workflow Engine bunları yapar:- Öngörülebilir: açık adımlar, durumlar, SLA'lar ve sorumlu.
- Güvenilir: idempotency, retrays, tazminatlar, son tarihler.
- Şeffaf: metrikler, izleme, denetim, düzenleyiciler için kanıtlanabilirlik.
- Etkili: Rutinin otomasyonu + bir kişi kurallara göre bağlanır.
2) Temel ilkeler
Kritik orkestrasyon, koreograf geri kalanı: kritik zincirleri (ödemeler/çıktılar/yerleşme) - merkezi orkestrasyon altında; Kritik olmayan olaylar - koreografi yoluyla (pub/sub).
Idempotency her yerdedir: her adım 'idempotency _ key' alır ve sonuçları saklar.
SLA farkındalığı: adım başına zaman ve genel son tarih sabittir; zamanlayıcılar tarafından tırmanma.
Telafi, DB geri alma: dış etkiler için - destanlar/tazminat.
Döngüdeki insan: resmileştirilmiş'dar kapılar "(appruves, 4-eyes, SoD).
Kod Olarak Politika: yönlendirme, öncelikler, şube koşulları - politikalarda.
Gözlemlenebilirlik: Her görevin bir SLI/SLO'su, izleri ve denetimi vardır.
3) Etki alanı modeli
3. 1 Temel varlıklar
Süreç: Uzun ömürlü orkestrasyon (dakika/saat/gün).
Görev: atomik işlem (hizmet/insan).
Aktivite: tip (hizmet/insan/karar) ile süreç adımı.
Sinyal/Etkinlik: harici olaylar (PSP webhook, KYC yanıtı, özel eylem).
Zamanlayıcı: son tarihler, hatırlatıcılar, süreli yayınlar.
Bağlam: Sürecin güvenli yükü (kiracı, bölge, KYC-id, limitler, risk oranı).
3. 2 Görev durumları
scheduled - running - (başarılı | başarısız | timed_out | iptal edildi | telafi edildi)
4) Mimari desenler
Süreç orkestratörü: merkezi motor durumu, zamanlayıcıları, kuyrukları, yönlendirmeyi depolar.
Çalışanlar: Etki alanı görev kuyruklarına abone olan durumsuz hizmetler (Ödemeler, KYC, Risk, Oyunlar).
Sagalar: Her "güçlü" işlem için bir ters (telafi edici) vardır.
Giden Kutusu/Gelen Kutusu: harici sistemlerle "tam olarak bir kez" entegrasyonunu garanti eder.
Komut/Geri Çağrı: görevler komutlarla başlatılır; Sonuçlar - sosis/webhooks tarafından.
Özellik bayrakları: dinamik dal seçimi (örn. Alternatif PSP).
İzleme: Tüm çağrılarla 'trace _ id' ilişkisini işleyin.
5) Garantiler ve sürdürülebilirlik
En az bir kez görev yürütme + işleyici idempotency.
Jitter ve sınırlı bütçeli Retrai (görev başına, süreç başına).
Zaman aşımları: 'task _ timeout' <step SLA; 'process _ deadline' <düzenleyici süre.
Histerezis ve geri tepme: fırtına koruması.
Devre kesiciler: bağımlılık "kırmızı" olduğunda geri çekilmeyi durdurun.
Büyükbaba Mektubu (DLQ): Nadir görülen aksaklıkların tam bağlamla manuel olarak sökülmesi için.
6) Tipik süreçlerin kataloğu (iGaming)
1. Deposit: init - 3DS/auth - capture - ledger - bonus credits - notice - antifraud check (asynchronously).
Tazminatlar: iptal/iptal, geri dönüş, indirim iadesi.
2. Withdrawal: request ^ risk scoring ^ 4-eyes app ^ payment gateway ^ payment register ^ notification.
Tazminat: para çekme iptali, yeniden rota, hesap dondurma.
3. KYC/AML: doküman toplama, sağlayıcı 1, fallback sağlayıcı 2, manuel kontrol, sonuç/TTL.
4. Bet/Settle: Reservation - Factor Fix - Confirmation - Settle/Settle - Payout.
5. Bonus kampanya: Hedefleme - kupon sorunu - aktivasyon - bütçe izleme - sona erme/iptal.
6. Incident-process: detection - classification of P1-P4 - var-room - actions - closure of post-mortem.
7) Görev Özellikleri
IDempotent anahtar: 'task _ id' + iş anahtarı (örn. 'within _ id').
Ön koşullar: fırlatma koşulları (veriler, limitler, bayraklar).
Eylem RPC/HTTP/gRPC/kuyruk komutu.
Sonuç işleme başarılı/kısmi/hata/zaman aşımı.
Retrai: strateji (exp backoff + jitter), maksimum deneme.
Tazminat: ters eylem/güvenli bir duruma geçiş.
Denetim: ne, kim tarafından/ne, ne zaman ve neden; Öncesi/sonrası.
8) Döngüde insan
Yerleşik insan görevleri: kontrol listesi, ekler, ipuçları (çalışma kitabı), RACI.
SoD/4-eyes: uyumsuz roller, P1/P2 için iki uygulama.
SLA: Hareketsizlik sırasında yükselme (zamanlayıcılar, grup değişikliği, düşük riskte otomatik düşüş/onaylama).
İletişim: istenen kanallara bildirimler, P1/P2'daki durum sayfası Comms Lead aracılığıyla.
9) SLA, önceliklendirme ve zamanlayıcı
Öncelikler P1 (hemen) - P2 - P3 (arka plan).
Kotalar: kiracı/bölge/sağlayıcı başına; Kuyruk "yakalama" karşı koruma.
Son tarihler: bir adım ve süreç; Son teslim tarihinin ihmal edilmesi - tazminat/tırmanma.
Süreli yayınlar: cron süreçleri (kapanış kayıtları, bonusların sona ermesi, düzenleyicilere raporlar).
QoS sınıfına göre kuyruklar: gerçek zamanlı (A), operasyonel (B), analitik (C).
10) Politikalar ve DSL
Kod Olarak İlke: Şubeler için Rego/YAML/JSON-DSL, PSP yönlendirme, SoD gereksinimleri, limitler.
Sürüm oluşturma: etkin örnekleri kesmeden v1 - v2 işlemlerini geçirir.
Kanarya politikaları: yeni şubedeki trafiğin bir kısmı; SLI tarafından geri alındı.
11) Veri, gizlilik ve uyumluluk
Bağlamı en aza indirmek: süreçte - sadece gerekli alanlar; PII - tokenize.
Jeo-bilinçli depolama: Yargı yetkisine göre (GDPR ve yerel kurallar).
TTL ve saklama: dergiler, eserler ve belgeler için farklıdır.
Dışa aktarma: Yalnızca şifreleme, bilet ve SoD ile iş akışıyla.
Denetim: Değiştirilemeyen günlükler (WORM), olay bağlantısı.
12) Gözlemlenebilirlik ve kalite kontrolü
SLI/SLO süreci: tamamlanma yüzdesi, ortalama/95. süre, SLA ihlalleri.
Görev metrikleri: başarı/hata/geri alma/zaman aşımları, kuyruktaki yaş.
İzler: Adımlar, ödemeler/oyun etkinlikleri ile korelasyon.
Panolar: Exec (SLA/hata bütçesi, darboğazlar), Ops (kuyruklar/gecikmeler, geri ödemeler, DLQ), Risk/Ödemeler (PSP şubeleri, uygulamalar).
Anomaliler: Süre ve hatalar konusunda STL/CUSUM/CPD; otomatik ölçeklendirme/feilover.
13) Maliyet (FinOps İş Akışı)
$/process örneği, $/task, $/retray.
Optimizasyonlar: Düşük öncelikli adımlar, olayların toplanması, uzun süreçlerin sınırları, eski verilerin temizlenmesi.
Kotalar: Kiracı başına başlatma/saklama için; showback/chargeback.
14) Güvenlik
IAM/ABAC: Süreçlere/görevlere rollere ve niteliklere göre erişim (kiracı/bölge/çevre).
PAM/JIT: Manuel adımlar için geçici ayrıcalıklar.
Webhookların ve isteklerin imzası: HMAC/mTLS.
Koruyucu eylemler: Anomali durumunda otomatik blok ihracat PII; Hassas dallara çift kontrol (PSP yönlendirme, ödeme limitleri).
15) Entegrasyonlar
Ödeme sağlayıcıları (PSP): komutlar/webhooks, geri dönüş yönlendirmesi.
KYC/AML: sağlayıcılar, manuel kuyruklar, düzenleyici son tarihler.
Oyun sağlayıcıları: yerleşme/raporlama, işlem kanalı gecikmeleri.
Olay-platform/durum sayfası: Haritaların otomatik oluşturulması/güncellenmesi.
Serbest bırakma kapıları: "Kırmızı" işlemler sırasında tehlikeli salınımları engelleme.
16) Şablon dizini (DSL parçaları)
Servis görevi (HTTP):yaml type: http id: payments_auth retry:
max_attempts: 5 backoff: exponential_jitter timeout: 2s idempotency_key: ${process. deposit_id}
on_fail: compensate: cancel_auth
İnsan görevi (4 göz):
yaml type: human id: withdrawal_approve sod: true approvers: [Risk, Finance]
sla: 2h on_timeout: escalate: L2
Tazminat destanı:
yaml saga:
do: [reserve_funds, capture, ledger_post]
undo: [ledger_revert, refund_capture, release_funds]
17) Uygulama Yol Haritası (8-12 hafta)
Ned. 1–2:- Süreçlerin envanteri (depozito/çıktı/CCM/yerleşme), SLA hedefleri, risk sınıfları.
- Motor/yaklaşım seçimi (orkestratör + kuyruklar + durum mağazası).
- MVP: iki destan olarak para yatırma ve çekme; Idempotent işleyicileri; DLQ; Temel metrikler/yollar.
- Sonuçlar için insan-görevleri (4-göz); PSP yönlendirme zamanlayıcıları ve son tarihler için Kod Olarak İlke.
- Gözlemlenebilirlik (SLO/gösterge panoları), süreye göre anormallikler, otomatik ölçekli işçiler; Olay platformu/durum sayfası ile entegrasyon.
- Uyum: gizlilik/TTL/WORM denetimi; dışa aktarma-iş akışı; SoD/ABAC.
- Maliyet optimizasyonu, pik perf testleri, masa üstü alıştırmaları, şablon kütüphanesi.
18) KPI/KRI işlevleri
SLA süreç yürütme, MTTP (ortalama işlem süresi).
Manuel katılım olmadan otomatik tamamlamaların oranı.
Geri alma/Görev oranı, DLQ oranı, Tazminat oranı.
Uygulama zamanı (insan görevleri) ve gecikme yüzdesi.
Maliyet: $/süreç, $/görev, $/retray.
Risk sinyalleri: para çekme/yatırma anomalileri, SoD tutarsızlıkları.
19) Antipatterns
"Her şey" için bir monolitik süreç ölçeklendirmek ve değiştirmek zordur.
Idempotency olmadan Retrays - yinelenen ödemeler/eylemler.
Son tarihler/yükselmeler yok - asılı sonuçlar/CCL.
TTL ve maskeleme olmadan bir süreç bağlamında PII depolama.
Otomasyon olmadan "kağıt üzerinde" tazminat.
İzleme ve denetim eksikliği - doğruluğu kanıtlamak imkansızdır.
Toplam
İş akışı motoru, iş operasyonlarının yaşam döngüsünü yönetmek için bir sistemdir: kritik yolların düzenlenmesi, sürdürülebilirlik (idempotency, geri çekilmeler, sagalar), resmi insan katılımı, güvenlik ve uyum politikaları, uçtan uca gözlemlenebilirlik ve değer kontrolü. Bu kontur, iGaming platformunu ani artışlarda öngörülebilir, olaylarda hızlı ve düzenleyiciler ve ortaklar için ikna edici hale getirir.