C. Real-time Antifraud¶

Тип материала — инженерный walkthrough. HYPOTHETICAL — модель и схемы.

Архитектура и владельцы¶

flowchart LR
 A["Bet API"] --> B["Inline risk gate"] --> C["Redis scoped state"] --> D["Kafka audit and Flink"]

Контракт и нормальная последовательность¶

Gate получает identity запроса и rule version. Atomic rule дедуплицирует запрос, обновляет окно и возвращает признаки. Decision record хранит outcome и feature generation. Stream формирует более сложные признаки.

sequenceDiagram
 participant A as Bet API
 participant B as Inline risk gate
 participant C as Redis scoped state
 participant D as Kafka audit and Flink
 A->>B: Send versioned input
 B->>C: Check atomic player window
 C-->>B: Return durable evidence
 B->>D: Advance downstream processing

Отказ и replay¶

Redis timeout оставляет неизвестный update. Retry применяет прежнюю identity. При недоступности state действует degraded policy. После Flink restore проверить serving frontier и перестроить generation.

sequenceDiagram
 participant B as Inline risk gate
 participant C as Redis scoped state
 participant O as Recovery owner
 B->>C: Attempt operation
 Note over B,C: Counter timeout with unknown outcome
 O->>C: Retry same identity or degrade
 C-->>O: Verified state or explicit pending

Мониторинг и сверка¶

Сравнить counters с dedup input cut. Измерять API decision latency, feature age, watermark и fallback отдельно.

Альтернативы¶

Inline gate предотвращает эффект, async review поддерживает расследования. Гибрид требует связи decisions и signal revisions.

Распределённый runtime сценария NOT_RUN. Локальные примеры