Detect Crypto Liquidity Shocks
Monitor real-time crypto market data to detect sudden liquidity changes and whale movements, sending comprehensive risk alerts directly to your inbox.
Detect Crypto Liquidity Shocks
This workflow continuously gathers and analyzes multiple layers of crypto market data to detect unusual liquidity shocks and whale activity in real-time. It combines orderbook details, on-chain flows, market prices, snapshot data, and AI-driven whale tracking to generate comprehensive alerts for traders or risk analysts.
It performs the following key actions:
- Fetches live orderbook data from Binance to assess market microstructure.
- Retrieves on-chain exchange flow metrics from CryptoQuant to monitor asset movements.
- Collects real-time pricing and market stats from CoinGecko.
- Gets additional snapshot data from Massive for broader market insights.
- Performs an AI-powered internet search for recent whale tracking intelligence from specialized sources.
- Normalizes and merges all collected data, applying AI analysis to score and flag anomalies based on defined risk dimensions.
What You Need
You will need a few API keys to power the different data feeds in this workflow:
| Data Source | Requirement | Purpose |
|---|---|---|
| Binance | API Key | Accessing real-time orderbook data |
| CryptoQuant | API Key | Retrieving on-chain exchange flow metrics |
| Massive | API Key | Getting market snapshot ticker data |
| CoinGecko | No Auth Needed | Fetching latest price, volume, and market cap |
| Gmail | Account Authentication | Sending the final alert emails |
How the Flow Works
- Binance Orderbook Fetch: Utilizes the Binance API to pull the current orderbook depth for a specified symbol and limit, evaluating the spread, depth, and bid/ask imbalances.
- CryptoQuant Exchange Flows Fetch: Gets net inflow and outflow data of Bitcoin across exchanges over a selected time window to detect abnormal exchange movements.
- CoinGecko Market Data Fetch: Fetches the latest price, 24-hour changes, volume, and market cap for the coin to track market trends.
- Massive Snapshot Fetch: Retrieves snapshot ticker data to gain additional market status context.
- AI Whale Tracking Search: Runs an AI-powered internet search focusing on whale activities like large wallet movements, smart money flows, and exchange-related influxes over the last few hours.
- Data Merge and Normalization Node: Combines outputs from all previous data sources into a structured object, gracefully handling any missing or faulty inputs.
- AI Analytical Scoring: Processes the merged data with a quantitative risk analyst prompt to detect and score anomalies. It uses thresholds like spread norms, depth, exchange flow surges, price changes, and whale activity presence to determine risk.
- Email Alert Generation: Sends a structured, color-coded alert report directly to your inbox with composite scores and specific trading recommendations.
Output
At the end of the run, you get a detailed email report summarizing:
- Orderbook health indicators including spread and depth metrics.
- On-chain exchange flow surges flagged for abnormality.
- Market price trends and volume changes.
- Whale intelligence flags based on recent large transactions or accumulation patterns.
- A consolidated anomaly score with explanations and risk flags to trigger alerts or further investigation.
Notes
- Keep your API keys secure and never expose them in public environments.
- The thresholds for anomalies in the AI scoring logic can be adjusted based on your personal risk appetite or current market conditions.
- The AI whale tracking relies on web search results, meaning its coverage and response completeness may vary depending on available public information.
- Run periodic tests to verify connectivity with each data source, as any API downtime could affect the accuracy of your alerts.
Want to showcase your own workflows?
Become a Needle workflow partner and turn your expertise into recurring revenue.
