horus-flow-mcp

---

🤖 零人工决策闭环实战

将 Claude Desktop、Cursor 或自主 LangChain / AutoGen Agent 连接到 Horus Cortex 后，你的 Agent 将不再产生幻觉，而是开始以华尔街级别的风险严谨性执行操作：

┌─────────────────────────────────────────────────────────────────────────────────────────────┐
│  Autonomous Quant Agent (Claude 3.5 Sonnet / Cursor IDE) 🤖                                │
│                                                                                             │
│  Prompt: "BTC is pumping. Should we execute a 3x breakout long entry?"                      │
│                                                                                             │
│  AI Calls Tool: `get_horus_cortex()`                                                        │
│  ◀  Horus Cortex Returns:                                                                   │
│     {                                                                                       │
│       "regime_state": "TRANSITION",                                                         │
│       "trust_score": 26.5,                                                                  │
│       "action_policy": {                                                                    │
│         "directive": "Deteriorating Transition: Capital Preservation Lock (0.0x)",          │
│         "trend_allowed": false,                                                             │
│         "ignition_allowed": false                                                           │
│       },                                                                                    │
│       "market_vitals": { "taker_ratio": 0.24, "global_ignition": 0.08 },                    │
│       "active_contradictions": [                                                            │
│         { "id": "BULLISH_PRICE_vs_HOLLOW_BREADTH", "severity": "MEDIUM" }                   │
│       ],                                                                                    │
│       "execution_boundaries": {                                                             │
│         "invalidation_support": 77052.0,                                                    │
│         "breakout_resistance": 78608.0                                                      │
│       }                                                                                     │
│     }                                                                                       │
│                                                                                             │
│  AI Final Output:                                                                           │
│  "⛔ TRADE ABORTED — CAPITAL PRESERVATION ENFORCED.                                        │
│   Although spot price is making local highs, Horus Cortex flags a severe divergence:        │
│   1. Taker Buy/Sell ratio collapsed to 0.24 (Aggressive seller absorption).                 │
│   2. Global market breadth is dormant (0.08) indicating an isolated, hollow squeeze.        │
│   3. Cortex Trust Score is 26.5/100 with active trend locks enabled.                        │
│   Action: Standing aside. Re-evaluating only if price confirms above $78,608 with volume."  │
└─────────────────────────────────────────────────────────────────────────────────────────────┘

---

🛑 别再预测 K 线，开始测量市场引力。

散户交易者依赖滞后指标（RSI、MACD、移动平均线），这些指标计算的是已经发生的情况。

Horus 提供预测，而非反应：

1. **一级至二级物理层（之眼）：**在 K 线打印前，测量亚秒级限价订单簿深度、虚假流动性墙和主动吃单执行差值。
2. **三级取证层（之雷达）：**追踪清算级联（引力方向）以及现货与期货投机比率。
3. 四级 Cortex（之思维）：综合7 个独立证据系列，通过实时矛盾引擎输出可供机器执行的仓位规模乘数和以 USD 计的失效边界。

---

🏗️ 架构

