Horus Flow Mcp

io.github.horustechltd由 GitHub 账号 horustechltd 发布v1.0.2更新于 Oct 24, 2026

Institutional crypto & equity orderflow intelligence for AI trading agents.

发布方自己的服务：Horus Flow Mcp

已验证STDIO仅桌面金融数据与分析

概览

AI 生成的概览

为 AI 交易代理提供机构级加密货币与股票订单流情报，包括带信任评分和执行边界的市场认知判断。

可以做什么
Horus Flow MCP 提供返回加密货币与美股市场微观结构和情报数据的工具。工具包括 get_horus_cortex（返回含信任评分、矛盾标记、执行边界和机器人操作乘数的共识判断），以及 get_crypto_flow、get_equity_flow、scan_crypto_flow、get_liquidation_heatmap、get_cross_exchange_flow、get_composite_intelligence 和 get_full_market_intelligence。输出用于为自主交易代理提供市场状态、订单流指标和风险指令。
适用场景
适用于构建或运行需要订单流、清算、跨交易所和宏观状态信号而非滞后指标的 AI 交易代理。适合由代理决定仓位规模或是否观望的量化工作流。
运行要求
作为本地 Python stdio 进程运行（PyPI 包 horus-flow-mcp）。需要通过 RAPIDAPI_KEY 环境变量提供 RapidAPI 密钥，并需要访问 Horus Flow 服务的网络连接。付费订阅等级决定第 3、4 级情报和更高 API 配额。
安装前请注意
需要 RAPIDAPI_KEY 密钥，请勿放入共享配置。该服务为付费订阅且有配额限制，更高等级才能解锁 Cortex 和情报端点。输出为交易信号和指令而非保证；代理据此操作可能进行真实交易并造成亏损。数据会发送至第三方市场数据服务。

安装

在 SourceWeft 中

  1. 打开 控制台中的 Horus Flow Mcp，将其添加到工作区。
  2. 为需要使用其工具的对话启用该服务。

Desktop only，通过 STDIO。 STDIO 服务会启动本地进程，因此需要 SourceWeft 桌面宿主。

其他 MCP 客户端

参照 仓库 中的启动说明。

README

🦅 HORUS CORTEX & FLOW

The Cognitive Market Brain for Autonomous AI Trading Agents

[Glama Verified] [Glama Score] [AI Agents Listing Verified]

[FastMCP] [Status] [Python] [License]

Don't let your AI trading agents trade on lagging candlestick echoes. Give them the whale's eyes and an institutional cognitive mind.

🤖 The Zero-Human Decision Loop in Action

When you connect Claude Desktop, Cursor, or an autonomous LangChain / AutoGen agent to Horus Cortex, your agent stops hallucinating and begins executing with Wall Street risk rigor:

text
┌─────────────────────────────────────────────────────────────────────────────────────────────┐│  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."  │└─────────────────────────────────────────────────────────────────────────────────────────────┘

🛑 Stop Predicting Candles. Start Measuring Gravity.

Retail traders rely on lagging indicators (RSI, MACD, Moving Averages) which calculate what has already happened.

Horus is predictive, not reactive:

  1. Level 1-2 Physics (The Eye): Measures sub-second limit orderbook depth, spoofed liquidity walls, and aggressive taker execution delta before candlesticks print.
  2. Level 3 Forensics (The Radar): Tracks Liquidation Cascades (Gravity Direction) and Spot vs. Futures Speculation Ratios.
  3. Level 4 Cortex (The Mind): Synthesizes 7 independent evidence families with a real-time Contradiction Engine to output machine-executable position sizing multipliers and USD invalidation boundaries.

🏗️ Architecture

mermaid
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

📡 Complete API Catalog

Level 1-2: Orderflow Microstructure

EndpointMethodDescriptionTier
/v1/flow/crypto/{symbol}GETOrder book imbalance (top 20 levels) and taker flow from Binance's public stream. Any TRADING spot pairFree: all pairs
/v1/flow/crypto/{symbol}/historyGETSnapshots every 15s with price, deltas and ratiosBuilder: 60 min · Pro: 24 h
/v1/flow/equity/{symbol}GETUS equity flow from the IEX feed (about 3% of US volume, a sample)Builder
/v1/flow/equity/macro-blocksGETSPY buy/sell skew and IEX prints of $200k or moreFree
/v1/statusGETFreshness and uptime of every data source (no key)Public

Level 3: Forensic Market Intelligence

EndpointMethodDescriptionTier
/v1/intelligence/climateGETWiseMan BTC regime and healthBuilder
/v1/intelligence/ignitionsGETVolatility breakout scanner across ~750 assets, refreshed every minuteBuilder
/v1/intelligence/liquidation-heatmapGETCrowd positioning vs its 24h median and estimated liquidation levels (10 majors)Pro
/v1/intelligence/cross-exchange-flowGETFutures/spot volume vs its 7-day median, premium, funding and OI across Binance, Bybit and OKXPro
/v1/intelligence/compositeGET0-100 score from climate, ignition, positioning and futures/spot flowPro
/v1/intelligence/market-intelligenceGETAll of the above for 10 majors in one callPro

Every Level 3 document carries a method field with its exact formula. Endpoints return 503 data_stale instead of serving data older than their freshness limit.

Level 4: The Sovereign Cognitive Cortex

EndpointMethodDescriptionTier
/v1/intelligence/cortexGETRegime state, trust score, contradictions, execution boundaries and action policyPro
/v1/intelligence/maestroGETBackward-compatible alias for the Cortex endpointPro

Agent Layer

