MESSAGE FLOW
- • 1: CheckAndMark → 幂等检查 (pending/completed)
- • 2: Run → Pipeline 启动 5 阶段流水线
- • 3: FetchMetadata → OrderService 轮询 (30s 间隔, 3min 超时)
- • 4: Download → dbcli export 日志目录
- • 5a/5b: Preprocess + Query → asyncio 并行
- • 6: Score → GPT Engine 风控评分
- • 7: Alert → POST 上报风控结果
- • 8: MarkComplete → 标记幂等完成 (dashed)
PARALLEL
- • 5a/5b 使用 asyncio 并行执行
- • 任一 goroutine 失败不取消另一个
- • Rules 失败仅记日志，不阻塞流程
- • Preprocess 失败则 Pipeline 整体失败
- • 6 必须等 5a/5b 全部完成后执行