graph TD
    %% Styling
    classDef crypto_stream fill:#F3BA2F,stroke:#000,color:#000,stroke-width:2px;
    classDef equity_stream fill:#000,stroke:#09b533,color:#09b533,stroke-width:2px;
    classDef compute fill:#1A1F36,stroke:#00D6FF,color:#fff,stroke-width:2px;
    classDef level3 fill:#1A1F36,stroke:#FF6B00,color:#fff,stroke-width:2px;
    classDef cortex fill:#4A154B,stroke:#FFD700,color:#fff,stroke-width:3px;
    classDef mcp fill:#632CA6,stroke:#fff,color:#fff,stroke-width:2px;
    classDef client fill:#FF3366,stroke:#fff,color:#fff,stroke-width:2px;

    %% Ingestion
    subgraph Data_Pipelines [Websocket Ingestion]
        B[Binance WSS <br/> L1/L2 Book]:::crypto_stream
        A[Alpaca WSS <br/> IEX Equities - sample]:::equity_stream
        BF[Binance Futures <br/> OI / Funding / Liquidations]:::crypto_stream
    end

    %% Level 1-2 Engine
    subgraph Core_Engine [Level 1-2: Microstructure Physics]
        IC[Imbalance Calculator <br/> Bid/Ask Walls]:::compute
        FC[Flow Calculator <br/> Tape Deltas]:::compute
        BC[Behavioral Court <br/> Spoofing & Absorption Rules]:::compute
    end

    %% Level 3 Intelligence
    subgraph L3_Engine [Level 3: Institutional Intelligence]
        LH[Liquidation Heatmap <br/> Gravity Zones]:::level3
        XF[Cross-Exchange Flow <br/> Spot ↔ Futures]:::level3
        CI[Composite Intelligence <br/> 4-Layer Verdict]:::level3
    end

    %% Level 4 Cognitive Cortex
    subgraph L4_Cortex [Level 4: The Sovereign Cognitive Cortex]
        HC[Horus Cortex Symphony 3.0 <br/> 7 Forensic Families + Contradiction Engine]:::cortex
        TS[Penalized Trust Score 0-100]:::compute
        EB[Execution Boundaries USD]:::compute
        AP[Action Policy Multipliers for Bots]:::compute
    end

    %% Output
    subgraph Output_Layer [Data Delivery & Agent Integration]
        MCP[AI Agent FastMCP Server <br/> 8 Sovereign Tools]:::mcp
        API[FastAPI REST Gateway <br/> 13 Endpoints]:::client
        Dash[Real-Time Portal <br/> Live Microstructure]:::client
    end

    B --> IC
    A --> IC
    B --> FC
    A --> FC
    BF --> LH
    BF --> XF

    IC --> BC
    FC --> BC
    LH --> CI
    XF --> CI
    BC --> CI

    CI --> HC
    HC --> TS
    HC --> EB
    HC --> AP

    HC --> MCP
    HC --> API
    BC --> Dash

---

📡 完整 API 目录

一级至二级：订单流微观结构

端点	方法	说明	套餐
/v1/flow/crypto/{symbol}	GET	来自 Binance 公共数据流的订单簿失衡（前 20 档）和主动吃单流。适用于任意 TRADING 现货交易对	免费：所有交易对
/v1/flow/crypto/{symbol}/history	GET	每 15s 生成快照，包含价格、差值和比率	Builder：60 min · Pro：24 h
/v1/flow/equity/{symbol}	GET	来自 IEX 数据流的美国股票流量（约占美国成交量的 3%，为抽样数据）	Builder
/v1/flow/equity/macro-blocks	GET	SPY 买卖倾向及 IEX 记录的 200k USD 或以上成交	免费
/v1/status	GET	每个数据源的新鲜度和运行时间（无需密钥）	公开

第 3 级：取证级市场情报

端点	方法	描述	等级
/v1/intelligence/climate	GET	WiseMan BTC 市场状态与健康状况	Builder
/v1/intelligence/ignitions	GET	扫描约 750 种资产的波动率突破情况，每分钟刷新	Builder
/v1/intelligence/liquidation-heatmap	GET	群体仓位相对于其 24 小时中位数的情况，以及预估清算价位（10 种主流资产）	Pro
/v1/intelligence/cross-exchange-flow	GET	Binance、Bybit 和 OKX 的期货／现货成交量相对于其 7 日中位数的情况、溢价、资金费率和未平仓合约量	Pro
/v1/intelligence/composite	GET	根据市场状态、点火信号、仓位和期货／现货资金流计算的 0–100 分数	Pro
/v1/intelligence/market-intelligence	GET	一次调用获取上述所有 10 种主流资产的数据	Pro

每份第 3 级文档都包含一个 method 字段，其中注明精确公式。若数据超过新鲜度限制，端点会返回 503 data_stale，而不会提供过期数据。

