TRIGGER
- • RabbitMQ / Manual / LocalDir
- • IdempotentStore 幂等防重复消费
- • CheckAndMark → MarkComplete
PIPELINE
- • Fetch → Download → Validate → Extract+Rules → Score → Alert
- • 全局 5min 超时，各阶段独立 timeout
- • Stage 4 Preprocess/Rules asyncio 并行
- • 非-alert 阶段失败走 fail() 统一出口
FALLBACK
- • GPT Engine 不可用 → rule_engine.py
- • 上报: POST /risk/alert
- • X-Auth-Token 鉴权, scan_status 0/1/2/3