Horus Flow Mcp

pro.horustek由 horustek.pro 發布官方發布者v3.1.0更新於 Oct 25, 2026

Crypto order flow, cross-venue derivatives and US market context for AI agents, with a track record.

已驗證Streamable HTTP可網頁執行金融資料與分析

概覽

AI 產生的概覽

遠端 MCP 伺服器,讓助理取得加密貨幣即時訂單流、衍生品持倉、美股資金流與市場狀態讀數,並附實測命中率。

可以做什麼
  • 讀取某個幣安現貨交易對的即時訂單流與近期 15 秒快照
  • 掃描並排序幣安永續合約市場,依買方/賣方主導、成交量暴增、資金費率或漲跌篩選
  • 取得衍生品持倉、市場總覽、市場狀態與信任分數,以及涵蓋大量資產的波動突破掃描
  • 對比 BTC 資金流與美股及加密相關 ETF 資金流,並查詢美股交易時段與暫停交易情況
  • 查看訊號歷史命中率、供回測使用的時點訊號帳本、近期變化事件與資料來源新鮮度
適用情境
適合助理需要回答目前加密市場狀況、訂單流壓力、衍生品持倉,或加密與美股風險偏好是否一致時使用;也適合在依某個讀數行動前,先對照其實測命中率評估可信度。
執行需求
遠端 Streamable HTTP 端點,不需本機安裝。選用憑證:Horus 方案使用 X-API-Key 標頭(或 Bearer 權杖),RapidAPI 訂閱者使用 RapidAPI 金鑰標頭。未提供金鑰時適用免費額度,歷史較短、掃描結果較少,且不含衍生品與 Cortex 細節。需要網路連線。
安裝前請注意
工具為唯讀行情資料,但屬金融資訊而非投資建議:README 指出許多訊號接近擲硬幣水準,讀數僅供參考而非交易指令。美股資金流來自約占美國成交量 3% 的 IEX 樣本。歷史、衍生品、Cortex 與事件需付費方案。API 金鑰屬機密,以標頭傳送,請勿寫入共用設定。

安裝

在 SourceWeft 中

  1. 開啟 儀表板中的 Horus Flow Mcp,將其新增到工作區。
  2. 為需要使用其工具的對話啟用該服務。

Web executable,透過 Streamable HTTP。 遠端服務在工作區中設定後即可從網頁執行環境執行。

交給代理程式安裝

把這段提示詞貼上到 Claude Code、Codex、Cursor 等代理程式,或 SourceWeft 對話中。代理程式會讀取該伺服器的安裝指南,先向你展示發布者、端點和登入方式,經你同意後再把它新增到你的客戶端。金鑰不會寫進任何命令。

閱讀 https://sourceweft.com/mcp/pro.horustek%2Fhorus-flow-mcp/install.md,並按其中說明把這個 MCP 伺服器接入我的客戶端。修改任何設定之前,先告訴我它的發布者、端點和登入方式,等我確認。不要把 API 金鑰寫進命令或我會提交的檔案;問我金鑰應從哪裡取得。

檢視代理程式所依據的安裝指南

其他 MCP 客戶端

把它新增到你客戶端的 mcpServers 設定中。

