horus-flow-mcp について
horus-flow-mcpは、クオンツトレーダーやAI取引エージェント向けに、暗号資産と米国株のリアルタイム注文フローおよび市場情報を提供します。多層シグナル、実績記録、Cortexのリスク境界を使ってデータに基づく市場評価を支援します。
主な機能
- 01暗号資産のリアルタイム注文フロー
- 02米国株フローのサンプル
- 03デリバティブと清算情報
- 04クロスマーケットのスキャンとイベント
- 05シグナルの的中率と履歴
- 06Cortexのリスクと執行境界
活用シーン
- 01BTCの注文板圧力と成行フローを確認
- 02ブレイクアウトや過密ポジションをスキャン
- 03暗号資産と米国株のフローを比較
- 04シグナル結果と信頼性を検証
MCP 対応
Streamable HTTP経由で読み取り専用の市場データツールを公開するリモートMCPサーバーです。PyPIからローカルのstdioサーバーも利用できます。
設定
ローカルサーバーの設定はどのクライアントでも共通です。コピーしてクライアントの MCP 設定ファイルに貼り付けてください。
ツール
ローカルサーバーのツールはマシン上で起動して初めて取得できます。メンテナーはまだツール一覧を提供していません。
詳細
🦅 HORUS CORTEX & FLOW
自律型AIトレーディングエージェントのための認知型マーケットブレイン
遅行するローソク足の残響を頼りにAIトレーディングエージェントを取引させてはいけません。クジラの目と、機関投資家レベルの認知能力を与えましょう。
🤖 人間を介さない意思決定ループの実例
Claude Desktop、Cursor、または自律型のLangChain / AutoGenエージェントをHorus Cortexに接続すると、エージェントは幻覚を起こさなくなり、ウォール街の厳格なリスク管理基準に基づいて実行を開始します。
┌─────────────────────────────────────────────────────────────────────────────────────────────┐
│ 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." │
└─────────────────────────────────────────────────────────────────────────────────────────────┘
🛑 ローソク足を予測するのはやめましょう。相場の重力を測りましょう。
個人トレーダーは、すでに起きたことを計算する遅行指標(RSI、MACD、移動平均)に頼っています。
Horusは事後対応ではなく、先を予測します。
- レベル1~2の物理(目): ローソク足に反映される前に、サブ秒単位の指値注文板の厚み、偽装された流動性の壁、積極的なテイカー執行のデルタを測定します。
- レベル3のフォレンジック(レーダー): 清算カスケード(重力の方向)と、現物対先物の投機比率を追跡します。
- レベル4の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カタログ全体
レベル1~2:オーダーフローのマイクロストラクチャー
| エンドポイント | メソッド | 説明 | ティア |
|---|---|---|---|
/v1/flow/crypto/{symbol} | GET | Binanceの公開ストリームから取得した、注文板の不均衡(上位20段)とテイカーフロー。取引可能なすべての現物ペア | 無料:全ペア |
/v1/flow/crypto/{symbol}/history | GET | 価格、デルタ、比率を含む15秒ごとのスナップショット | Builder:60分 · Pro:24時間 |
/v1/flow/equity/{symbol} | GET | IEXフィードから取得した米国株のフロー(米国取引量の約3%に相当するサンプル) | Builder |
/v1/flow/equity/macro-blocks | GET | SPYの買い/売りの偏りと、20万ドル以上のIEX約定記録 | 無料 |
/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日間の中央値と比較。プレミアム、ファンディング、OI も表示 | Pro |
/v1/intelligence/composite | GET | 市況、イグニッション、ポジショニング、先物/現物フローから算出した0〜100のスコア | Pro |
/v1/intelligence/market-intelligence | GET | 主要10銘柄について、上記すべてを1回の呼び出しで取得 | Pro |
レベル 3 の各ドキュメントには、正確な計算式を示す method フィールドが含まれます。鮮度の上限を超えたデータを配信する代わりに、エンドポイントは 503 data_stale を返します。
レベル 4:ソブリン・コグニティブ・コーテックス
| エンドポイント | メソッド | 説明 | ティア |
|---|---|---|---|
/v1/intelligence/cortex | GET | レジーム状態、信頼度スコア、矛盾、執行境界、アクションポリシー | Pro |
/v1/intelligence/maestro | GET | Cortex エンドポイントとの後方互換性を保つエイリアス | Pro |
エージェントレイヤー
| エンドポイント | メソッド | 説明 | プラン |
|---|---|---|---|
/v1/book/pressure | GET | Binance の30ペアの現物オーダーブックを1回の呼び出しで取得(上位5段の買い注文比率、買い/売り比率、30秒間のテイカーフロー)。次の1分間との測定済み相関も表示 | Free:3行 · Trader:30 |
/v1/scan | GET | Binance の無期限先物約250銘柄を1回の呼び出しでランク付け:買い手または売り手の優勢、出来高急増、ブレイクアウト候補、ファンディングの偏り、またはカスタムフィルター | 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 | 同じイベントを Server-Sent Events で取得 | 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 エージェントを接続する
リモート 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 の主要通貨の現在のオーダーブックが示す状況と、それが次の 1 分間についてどの程度の情報を示してきたか | Free(3 行) / Trader |
scan_market | 約 250 の市場で、買い手、売り手、または出来高が現在どこで急増しているか | Free(3 行) / Builder |
get_crypto_flow | 1 つのペアのリアルタイムの注文フローと、シグナルの測定済み的中率 | Free |
get_flow_history | 過去 1 時間にわたり、圧力が強まっているか弱まっているか | Builder |
get_market_overview | Climate、Cortex、主要 10 銘柄の情報を 1 回の呼び出しで取得 | Pro |
get_derivatives | Binance/Bybit/OKX の資金調達率と OI、群衆のポジショニング、清算水準 | Pro |
get_cortex | レジーム、信頼度スコア、矛盾、無効化水準、ブレイクアウト水準 | Pro |
get_ignitions | 約 750 の資産を対象としたブレイクアウトスキャナー | Builder |
get_track_record | 各シグナルがどの程度正しかったか | Free |
get_signal_ledger | バックテスト用の、結果を含む過去のシグナル | Builder |
get_recent_events | 前回の確認から何が変わったか | Builder |
get_us_market_session | 現在、米国株を取引できるか、また取引停止中の銘柄はどれか | Free |
get_cross_asset | 暗号資産と米国株式がともにリスクオンか、または乖離しているか | Builder |
get_equity_flow | IEX のサンプルに基づく米国株のフロー | Builder |
get_service_status | すべてのデータソースの鮮度 | Free |
データは測定済みの実績を伴う状況把握用の情報であり、取引の指示ではありません。多くのシグナルのスコアは五分五分に近く、そのことは reliability フィールドに示されています。
ローカル stdio サーバー(PyPI)
ローカルの MCP クライアントから RapidAPI のリスティングを利用するには、pip install horus-flow-mcp を実行し、RAPIDAPI_KEY を設定します。
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 秒で始める Quant Bot クイックスタート(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"])
💎 プラン
| 機能 | Free | Builder / Trader($29/mo) | Pro($149/mo) | Institutional($499/mo) |
|---|---|---|---|---|
| 暗号資産の注文フロー | 任意の Binance 現物ペア | 任意の Binance 現物ペア | 任意の Binance 現物ペア | 任意の Binance 現物ペア |
| フロー履歴 | – | 60 分 | 24 時間 | 24 時間 |
| 実績と米国市場セッションの状況 | ✅ | ✅ | ✅ | ✅ |
| Climate、ignitions、クロスアセット、米国株式(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 エージェントとクオンツトレーダーのために、数学的厳密さをもって設計されています。
© 2026 Horus Tech Ltd. 🦅
mcp-name: pro.horustek/horus-flow-mcp
コメント
AI アプリケーションが外部のツールやデータソースに統一的な方法で接続するためのオープンなプロトコルです。クライアントはモデルとの対話を担い、MCP サーバーはツール・リソース・プロンプトテンプレートを提供します。標準メッセージでやり取りするため、1 つのサーバーを複数のクライアントで再利用できます。