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