EndpointMethodDescriptionPlan
/v1/book/pressureGETThe spot order book of 30 Binance pairs in one call (top-five bid share, bid/ask ratio, 30 s taker flow), with its measured link to the next minuteFree: 3 rows · Trader: 30
/v1/scanGETRank about 250 Binance perpetuals in one call: buyers or sellers in control, volume surge, breakout candidates, crowded funding, or custom filtersFree: 3 rows · Builder: 100
/v1/track-recordGETLive hit rate of every signal at 1/5/15/30 min, by signal, symbol and confidencePublic
/v1/track-record/signalsGETPoint-in-time ledger: what Horus said, at what price, and what happened next (since Aug 2026)Builder
/v1/eventsGETChanges since your last check: liquidation cascades, regime changes, new US halts, and moreBuilder
/v1/events/streamGETThe same events as Server-Sent EventsBuilder
/v1/webhooksPOST GET DELETESigned webhooks for any event typePro
/v1/equity/sessionGETUS session phase, holidays, early closes, next open/close, active haltsPublic
/v1/equity/haltsGETAll US trading halts published today, with plain-language reasonsPublic
/v1/cross-assetGETBTC order flow next to SPY, QQQ, COIN, MSTR and IBIT flowBuilder
/v1/statusGETFreshness and uptime of every data sourcePublic

Every directional flow reading carries a reliability block with its measured hit rate. Add ?view=compact to /v1/flow/crypto/{symbol} for a token-light answer.

🤖 Connect Your AI Agent

Remote MCP server (recommended)

https://flow.horustek.pro/mcp (Streamable HTTP).

  • RapidAPI subscribers: send your RapidAPI key as X-RapidAPI-Key: <key>. Calls go through RapidAPI, so your RapidAPI plan and quota apply. Subscribe on RapidAPI.
  • Horus keys: X-API-Key: <key> or Authorization: Bearer <key>.
  • No key: free tier: order flow for any pair, the public track record, US session context, the first 3 scanner results and service status.

Claude Code:

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

Any MCP client that supports remote servers:

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

Tools (all read-only, compact JSON with an output schema)

ToolWhat it answersPlan
get_book_pressureWhat does the order book say right now across 30 majors, and how much has that told about the next minuteFree (3 rows) / Trader
scan_marketWhere are buyers, sellers or volume surging across about 250 markets right nowFree (3 rows) / Builder
get_crypto_flowLive order flow for one pair, with the signal's measured hit rateFree
get_flow_historyIs pressure building or fading over the last hourBuilder
get_market_overviewClimate, Cortex and 10 majors in one callPro
get_derivativesFunding, OI across Binance/Bybit/OKX, crowd positioning, liquidation levelsPro
get_cortexRegime, trust score, contradictions, invalidation and breakout levelsPro
get_ignitionsBreakout scanner across ~750 assetsBuilder
get_track_recordHow often each signal was rightFree
get_signal_ledgerHistorical signals with outcomes, for backtestingBuilder
get_recent_eventsWhat changed since your last checkBuilder
get_us_market_sessionCan US stocks be traded right now, and which are haltedFree
get_cross_assetAre crypto and US equities risk-on together or divergingBuilder
get_equity_flowUS stock flow from the IEX sampleBuilder
get_service_statusFreshness of every data sourceFree

Readings are context with a measured track record, not trade instructions. Many signals score close to a coin flip; the reliability field says so.

Local stdio server (PyPI)

pip install horus-flow-mcp and set RAPIDAPI_KEY to use the RapidAPI listing from a local MCP client.

Webhook signatures

python
import hmac, hashlibdef 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-Second Quant Bot Quickstart (Python)

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 Stateres = 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 Rulesif 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"])

💎 Plans

FeatureFreeBuilder / Trader ($29/mo)Pro ($149/mo)Institutional ($499/mo)
Crypto order flowAny Binance spot pairAny Binance spot pairAny Binance spot pairAny Binance spot pair
Flow history–60 minutes24 hours24 hours
Track record and US session context✅✅✅✅
Climate, ignitions, cross-asset, US equities (IEX sample)–✅✅✅
Events (polling and SSE), signal ledger–✅✅✅
Derivatives (10 majors, Binance + Bybit + OKX), composite, Cortex––✅✅
Signed webhooks––✅✅
Rate limit30/min120/min300/min600/min
Remote MCP server✅✅✅✅

Live status and uptime: flow.horustek.pro/status.html

🌐 Live Real-Time Dashboard

Explore the live institutional orderflow visualizer at flow.horustek.pro/dash/.

Engineered with mathematical rigor for Autonomous AI Agents and Quantitative Traders.
© 2026 Horus Tech Ltd. 🦅

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

来源：README.md，提交 12ac376

工具

0
SourceWeft 尚未在沙箱中启动过该软件包，因此其工具未知。

版本历史

1
  1. v1.0.2最新Sep 16, 2026

评分

已满足适用检查项的 50%

该评分衡量此收录条目的完整程度，依据注册中心条目、端点与公开来源计算得出。它不是对服务器本身的评价，也不表示服务器安全或当前可用：可连通性是带日期的检查结果，评分也不包含安装量或用户评价。

  • 近 30 天内可连通25 分

    请保持端点能够响应 MCP 握手；SourceWeft 每 30 天探测一次。

  • 已声明认证方式10 分

    请在注册中心条目中声明凭据请求头，或保持端点能够响应探测，以便判定其认证方式。

  • 已列出工具15 分

    请让服务器在无凭据时响应 tools/list，或发布可在沙箱中无凭据启动的软件包。

  • 描述必需15 分
  • 图标10 分
  • 文档15 分
  • 许可证10 分

其他 Horustek 集成

Horus Flow Mcp

pro.horustek官方发布者

远程 MCP 服务器，为助手提供加密货币实时订单流、衍生品持仓、美股资金流与市场状态读数，并附带实测命中率。

Streamable HTTP可网页运行
金融14 个工具Oct 25, 2026