Sequence Diagram

风控消息时序

RabbitMQ 消息到达 → 5 阶段 Pipeline → 发送告警,全程最多 10min

序列图 (Sequence Diagram) — 行为性图形·交互图。按照时间顺序展示对象之间传递的消息。

RabbitMQ Pipeline OrderService GPT Engine / Fallback AlertService 消息到达 IDEMPOTENT CHECK GET /order/:id OrderInfoResponse DBCLI EXPORT VALIDATE PREPROCESS+Rules --format=json RiskResult[] POSTPROCESS POST /risk/alert 200 OK CONSUME STAGE 1 STAGE 2 STAGE 3 STAGE 4 STAGE 5 STAGE 6 失败 → FALLBACK LEGEND 内部调用 HTTP / API 关键诊断 返回 激活期

INBOUND

订单入口

  • • RabbitMQ Queue: orderRiskCheck
  • • AMQP TLS 认证
  • • IdempotentStore 去重,跳过重复消息
  • • 手动确认消息,WithoutCancel 保优雅关闭

SCORING

核心风控

  • • GPT Engine: --format=json --model gpt-4-turbo
  • • 3min 独立超时,RiskResult[] 返回
  • • 失败降级 → rule_engine.py (Fallback)
  • • PostProcess: extractJSON → validate → normalize → sort

METADATA

元数据与下载

  • • OrderService: GET /order/:id/detail
  • • 30s 轮询至 success/failed,5min 超时
  • • 数据库导出: dbcli export,5min 超时
  • • DBConfig {region, ak, sk, path}

ALERT

告警发送

  • • POST /job/:jobId/score-result
  • • X-Auth-Token 鉴权,3 次重试
  • • scan_status: 1=诊断中 2=完成 3=失败
  • • 完成/失败均上报,offset 始终提交