皇冠赔率数据分发引擎：多源采集架构与毫秒级API推送协议

{
  "op": "ODDS_DELTA",
  "seq_id": 98410294812,
  "server_ts_ms": 1742914820415,
  "ingest_latency_ms": 9,
  "match_id": "CR-20250325-EPL-089",
  "league_code": "ENG_PR",
  "is_in_play": true,
  "match_clock": "64:18",
  "score": { "home": 1, "away": 1, "corners_h": 6, "corners_a": 4 },
  "deltas": [
    {
      "line_id": "AH_MAIN_01",
      "market_type": "ASIAN_HANDICAP",
      "is_main_line": true,
      "hdp": -0.25,
      "hdp_display": "0/0.5",
      "market_status": "OPEN",
      "home_hk": 0.880,
      "away_hk": 1.020,
      "home_dec": 1.880,
      "away_dec": 2.020,
      "payout_rate": 97.14,
      "water_trend": "HOME_DROP_FAST",
      "delta_home": -0.060
    }
  ]
}

{
  "op": "MARKET_LOCK_ALERT",
  "seq_id": 98410294813,
  "server_ts_ms": 1742914822102,
  "qos_priority": 0,
  "match_id": "CR-20250325-EPL-089",
  "match_clock": "64:20",
  "trigger_event": "PENALTY_OR_VAR_REVIEW",
  "danger_zone": "AWAY_BOX_PENALTY_AREA",
  "affected_markets": ["ASIAN_HANDICAP", "OVER_UNDER", "1X2_LIVE"],
  "market_status": "SUSPENDED",
  "reject_new_orders": true,
  "note": "禁区内疑似手球触发VAR核查，全线滚球盘口瞬时锁死"
}

{
  "code": 200,
  "snapshot_seq_id": 98410294800,
  "generated_at_ms": 1742914800000,
  "match_info": {
    "match_id": "CR-20250325-EPL-089",
    "league_zh": "英格兰超级联赛",
    "home_zh": "阿森纳",
    "away_zh": "切尔西",
    "kickoff_utc": "2025-03-25T19:45:00Z"
  },
  "markets": {
    "asian_handicap": [
      { "line_id": "AH_MAIN_01", "line_rank": 1, "hdp": -0.5, "home_hk": 0.94, "away_hk": 0.96, "status": "OPEN" },
      { "line_id": "AH_ALT_02",  "line_rank": 2, "hdp": -0.25, "home_hk": 0.68, "away_hk": 1.24, "status": "OPEN" },
      { "line_id": "AH_ALT_03",  "line_rank": 3, "hdp": -0.75, "home_hk": 1.21, "away_hk": 0.70, "status": "OPEN" }
    ],
    "over_under": [
      { "line_id": "OU_MAIN_01", "line_rank": 1, "line": 2.75, "over_hk": 0.91, "under_hk": 0.99, "status": "OPEN" }
    ]
  }
}

import asyncio, json, hmac, hashlib, time, websockets

API_KEY = "cr_live_99281a7bc..."
API_SECRET = b"your_hmac_secret_key"

async def subscribe_crown_stream():
    ts = str(int(time.time() * 1000))
    sig = hmac.new(API_SECRET, f"{API_KEY}:{ts}".encode(), hashlib.sha256).hexdigest()
    uri = f"wss://stream.apex-odds.com.cn/v4/crown/live?key={API_KEY}&ts={ts}&sig={sig}"

    async with websockets.connect(uri, ping_interval=15) as ws:
        await ws.send(json.dumps({
            "action": "SUBSCRIBE",
            "channels": ["inplay.ah.all", "inplay.ou.all"],
            "odds_format": "HK"
        }))
        last_seq = {}
        async for raw_msg in ws:
            pkt = json.loads(raw_msg)
            m_id, seq = pkt.get("match_id"), pkt.get("seq_id", 0)
            if m_id in last_seq and seq > last_seq[m_id] + 1:
                # 触发增量回补请求防止丢包
                await ws.send(json.dumps({"action": "REPLAY_GAP", "match_id": m_id, "from_seq": last_seq[m_id] + 1}))
            last_seq[m_id] = seq
            print(f"[{pkt.get('match_clock')}] {m_id} -> {pkt.get('op')}")