第 4 级：主权认知中枢

端点	方法	描述	等级
/v1/intelligence/cortex	GET	市场状态、信任分数、矛盾、执行边界和操作策略	Pro
/v1/intelligence/maestro	GET	Cortex 端点的向后兼容别名	Pro

---

Agent 层

端点	方法	描述	计划
/v1/book/pressure	GET	一次调用获取 Binance 30 个交易对的现货订单簿（买单前五档占比、买卖比、30 秒主动成交资金流），以及其与下一分钟走势的实测关联	Free：3 行 · Trader：30
/v1/scan	GET	一次调用为约 250 个 Binance 永续合约排名：买方或卖方是否占据主导、成交量激增、突破候选标的、资金费率拥挤情况，或自定义筛选条件	Free：3 行 · Builder：100
/v1/track-record	GET	按信号、交易标的和置信度查看各信号在 1／5／15／30 分钟时的实时命中率	Public
/v1/track-record/signals	GET	时点分类账：Horus 当时发出了什么信号、对应价格，以及随后发生了什么（自 2026 年 8 月起）	Builder
/v1/events	GET	自上次检查以来的变化：清算连锁、市场状态变化、美国新增停牌等	Builder
/v1/events/stream	GET	以服务器发送事件的形式提供相同的事件	Builder
/v1/webhooks	POST GET DELETE	针对任何事件类型的签名 Webhook	Pro
/v1/equity/session	GET	美国交易时段阶段、节假日、提前收盘、下次开盘／收盘时间、当前停牌	Public
/v1/equity/halts	GET	当日公布的所有美国交易停牌信息及通俗易懂的原因说明	Public
/v1/cross-asset	GET	BTC 订单流与 SPY、QQQ、COIN、MSTR 和 IBIT 的资金流并列显示	Builder
/v1/status	GET	每个数据源的新鲜度和正常运行时间	Public

每项方向性资金流读数都包含一个 reliability 区块，其中提供实测命中率。在 /v1/flow/crypto/{symbol} 后添加 ?view=compact，即可获得精简答复。

---

🤖 连接你的 AI Agent

远程 MCP 服务（推荐）

https://flow.horustek.pro/mcp（Streamable HTTP）。

• RapidAPI 订阅用户： 将 RapidAPI 密钥作为 X-RapidAPI-Key: <key> 发送。调用会经由 RapidAPI，因此适用你的 RapidAPI 计划和配额。在 RapidAPI 上订阅。
• Horus 密钥： X-API-Key: <key> 或 Authorization: Bearer <key>。
• 无需密钥： 免费层：任意交易对的订单流、公开的历史表现记录、美国交易时段背景信息、扫描器前 3 条结果和服务状态。

Claude Code：

claude mcp add --transport http horus-flow https://flow.horustek.pro/mcp --header "X-RapidAPI-Key: YOUR_RAPIDAPI_KEY"

任何支持远程服务的 MCP 客户端：

{
  "mcpServers": {
    "horus-flow": {
      "type": "http",
      "url": "https://flow.horustek.pro/mcp",
      "headers": { "X-RapidAPI-Key": "YOUR_RAPIDAPI_KEY" }
    }
  }
}

工具（均为只读，使用精简 JSON 和输出架构）

