Activity Diagram

风控消息处理活动

RabbitMQ 消息到达 → 去重 → 采集 → 并行预处理 → 诊断 → 上报

活动图 (Activity Diagram) — 行为性图形。展示业务逻辑或算法流程，侧重于动作和执行过程。

重复 跳过 新消息 失败 通过 失败 成功 消息到达 接收订单 去重? 获取订单信息 拉取交易数据 dbcli export 验证? 预处理 规则查询 GPT 风控评分 成功? Fallback 降级 发送告警 CONSUME IDEMPOTENT STAGE 1 STAGE 2 STAGE 3 STAGE 4 STAGE 5 STAGE 6 FORK JOIN LEGEND 开始/结束 活动 判断 并行分叉/汇合 关键活动

PARALLEL

并行活动

  • • Stage 4: 预处理与 规则查询并行执行
  • • asyncio 并发，任一失败则整体失败
  • • Fork/Join 条表示并行分叉与汇合
  • • 规则查询 30 分钟缓存，关键词去重排序

FALLBACK

异常分支

  • • 验证失败 → 直接告警失败 (scan_status=3)
  • • GPT 风控评分失败 → Fallback 降级
  • • 降级走 rule_engine.py，结果仍上报
  • • 非-alert 阶段失败统一走 fail() 出口
nova-shield · github.com/novashield/risk-engine