horus-flow-mcp
Provides real-time orderflow intelligence for Binance cryptocurrency pairs, enabling AI agents to analyze live Level 2 orderbook data and institutional buying/selling pressure for USDT trading pairs.
Integrates with RapidAPI to access Horus Flow Intelligence API for institutional-grade crypto and equity orderflow data, requiring a RapidAPI key for authentication and data access.
🛑 Stop Predicting Candles. Start Measuring Gravity.
Retail traders use trailing indicators (RSI/MACD) to guess what the market will do based on the past. Horus uses Level 2 Orderbook physics, Tick imbalances, and 5-Second Flow Deltas to measure exactly what institutional whales are doing right now.
Horus doesn't ask "Are we overbought?". It measures gravitational pull and tells you: "Whales are spoofing the bid and aggressive takers are tearing through the ask. Liquidity is collapsing. Bailout now."
⚡ Why AI Agents (Claude, Cursor) Love Horus
If you hook up an AI Agent to a basic technical indicator feed, it gets confused by noise. If you feed an AI Agent Horus, it gets an institutional grade decision matrix.
Look at what Horus catches in real-time during a Liquidity Withdrawal / Flash Crash attempt:
{
"symbol": "BTCUSDT",
"signal": "LIQUIDITY_EVENT",
"confidence": 0.99,
"market_state": "DISTRIBUTION",
"risk": "EXTREME",
"description": "Liquidity withdrawn under price. Aggressive taking.",
"metrics": {
"bid_ask_ratio": 7.934,
"buy_sell_ratio": 0.393,
"delta_5s": -83040.05,
"whale_activity": true,
"large_sell_count": 4,
"delta_accel": 3.8,
"wall_side": "BID",
"wiseman_climate": {
"market_mode": "CHOP",
"health": "FRAGILE",
"confidence": 0.85
},
"flags": [
"GLOBAL_LIQUIDITY_EVENT",
"SPOOFING_DETECTED(wall=BID)"
]
},
"timestamp": 1776107738.975
}The Institutional Alpha:
bid_ask_ratio: 7.934&wall_side: BID: Massive spoofed bid walls are placed by whales below the market to create fake support.buy_sell_ratio: 0.393: Horus sees through the spoofing (SPOOFING_DETECTEDflag). It measures real taker flow and discovers aggressive selling is devastating the orderbook.delta_accel: 3.8&whale_activity: true: Selling momentum accelerated by 3.8x natively tracking 4 major whale dumps within milliseconds.wiseman_climate: FRAGILE: Integrates perfectly with the overarching Horus SaaS macro brain, verifying that Bitcoin's holistic environment is fragile before attacking.The Verdict: With a
0.99Confidence factor, the AI engine triggersLIQUIDITY_EVENT. It front-runs the ensuing 1-minute crash. This is Institutional Grade.
🏗️ Architecture
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 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 [Sub-Millisecond Websocket Ingestion]
B[Binance WSS <br/> L1/L2 Book]:::crypto_stream
A[Alpaca WSS <br/> SIP Equities]:::equity_stream
end
%% Engine
subgraph Core_Engine [The Physics Engine]
IC[Imbalance Calculator <br/> Bid/Ask Spread]:::compute
FC[Flow Calculator <br/> Tape Deltas]:::compute
Tkr[Prediction Tracker <br/> In-Memory Evaluator]:::compute
BC[Behavioral Court <br/> Spoofing & Liquidity Rules]:::compute
end
%% Output
subgraph Output_Layer [Data Shield & Delivery]
MCP[AI Agent MCP Context <br/> Context-Aware Prompts]:::mcp
API[FastAPI Client <br/> Safe Shielded Outputs]:::client
Dash[Real-time Dashboard <br/> Live Edge Proof]:::client
end
B --> IC
A --> IC
B --> FC
A --> FC
IC --> BC
FC --> BC
BC --> Tkr
Tkr -- "Validates 1M accuracy" --> BC
BC --> MCP
BC --> API
BC --> Dash🚀 Quickstart for Trading Bots
Getting started with Horus takes less than 60 seconds. ⚡ Test Instantly: Download our Postman Collection to ping the API directly from your browser.
# 1. Install Dependencies
pip install -r requirements.txt
# 2. Fire up the Core Engine
uvicorn app.main:app --host 0.0.0.0 --port 8011In your local Bot / Agent, simply pull the live flow for any Crypto or US Equity:
import requests
response = requests.get(
"http://127.0.0.1:8011/v1/flow/crypto/BTCUSDT",
headers={"X-API-Key": "your_secure_api_key"}
)
flow_data = response.json()
# The Zero-Human Decision Loop:
if flow_data['signal'] in ['EMERGENCY_DUMP', 'BAILOUT', 'LIQUIDITY_EVENT']:
print("Market gravity collapsing. Market selling all positions.")
# execute_market_sell()🌐 Live Real-Time Dashboard
Horus comes with a stunning glass-morphism WebSocket dashboard out-of-the-box (/dash/).
It features a Local Edge Proof Tracker that strictly measures 1-Minute Candle directional predictions generated by the Physics Engine with an openly transparent win rate.
Built with absolute precision for those who need to see the Matrix. — HORUS INTELLIGENCE 👁️
Latest Blog Posts
MCP directory API
We provide all the information about MCP servers via our MCP API.
curl -X GET 'https://glama.ai/api/mcp/v1/servers/horustechltd/horus-flow-mcp'
If you have feedback or need assistance with the MCP directory API, please join our Discord server