工具	可解答的问题	计划
get_book_pressure	当前 30 种主要币的订单簿反映了什么？这些信息对预测下一分钟有多大帮助？	免费版（3 行）/ Trader
scan_market	当前约 250 个市场中，哪些市场的买盘、卖盘或成交量正在激增？	免费版（3 行）/ Builder
get_crypto_flow	单个交易对的实时订单流，以及信号测得的命中率	免费版
get_flow_history	过去一小时内的压力是在增强还是减弱？	Builder
get_market_overview	一次调用即可获取气候、Cortex 和 10 种主要币的信息	Pro
get_derivatives	Binance/Bybit/OKX 的资金费率和持仓量、市场仓位分布、清算价位	Pro
get_cortex	市场状态、信任分数、矛盾点、失效位和突破位	Pro
get_ignitions	覆盖约 750 种资产的突破扫描器	Builder
get_track_record	各信号的准确率	免费版
get_signal_ledger	含结果的历史信号，用于回测	Builder
get_recent_events	自上次检查后发生了哪些变化	Builder
get_us_market_session	当前能否交易美股？哪些股票已暂停交易？	免费版
get_cross_asset	加密货币和美股是否同步处于风险偏好状态，还是走势背离？	Builder
get_equity_flow	来自 IEX 样本的美股订单流	Builder
get_service_status	每个数据源的新鲜度	免费版

这些读数用于提供背景信息，并附有经测量的历史表现记录，而非交易指令。许多信号的得分接近抛硬币的随机结果；reliability 字段会如实说明这一点。

本地 stdio 服务（PyPI）

运行 pip install horus-flow-mcp 并设置 RAPIDAPI_KEY，即可通过本地 MCP 客户端使用 RapidAPI 上架版本。

Webhook 签名

import hmac, hashlib
def verify(secret: str, timestamp: str, body: bytes, signature: str) -> bool:
    expected = "sha256=" + hmac.new(secret.encode(), timestamp.encode() + b"." + body, hashlib.sha256).hexdigest()
    return hmac.compare_digest(expected, signature)
# timestamp = request.headers["X-Horus-Timestamp"], signature = request.headers["X-Horus-Signature"]

---

⚡ 60 秒量化机器人快速入门（Python）

import requests

HEADERS = {"X-API-Key": "your_horus_api_key"}
BASE_URL = "https://flow.horustek.pro"

# 1. Query Horus Cortex for the Sovereign Market State
res = requests.get(f"{BASE_URL}/v1/intelligence/cortex", headers=HEADERS).json()

trust_score = res["trust_score"]
policy = res["action_policy"]
boundaries = res["execution_boundaries"]

print(f"🧠 Market State: {res['regime_state']} | Trust: {trust_score}/100")
print(f"🛡️ Action Directive: {policy['directive']}")
print(f"🎯 Support Invalidation: ${boundaries['invalidation_support']:,.0f} | Breakout Target: ${boundaries['breakout_resistance']:,.0f}")

# 2. Enforce Autonomous Risk Rules
if not policy["trend_allowed"]:
    print("⛔ Trade Rejected: Cortex forbids trend breakouts during transitions.")
else:
    position_multiplier = policy["trend_multiplier"]
    # execute_trade(multiplier=position_multiplier, stop_loss=boundaries["invalidation_support"])

---

💎 计划

功能	免费版	Builder / Trader（$29/mo）	Pro（$149/mo）	Institutional（$499/mo）
加密货币订单流	任意 Binance 现货交易对	任意 Binance 现货交易对	任意 Binance 现货交易对	任意 Binance 现货交易对
订单流历史	–	60 分钟	24 小时	24 小时
历史表现和美股交易时段背景信息	✅	✅	✅	✅
气候、点火信号、跨资产、美股（IEX 样本）	–	✅	✅	✅
事件（轮询和 SSE）、信号账本	–	✅	✅	✅
衍生品（10 种主要币，Binance + Bybit + OKX）、综合指标、Cortex	–	–	✅	✅
签名 Webhook	–	–	✅	✅
速率限制	30/min	120/min	300/min	600/min
远程 MCP 服务	✅	✅	✅	✅

实时状态和正常运行时间：flow.horustek.pro/status.html

---

🌐 实时仪表板

在 flow.horustek.pro/dash/ 探索实时机构级订单流可视化工具。

---

以严谨的数学方法打造，服务于自主 AI Agent 和量化交易员。
© 2026 Horus Tech Ltd. 🦅

---

mcp-name: pro.horustek/horus-flow-mcp