{
  "mcpServers": {
    "horus-flow": {
      "type": "http",
      "url": "https://flow.horustek.pro/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

工具

14

get_crypto_flow

Live order flow for one Binance spot pair: signal, direction, 30-second buy/sell delta in USD, order book depth ratio, large sells in the last 5 minutes, and the signal's measured hit rate. Use for "what is the market doing right now in X". Symbols like BTCUSDT, ETHUSDT, SOLUSDT.

輸入參數symbol

get_flow_history

Recent order-flow snapshots (every 15s) for a crypto pair with a summary: signal counts, price change, cumulative 30s delta. Use to see whether pressure is building or fading. minutes up to 60 (BUILDER / RapidAPI PRO) or 1440 (PRO / RapidAPI ULTRA); free plans get the last 15 minutes.

輸入參數symbolminutes

get_market_overview

One call for the crypto market: BTC climate, ignition regime, Cortex regime, and for 10 majors the composite score, derivatives positioning (crowd vs its 24h median, liquidation gravity), futures/spot activity and open interest across Binance, Bybit and OKX. Full: PRO / RapidAPI ULTRA; lower plans get a BTCUSDT preview.

無需輸入參數。

get_derivatives

Derivatives positioning for one of 10 majors: funding (per venue and OI-weighted), open interest and its 10/30-minute change, futures/spot volume vs its 7-day median, crowd long/short vs its 24h median, top-trader divergence, estimated liquidation levels, liquidations seen in the last 5 minutes. Full: PRO / RapidAPI ULTRA; lower plans get a BTCUSDT preview.

輸入參數symbol

get_cortex

Horus Cortex: the BTC market regime, trust score (0-100), active contradictions between evidence families, invalidation and breakout levels, and position-size multipliers by strategy type. Full: PRO / RapidAPI ULTRA; lower plans get regime, trust score and headline.

無需輸入參數。

get_ignitions

Volatility-breakout scanner across ~750 crypto assets, refreshed every minute: global regime and the assets with the highest ignition score (0-1). A ranking of breakout conditions, not a probability. Full: BUILDER / RapidAPI PRO; free plans get the top 3.

輸入參數limit

scan_market

Scan about 190 Binance perpetual markets in one call and get a ranked list. preset is one of: buyers_in_control, sellers_in_control, volume_surge, breakout_candidates, crowded_funding, top_movers. Each row: price, 15m and 1h change, aggressive buy share, net taker flow in USD, volume surge, funding, ignition score, and Horus live flow with its measured hit rate where Horus tracks the pair. Use it to find where to look before calling get_crypto_flow or get_derivatives on a specific market. Rankings of current conditions, not predictions. Free plans: 3 rows; BUILDER / RapidAPI PRO and above: up to 100.

輸入參數limitpresetmin_volume_24h_usd

get_track_record

Measured hit rates of Horus signals at 1, 5, 15 and 30 minutes (window 30d or all), from every signal recorded live since August 2026. Pass a signal name (e.g. STRONG_BUY_PRESSURE) for just that signal. Use this to decide how much weight to give a reading. Free.

輸入參數signalwindow

get_signal_ledger

Point-in-time ledger: every signal Horus emitted for BTCUSDT, ETHUSDT or SOLUSDT between start and end (ISO dates, max 31 days), with the price and what the market did 1/5/15/30 minutes later. For backtesting. Full: BUILDER / RapidAPI PRO; free plans get 20 signals from the last 24 hours.

輸入參數endlimitstartsymbol

get_recent_events

What changed since your last check: liquidation cascades, strong flow signals, composite changes, Cortex regime changes, climate changes, ignition alerts, US session changes, new US trading halts. Pass the last event id you saw as since_id. types is a comma-separated filter. Full: BUILDER / RapidAPI PRO; free plans get the last 3 events, 15 minutes late.

輸入參數limittypessince_id

get_us_market_session

US equity market right now: session phase (pre-market, regular, after-hours, closed), holidays and early closes, next open and close in New York time, minutes to close, and currently active trading halts. Call this before reasoning about US stock trades. Free.

無需輸入參數。

get_cross_asset

BTC order flow side by side with US equities flow (SPY, QQQ) and crypto-linked stocks and ETFs (COIN, MSTR, IBIT): are crypto and stocks risk-on together, risk-off together, or diverging? When US markets are closed, says so and keeps BTC as the live gauge. Equity flow is an IEX sample. Full: BUILDER / RapidAPI PRO; free plans get SPY and QQQ only.

無需輸入參數。

get_equity_flow

Order flow for one US stock or ETF from the IEX feed (about 3% of US volume, a sample): signal, buy/sell ratio, delta, large IEX prints. Extreme verdicts are capped because of the sample size. Full: BUILDER / RapidAPI PRO; free plans get SPY and QQQ.

輸入參數symbol

get_service_status

Freshness and uptime of every Horus data source. Check this if a tool returns data_stale. Free.

無需輸入參數。

版本歷史

2
  1. v3.1.0最新Oct 23, 2026
  2. v1.0.6Sep 16, 2026

評分

已滿足適用檢查項的 100%

該評分衡量此收錄條目的完整程度,依據註冊中心條目、端點與公開來源計算得出。它不是對伺服器本身的評價,也不表示伺服器安全或目前可用:可連通性是帶日期的檢查結果,評分也不包含安裝量或使用者評價。

  • 近 30 天內可連通必需25 分
  • 已宣告認證方式必需10 分
  • 已列出工具必需15 分
  • 描述必需15 分
  • 圖示10 分
  • 文件15 分
  • 授權條款10 分

其他 Horustek 整合