AI-офис: 7 реальных агентов в DeFi
Без «маленьких человечков в 2D». Реальный код на сервере, 24/7. Sentiment / Whale / Yield / Real-Trader / Portfolio / Mempool / Data-Audit. Архитектура каждого — внутри.
Что внутри гайда
- Sentiment Engine (CrowdPulse v4.5) — индекс страха и жадности по твоим монетам: 6 осей с верифицированными IC-весами, 20 коллекторов, composite score 0–100 каждый час
- Whale Tracker — 100 кошельков под наблюдением (Nansen Smart Money + ранние LP): push-алёрт при движении > $10M за < 90 секунд
- Yield Chaser v4.2 — новые DeFi-пулы с APR > 15%: 4 уровня фильтрации (TVL, аудит, smart money exposure, нетто-APR с IL и газом) — только то, что реально зайти
- Real Trader v2.1 — симуляция твоей стратегии на live-данных с реальным газом и слиппеджем: видишь «сколько заработал бы сегодня» без риска
- Portfolio Tracker — реальный P&L в долларах каждые 30 минут с учётом газа, IL и реализованных выходов — не «теоретическая доходность» из интерфейса
- Mempool Service — видит транзакции до подтверждения: large swap, новый LP, suspicious approve — алёрт за < 5 секунд через WebSocket
- Data Auditor — каждые 6 часов 3-way reconciliation (on-chain ↔ DB ↔ 3 внешних источника), авто-пауза агента при расхождении
- $200–250/мес — постатейная разбивка: 7 провайдеров, конкретные цифры, альтернативы для экономии
Sentiment Engine — индекс страха и жадности по твоим монетам
Большинство смотрят один Fear & Greed от Alternative.me — число от 0 до 100, которое никак не связано с твоими конкретными монетами. CrowdPulse v4.5 считает настроение по шести независимым осям с верифицированными весами (IC-калибровка на 4500 точках, ребаланс 20.02.2026). Composite score обновляется каждый час, алёрт идёт в Telegram при пересечении пороговых значений.
Агент не говорит «рынок позитивный». Он говорит: «smart_positioning = 0.71 bullish (IC_1d=+0.062), retail_emotion = −0.18 bearish (контрарианский сигнал), leverage_pressure = 1.3σ». Ты видишь расхождение — и это уже информация.
Архитектура: 20 коллекторов на входе (Binance REST, Deribit, SocialData.tools, Reddit API, CoinMetrics, Alternative.me, FRED, Google Trends, ForexFactory RSS, SoSoValue ETF, yfinance, FlowPulse signals). На выходе — composite 0–100 + значение по каждой оси (z-score) + LLM-анализ (DeepSeek hourly / Claude Sonnet daily) + TG-пуш при пересечении порога. Cadence: 10 * * * * (каждый час в :10) + daily report в 05:10 UTC + AI predictor каждые 4ч.
6-осевая модель (IC-rebalanced 20.02.2026, 4500 точек):
COMPOSITE_WEIGHTS_V4:
smart_positioning: 0.32 # IC_1d=+0.062 — лучшая ось
flow_activity: 0.18 # IC_1d=+0.041 — недооценивалась ранее
leverage_pressure: 0.14 # IC_1d=+0.019 — была переоценена
retail_emotion: 0.14 # IC_1d=−0.018 — контрарианский
market_structure: 0.12 # сильные TA IC (momentum_7d IC=+0.196)
macro_liquidity: 0.10 # Monthly data, hard to IC
Стек:
- Python 3.11 + FastAPI (REST API) + asyncio (коллекторы)
- PostgreSQL (time-series schema + ETF flows history)
- Claude Haiku 4.5 via OpenRouter (AI predictor, ~$0.40/мес)
- DeepSeek Chat (hourly LLM analysis, ~$1.4/мес)
- Claude Sonnet (daily premium report, ~$0.05/day)
- EWMA нормализация: winsorization ±4σ,
TANH_SCALE=1.5 - Cron + systemd
Ключевые формулы:
Composite score финальный:
composite_raw = Σ (weight_i × axis_score_i)
composite_0_100 = 50 + clip(composite_raw, −3, +3) / 3 × 50
EWMA нормализатор (per-metric halflife):
ewma_mean_t = α × x_t + (1−α) × ewma_mean_{t−1}
z_t = clip((x_t − ewma_mean_t) / ewma_std_t, −4, +4)
normalized = tanh(z_t × 1.5)
Retail Emotion (sub-axis):
retail_score =
x_sentiment_raw × 0.28
+ panic_fomo_raw × 0.15
+ reddit_sentiment × 0.15
+ x_velocity_raw × 0.12
+ engagement_raw × 0.10
+ google_trends × 0.10
+ fear_greed × 0.10
Источники данных (20 коллекторов):
- Binance REST klines — 8 TA метрик (BTCUSDT/ETHUSDT, 250 свечей, бесплатно)
- Deribit public API — Put/Call ratio, ATM IV, DVOL, Risk Reversal
- SocialData.tools — Twitter/X (20 CT-инфлюенсеры + retail keywords), ~$0.04/день
- Reddit API — r/CryptoCurrency, r/ethereum hot posts → DeepSeek NLP
- CoinMetrics Community API — MVRV, Puell Multiple, Exchange Flow (бесплатно)
- Alternative.me — Fear & Greed Index (бесплатно)
- FRED API — Global M2 (US/EU/China/Japan) + Fed balance sheet
- Google Trends (pytrends) — крипто-ключевые слова, graceful fallback при 429
- ForexFactory RSS — макрокалендарь (CPI, FOMC, NFP), кэш fallback при 429
- SoSoValue (Playwright + SOCKS5 proxy) — BTC+ETH ETF daily flows
- yfinance — S&P 500 (ES=F) + Nasdaq (NQ=F) фьючерсы
- DeFiLlama Yields API — Aave v3 USDC borrow APY z-score
- Coingecko price feed — кэш 5 мин, fallback Chainlink on-chain
- Binance funding rate — perpetual funding velocity (smart positioning input)
- Bybit funding + OI — секунд-резолюция OI velocity
- OKX top traders ratio — long/short смарт-сегмента
- FlowPulse composite_v5 — собственная производная сигналов
- Whale Tracker activity log — onchain.whale_vol_z из соседнего агента
- Stablecoin supply (DeFiLlama Stablecoins API) — flow_activity
- Etherscan gas tracker — gwei z-score (proxy для on-chain активности)
Пример output:
{
"timestamp": "2026-05-21T10:10:00Z",
"composite": 68,
"axes": {
"smart_positioning": {
"score": 0.71,
"signal": "bullish",
"summary": "Funding rate +0.018% (2.1σ), top traders net long 58%",
"details": [
"ETH basis +0.32% annualized (bullish carry)",
"Whale inflows stable"
]
},
"flow_activity": {
"score": 0.44,
"signal": "bullish",
"summary": "ETF inflows $312M yesterday, stablecoin supply +$1.2B 7d"
},
"leverage_pressure": {
"score": -0.18,
"signal": "neutral",
"summary": "OI velocity low, ATM IV declining"
},
"retail_emotion": {
"score": -0.22,
"signal": "bearish",
"summary": "Twitter FUD 0.31, Google Trends flat — contrarian bullish read"
},
"market_structure": {
"score": 0.61,
"signal": "bullish",
"summary": "momentum_7d above MA50, MACD cross confirmed"
},
"macro_liquidity": {
"score": 0.19,
"signal": "neutral",
"summary": "DXY -0.4% week, real yields stable"
}
},
"paradox": "Retail negativity (−0.22) vs smart positioning bullish (0.71) — classic divergence pre-move",
"clients": "1. Держать позиции ETH/USDC\n2. Следить за пробоем $3100\n3. Хедж при IV > 55"
}
Cost model:
SocialData.tools: ~$1.5/мес (Twitter/X коллекторы)
DeepSeek Chat: ~$1.4/мес (hourly LLM, 800 токенов/час × 720ч)
Claude Sonnet daily: ~$1.5/мес (30 daily reports × 4096 токенов)
AI predictor: ~$0.40/мес (Claude Haiku 4.5, каждые 4ч)
Прочие API: бесплатно (Binance, CoinMetrics, FRED, Reddit)
SoSoValue proxy: ~$0/мес (собственный VPS 178.173.249.135)
─────────────────────────────────────────────
Итого: ~$5/мес
Метрики:
- Hourly IC_1d:
smart_positioning = +0.062(лучшая ось из 6) - Walk-forward бэктест (4500 точек):
composite > 0.5= ~68% точность направления +24ч - AI predictor accuracy: накапливается weekly (self-learning loop каждое воскресенье)
- Runtime: ~55 сек/час (все 20 коллекторов параллельно через asyncio)
- Latency TG-алёрт: < 2 мин от сигнала до пуша
Whale Tracker — 100 кошельков под наблюдением
Когда кит двигает $20M из холодного кошелька на Binance — это не просто транзакция. Это сигнал. У тебя есть минуты до того, как большинство это увидит. Whale Tracker мониторит 100 заранее отобранных адресов и бьёт алёрт до того, как рынок среагировал.
Список не берётся с потолка. 96K+ меток в wallet_labels базе данных (файл label_enricher.py в FlowPulse) — это реальный label_db, построенный на Dune-запросах и Etherscan Labels API. Три категории адресов + динамическое обновление.
Архитектура: на входе — Alchemy WebSocket (alchemy_pendingTransactions + eth_subscribe("logs")), Etherscan Labels API, Dune Analytics (верификация smart money), PostgreSQL wallet_labels (96K+ адресов). На выходе — TG-алёрт при trigger + запись в whale_180.json + CrowdPulse ось smart_positioning.onchain.whale_vol_z. Cadence: realtime WebSocket (Ethereum mainnet + ETH Sepolia) + кэш обновляется каждые 6ч.
Стек:
- Alchemy WebSocket API (ETH mainnet) —
alchemy_pendingTransactionsс фильтром поfromAddress(до 1000 адресов за подписку) - Etherscan Labels API v2 (бесплатный tier, 5 req/sec)
- Dune Analytics API (2500 кредитов/мес free tier)
- PostgreSQL: таблица
wallet_labels(96K+ записей),whale_activity_log - Python asyncio + websockets
wallet_tracker.pyв FlowPulse (3-tier lookup: labels DB → Etherscan → Dune fallback)
Как составляется список 100 кошельков:
Три категории адресов в watchlist:
- Smart Money (верифицированные по Dune) — Dune SQL: кошельки с cumulative realized PnL > $2M за 12 месяцев, минимум 10 успешных входов в DeFi-протоколы с APR > 20%, без rug-паттернов. Это ≈ логика Nansen Smart Money (Nansen API от $99/мес даёт те же метки «Smart LP», «Smart Trader», «Fund», но мы реплицируем через Dune free tier).
- CEX-выводы крупных игроков — адреса, которые исторически выводили $5M+ с Binance/Coinbase/OKX и после которых следовало движение цены ±3% в течение 4ч. Верификация через Etherscan Labels API (помечены как CEX withdrawal destinations).
- Ранние LP крупных протоколов — первые 50 провайдеров ликвидности в Uniswap V4 (ETH mainnet), GMX V2, Aave V3 — через The Graph subgraph запросы по
mintsevent в первые 72ч после деплоя.
Что триггерит алёрт:
- Native ETH transfer > $10M (configurable)
- ERC-20 transfer > $10M USD (Coingecko price × amount)
- Withdraw from known CEX address (Binance/Coinbase hot wallets из labels DB)
- Deposit to known CEX address (накопление для продажи)
- Large DEX swap через Uniswap/Curve router > $500K
Ключевые формулы:
# USD value при алёрте:
usd_value = token_amount × coingecko_price_usd
# Coingecko /simple/price кэш 5 мин
# Для ETH native:
usd_value = wei / 1e18 × eth_price_usd
# Whale score (для CrowdPulse smart_positioning):
whale_vol_z = z_score(whale_usd_24h_rolling, window=168h)
Сравнение с коммерческими альтернативами:
- Nansen Standard — $99/мес, готовые метки Smart Money/Smart LP/Fund, но без кастомизации списка
- Nansen VIP — $1899/мес, расширенные алёрты, real-time wallet labels, deep API
- Dune + Etherscan + наш код — $0/мес (free tier), полная кастомизация под твой портфель и сетапы
- Arkham Intel — есть free tier, но без push-API real-time
Источники данных:
- Alchemy WebSocket — единственный способ получить pending tx по адресам (до 1000 адресов/подписку)
- Etherscan Labels API v2 — CEX адреса, известные протоколы
- Dune Analytics free tier (2500 кредитов/мес) — верификация smart money через SQL
- Nansen Smart Money labels [одиночный] — premium API, в нашем стеке заменён Dune-репликацией
Пример TG-алёрта:
🐋 WHALE ALERT — ETH Mainnet
Адрес: 0x742d...f3c2 [Binance: Large Withdrawal]
→ 0x89aB...d4f1 [Smart Money: Fund]
Актив: 15,420 ETH (~$38.1M)
Тип: CEX Withdrawal → Cold Wallet
Gas: 21 gwei / tx fee $4.20
⏱ Время: 14:23:07 UTC (pending, ждём подтверждения)
🔗 https://etherscan.io/tx/0xabc...
📊 Контекст: последнее движение этого адреса
было 2026-03-12 → через 4ч ETH +5.2%
Cost model:
Alchemy Pay-as-You-Go: ~$8–15/мес (WebSocket CU usage)
~30M CU/мес free tier
перекрывает базовую нагрузку
Etherscan API v2: $0/мес (бесплатный tier, 5 req/sec)
Dune Analytics: $0/мес (2500 кредитов/мес free)
─────────────────────────────────────────────
Итого: ~$0–15/мес (зависит от объёма подписок)
Метрики:
- Latency broadcast → TG push: < 90 секунд (pending tx)
- Latency broadcast → confirmed: +12–30 секунд (средняя скорость блока ETH)
- False positive rate: ~15% (dropped/replaced transactions, помечаются статусом)
- Address coverage: 100 адресов активного мониторинга + 96K+ в label DB для обогащения
- Update cadence label DB: каждые 6ч (Dune + Etherscan refresh)
alchemy_pendingTransactions работает только на ETH Mainnet и ETH Sepolia — Arbitrum, Base, Optimism не поддерживаются этим методом. Для L2 кит-мониторинга используем polling alchemy_getAssetTransfers каждые 5 минут (задержка выше — до 6 мин до push в TG).Yield Chaser — новые пулы > 15% APR без ручной проверки
Каждый день появляются новые DeFi-пулы. Большинство — мусор или прямой скам. Yield Chaser v4.2 сканит всё новое и возвращает только то, что прошло многоуровневую фильтрацию. Не «посмотри на этот пул с 2000% APR» — а конкретные возможности, в которые реально можно зайти.
Под капотом — не просто фильтр по цифрам. APY рассчитывается из реальных fee-данных субграфа The Graph (feesUSD/tvlUSD × 8760, rolling 2h avg) и верифицируется через Dune Analytics по историческим данным пула. Netto-APR считает IL, реальный газ и стоимость бриджа.
Архитектура: на входе — DeFiLlama Yields API (/yields/pools, 17K+ пулов), The Graph subgraphs (5 сетей), DeFiLlama Protocols API (/protocols поле audits), rug.build API, данные Whale Tracker (smart money exposure), Alchemy RPC (on-chain чтение контрактов), Across Protocol API (стоимость бриджа). Cadence: cron каждые 4ч + cooldown 24ч между moves (anti-churning).
Стек:
- DeFiLlama API (бесплатный, без ключа) —
/yields/pools(17K+ пулов),/protocols - The Graph subgraphs (5 сетей: ETH, ARB, BASE, OPT, POLY) —
feesUSD/tvlUSDизpoolHourDatas - rug.build API (бесплатный) — скан смарт-контрактов
- Alchemy RPC — on-chain чтение контрактов (multicall3 батчинг)
- Dune Analytics API (free tier, 2500 кредитов/мес) — исторические данные пулов
- Python:
defillama_client.py,protocol_risk.py,protocol_scanner.py - PostgreSQL:
protocol_cache(~1488 протоколов, обновляется Вс 03:00 UTC)
4-уровневая фильтрация:
- Уровень 1 — базовые пороги:
APR > 15%,TVL > $500K,Pool age > 72ч - Уровень 2 — аудит смарт-контракта:
DeFiLlama audits field != null, rug.build scan (mint without cap → reject, centralized admin → reject, proxy without timelock → reject),protocol_risk.py5-factor score >= 0.55 - Уровень 3 — smart money exposure:
whale_in_pool(any whale_address ∈ pool_lp_list),deployer_age > 180d(отсев serial rugpullers) - Уровень 4 — нетто-экономика:
netto_APR = gross_APR − IL_estimate − gas_entry_exit_annualized,breakeven_apr × 2
protocol_risk score (примеры реальных значений):
- Aave V3 — 0.920 (maturity max, audits OpenZeppelin + Sigma Prime, без incidents)
- Uniswap V3 — 0.870 (maturity max, OZ + Trail of Bits)
- Aave V3 (на стабильных стейблах) — 0.827 (composite по пулу)
- Pendle — 0.715 (audits есть, но новее)
- Fluid (Instadapp) — 0.620 (нижняя граница допуска, новый протокол)
- Threshold для прохождения: 0.55 (ниже — автоматический reject)
Формула:
safety = (
maturity × 0.25 +
tvl_rank × 0.20 +
audit_score × 0.25 +
(1 − incident_flag) × 0.20 +
code_quality × 0.10
)
Источники данных:
- DeFiLlama
/yields/pools— 17K+ пулов с TVL, APY, chain, project, audits — бесплатно, без ключа - The Graph subgraphs (Uniswap V3, 5 сетей) — fee/TVL данные, бесплатно
- Dune Analytics API — historical pool data verification (free 2500 CU/мес)
- rug.build API — смарт-контракт scan (бесплатный tier)
- Alchemy RPC — on-chain чтение, multicall3 батчинг
- Across Protocol API — реальная стоимость бриджа
APY-формула (из субграфа, верифицировано):
# Два завершённых часа (пропускаем текущий незакрытый)
apy = (avg_fees_2h / avg_tvl_2h) * 8760 * 100
# Субграф ETH/ARB/POLY:
# poolHourDatas { feesUSD, tvlUSD }
# Субграф BASE/OPT:
# liquidityPoolHourlySnapshots {
# hourlyTotalRevenueUSD,
# totalValueLockedUSD
# }
IL-формула и gas costs:
# Impermanent Loss (V2/classic CFMM):
IL = 2 × √(price_ratio) / (1 + price_ratio) − 1
# Для стейбл-пар: IL = 0
# Impermanent Loss (Uniswap V3 concentrated):
# IL зависит от ширины диапазона [pa, pb]:
# при P → pa: IL ≈ (√(P/pa) − 1) × 2
# Консервативный расчёт ±30% range
# Реальные gas costs (из FlowPulse pip_history.json):
arb: $0.05 × 2 (entry+exit) = $0.10
eth: $0.047 × 2 = $0.09
base: $0.006 × 2 = $0.01
# Breakeven APR:
breakeven_apr = (move_cost / deposit_size) × 100 × (8760 / cooldown_h)
threshold = max(15%, breakeven × 2)
# Smart allocation (portfolio weight):
weight_i = (apy_i × safety_i) / Σ (apy_j × safety_j for j in top10)
Пример output:
{
"scan_time": "2026-05-21T12:00:00Z",
"opportunities": [
{
"pool": "Uniswap V3 ETH-USDC 0.05%",
"chain": "arbitrum",
"gross_apy": "22.4%",
"netto_apy": "18.1%",
"tvl_usd": 14200000,
"pool_age_days": 180,
"audit": "OpenZeppelin + Trail of Bits",
"safety_score": 0.827,
"smart_money_in_pool": true,
"il_estimate": "2.1% (30d projection, ±30% range)",
"gas_cost_10k_usd": "$0.12 entry+exit",
"rug_scan": "PASS",
"signal": "RECOMMEND"
},
{
"pool": "Aave V3 USDC Supply",
"chain": "ethereum",
"gross_apy": "6.8%",
"netto_apy": "6.8%",
"tvl_usd": 890000000,
"audit": "OpenZeppelin + Sigma Prime",
"safety_score": 0.920,
"il_estimate": "0% (stablecoin)",
"signal": "STABLE_BASE"
}
],
"filtered_out": 1243,
"filter_breakdown": {
"apy_threshold": 892,
"tvl_threshold": 201,
"age_threshold": 87,
"audit_fail": 43,
"rug_fail": 20
}
}
Cost model:
DeFiLlama API: $0/мес (полностью бесплатный)
The Graph: $0/мес (бесплатный hosted service)
Dune Analytics: $0/мес (2500 CU/мес free tier покрывает)
rug.build API: $0/мес (бесплатный tier)
Alchemy RPC: входит в общий план
─────────────────────────────────────────────
Итого: ~$0/мес (отдельно от других агентов)
Метрики:
- Pools scanned per run: ~17K (DeFiLlama) → ~34 проходят все 4 фильтра типично
- False positive rate (rugpull в выдаче): ~2% на 90d бэктесте
- Cooldown между recommendations: 4ч (одна и та же возможность не повторяется)
- APY accuracy vs realized: ±15% в первые 7 дней (IL variability)
- Latency scan → TG: < 3 мин (включая все API calls)
Real Trader — твоя стратегия на live-данных без реальных денег
Backtest — это хорошо, но он на исторических данных. Real Trader v2.1 гоняет твою стратегию прямо сейчас, на реальных ценах, реальных сигналах от других агентов, в реальном времени. Без того чтобы потерять настоящие деньги пока проверяешь гипотезу.
Принципиальное отличие от обычного paper trading: агент не игнорирует газ и слиппедж. Каждый «бумажный» переход считается по реальным данным — gas через RPC, слиппедж из pip_history.json (PIP = Price Impact Proxy, симуляция свопа на $100K), бридж через Across Protocol API. Если стратегия не окупает эти расходы — агент это видит.
Архитектура: на входе — сигналы Sentiment Engine (last_crowdpulse.json), Yield Chaser (protocol_opportunities.json), Whale Tracker (TG-алёрты + DB), цены Coingecko/Binance, gas RPC, PIP history, Across bridge costs. На выходе — ежедневный PnL-отчёт в 22:00 МСК → TG + HTML→PDF через Playwright; real_trader_state.json (текущие paper positions). Cadence: event-driven (подписка на очередь сигналов) + daily cron report 19:00 UTC.
Стек:
- Python:
real_trader.pyв FlowPulse (execute_move: remove→bridge→mint моделирование) - PostgreSQL: схема
paper_positions(отдельная от реальных позиций) - Playwright: HTML отчёт → PDF (SCALE=3, через скриншоты)
- FastAPI:
/analytics/flowpulse/paper→ Paper Pools A/B/C статус - Across Protocol API (реальные bridge costs)
- Публичные RPC (publicnode.com) — реальные gas prices
Конфиг стратегии (пример):
strategy:
entry_conditions:
- sentiment_greed: ">= 0.6" # CrowdPulse Greed axis
- yield_apr: ">= 20%" # Yield Chaser signal
- smart_money_in_pool: true # Whale Tracker confirmation
position_size: "10%" # % от paper portfolio
exit_conditions:
stop_loss: "-8%" # от entry value
apr_threshold: "< 8%" # Yield Chaser update
max_duration_days: 30
max_positions: 5
paper_capital_usd: 100000
Источники данных:
- FlowPulse signals (
last_signals.json) — composite_v5, ML routing - CrowdPulse (
last_crowdpulse.json) — 6-осевой sentiment - Across Protocol API — реальные bridge costs (верифицированы 22.02.2026)
- publicnode.com RPC — реальные gas prices (arb ~0.02 gwei, base ~0.006 gwei)
- Coingecko + Binance REST — спот-цены для mark-to-market
TIR (Time-In-Range) формула для LP позиций:
tir_factor = compute_tir_factor(ohlcv_1h, lower_tick, upper_tick)
# Доля часа когда цена была в диапазоне
# Источник: cex_180.json (Binance klines)
hourly_fee = volume_usd × fee_rate × our_liq_share × tir_factor
# Реальная стоимость перемещения:
move_cost = gas_usd + slippage_usd + bridge_usd
# gas: RPC gasPrice × gasLimit
# slippage: pip_history[pool] × PIP_LP_FACTOR(0.02)
# bridge: Across API (arb→eth $5.34, arb→base $3.46)
breakeven_apr = (move_cost / deposit) × 100 × (8760 / cooldown_h)
threshold = max(10%, breakeven × 2)
# P&L:
unrealized_pnl = current_value_usd - entry_value_usd
realized_pnl = exit_value_usd - entry_value_usd - move_cost
cumulative_pnl = sum(realized_pnl) + unrealized_pnl
net_apr = cumulative_pnl / initial_capital × 100 × (365 / days)
Пример output (TG-отчёт):
📊 Real Trader — Daily Report 21.05.2026 22:00 МСК
💼 Paper Portfolio: $100,000
📈 Cumulative PnL: +$12,340 (+12.3%, 45 дней)
📆 Активных позиций: 3 / 5
ОТКРЫТЫЕ ПОЗИЦИИ:
1. arb/ETH-USDC/0.05% $25K — +$847 (+3.4%, 12д)
APR текущий: 18.2% | TIR: 71% | Gas annualized: 0.02%
Signal: FlowPulse composite 1.31 + Sentiment Greed 0.68
2. base/ETH-USDC/0.05% $20K — +$412 (+2.1%, 7д)
APR текущий: 22.4% | TIR: 68%
Signal: Yield Chaser smart money exposure
3. Aave USDC (ETH) $15K — +$203 (+1.4%, 30д)
APR: 6.8% | Stable base, no IL
ЗАКРЫТЫЕ СЕГОДНЯ:
- opt/ETH-USDC/0.3% $10K → EXIT (APR упал до 6.1%, ниже threshold)
PnL: +$89, move cost $2.49 (bridge), нетто: +$86.51
СИГНАЛЫ КОТОРЫЕ ЗАПУСТИЛИ ВХОДЫ СЕГОДНЯ:
- CrowdPulse retail_emotion контрарианский 0.22 → watchlist
- Whale Tracker: 2 адреса зашли в arb/ETH-USDC
Симуляционные результаты (180-дневный бэктест):
- 262% vs 103% passive — annualized APR симуляции composite_v5 vs пассивное держание ETH/USDC LP (FlowPulse sim на $100K за 180d)
- 107 moves, все прибыльные после газа — composite_v5 > 1.0 trigger
- $4,120 газа из $447,594 fees = 0.92% gas overhead total
- Win rate: 78% positive moves / 22% break-even (без отрицательных после costs)
- Avg hold time: 4.2 дня (минимум 24ч cooldown, максимум 30 дней по max_duration)
- Report latency: PDF генерируется за < 45 сек (Playwright SCALE=3)
Cost model:
Вычисление: ~$0/мес (локальные данные других агентов)
Playwright PDF: ~$0/мес (собственный VPS)
Across API: $0/мес (бесплатный)
RPC calls: входит в Alchemy план
─────────────────────────────────────────────
Итого: ~$0/мес (данные от других агентов бесплатны)
Portfolio Tracker — реальный P&L каждые 30 минут
Интерфейсы протоколов показывают «теоретическую доходность» — ту которая была бы если бы ты ни разу не выходил, не платил газ, не было IL. Portfolio Tracker считает реальный P&L: что ты внёс, что вышло, сколько заплатил, сколько стоит сейчас.
Подключение без API ключей протоколов — только адреса кошельков. Агент сам определяет все позиции: LP токены Uniswap V3, aTokens Aave, staked assets, wrapped tokens, GMX GM tokens — через DeBank API + on-chain чтение контрактов через The Graph и Alchemy multicall.
Архитектура: на входе — список кошельков в конфиге, DeBank Cloud API (/user/all_complex_protocol_list), The Graph subgraphs (Uniswap V3 ETH/ARB/BASE), Alchemy alchemy_getAssetTransfers (history), Coingecko API (исторические цены), Chainlink on-chain оракулы. На выходе — таблица P&L в Postgres (обновляется каждые 30 мин) + webapp /miniapp/portfolio + daily summary в TG. Cadence: cron */30 * * * * + update_positions.py systemd service.
Стек:
- DeBank Cloud API — DeFi positions across 90+ chains, 1300+ protocols
- The Graph subgraphs (Uniswap V3): ETH, ARB, BASE —
positions { liquidity, depositedToken0, collectedFeesToken0 } - Alchemy
alchemy_getAssetTransfers— полная история транзакций - Coingecko API
/coins/{id}/market_chart— исторические цены ($29/мес Professional) - Chainlink on-chain оракулы — верификация цен
- PostgreSQL: таблицы
positions,client_wallets,history update_positions.py(~300+ строк) +update_history.py
Источники данных:
- DeBank Cloud API — верифицированный агрегатор DeFi позиций (compute-unit модель)
- The Graph subgraphs Uniswap V3 (ETH/ARB/BASE) — on-chain данные напрямую
- Alchemy transaction history — полная история с декодированием
- Coingecko API — исторические цены ($29/мес Professional plan)
- Chainlink on-chain — независимая верификация цены
IL для V3 (concentrated liquidity, [pa, pb] range):
# Если P в диапазоне [pa, pb]:
# liq_value = 2 × √(P × pa × pb) / (√pb − √pa) × L
# Упрощённый IL при выходе:
il_pct = 2 × √(price_exit / price_entry) / (1 + price_exit/price_entry) - 1
# Консервативная оценка — реальный IL V3 зависит от ширины диапазона
# Для stable/stable пар: IL = 0
# Реальный APR (net) — НЕ gross APY из интерфейса:
real_apr = (fees_collected - gas_total + principal_change)
/ initial_deposit
* 365 * 24
/ hours_elapsed
Структура P&L:
# Нереализованный:
unrealized = current_value_usd - cost_basis_usd - il_estimate_usd
current_value = token0_amount × price0 + token1_amount × price1
cost_basis = initial_deposit_usd (из истории транзакций)
# Реализованный:
realized = exit_value_usd - cost_basis_usd - gas_paid_usd
# При каждом выходе из позиции
# Исторические цены: DeFiLlama /prices/historical/{timestamp}
# Gas overhead:
gas_per_position = sum(gas_used × gas_price × eth_price_usd)
for tx in position_transactions
netto_pnl = unrealized_pnl + realized_pnl - gas_overhead
Rebase tokens и fee-earning positions:
- aTokens (Aave) — растут в балансе без транзакций (rebase). Tracker отслеживает через DeBank:
balance растёт = нереализованный доход, исторические значения через snapshot каждые 30 мин - Uniswap V3 fees — накапливаются внутри позиции до
collect(). Tracker читает через subgraph:collectedFeesToken0/1(реализованные) +uncollectedFeesToken0/1(накопленные) - stETH/wstETH — stETH делает rebase, wstETH — нет. Tracker нормализует к ETH-equivalent через conversion rate
- GMX GLP/GM — earnings tracking через
claimableRewards()on-chain call
Пример output:
{
"wallet": "0x742d...f3c2",
"updated_at": "2026-05-21T14:30:00Z",
"total_value_usd": 94820,
"total_unrealized_pnl": 8340,
"total_realized_pnl": 3210,
"total_gas_overhead": 412,
"netto_pnl": 11138,
"netto_apr_annualized": "18.2%",
"positions": [
{
"protocol": "Uniswap V3",
"chain": "arbitrum",
"pair": "ETH-USDC",
"fee_tier": "0.05%",
"deposited_usd": 25000,
"current_value_usd": 26847,
"fees_collected_usd": 1203,
"il_estimate_usd": -356,
"gas_usd": -18,
"unrealized_pnl": 1847,
"netto": 2676,
"in_range": true,
"tir_30d": "71%"
},
{
"protocol": "Aave V3",
"chain": "ethereum",
"asset": "aUSDC",
"deposited_usd": 15000,
"current_value_usd": 15203,
"fees_collected_usd": 203,
"il_estimate_usd": 0,
"gas_usd": -4,
"unrealized_pnl": 203,
"netto": 199,
"apr_current": "6.8%"
}
]
}
Cost model:
DeBank Cloud API: ~$0–30/мес (compute units, по кол-ву адресов)
Coingecko Professional: $29/мес (исторические цены)
Alchemy (transfers): входит в план
Chainlink on-chain: $0/мес (бесплатно, on-chain вызовы)
─────────────────────────────────────────────
Итого: ~$29–59/мес
Метрики:
- Update latency: < 5 мин от on-chain события до обновления в DB
- Price accuracy: ±0.1% vs on-chain оракулов (Chainlink cross-check)
- IL estimation error: ±15% vs realized (V3 range complexity)
- Historical coverage: полная история с момента первой транзакции кошелька
- Supported chains: ETH, ARB, BASE (Uniswap V3) + SUI (Cetus, NAVI) + GMX V2
collectedFeesToken0/1 + uncollectedFeesToken0/1. Без этого учёта реальный P&L занижается на 5–15%.Mempool Service — сделки до того, как они попали в блок
Подтверждённая транзакция — это прошлое. Когда ты видишь tx в Etherscan, рынок уже знает. Mempool Service видит транзакции в момент broadcast — до майнинга, до подтверждения, до того как кто-то успел среагировать.
Mempool существует только внутри ноды. Alchemy WebSocket открывает доступ к pending транзакциям, которые прошли через инфраструктуру Alchemy. Это не полный мемпул сети — это ~60–70% от публичного флоу. Специализированные системы (Flashbots relay, bloXroute) видят больше, но стоят $500+/мес. Для наших целей Alchemy покрывает крупные транзакции (они видны сразу на множестве нод).
Архитектура: на входе — Alchemy WebSocket alchemy_pendingTransactions (ETH mainnet), ABI декодирование calldata (Uniswap V2/V3/V4, Curve, Balancer, Aave routers), список адресов из Whale Tracker. На выходе — Telegram алёрт (< 5 сек от broadcast) + подтверждающий апдейт после inclusion в блок + статус dropped (через 30 мин таймаут). Cadence: realtime WebSocket (persistent connection, reconnect on error).
Стек:
- Alchemy WebSocket API (
wss://eth-mainnet.g.alchemy.com/v2/{key}) alchemy_pendingTransactions— фильтр до 1000 адресов (whale list)eth_subscribe("newPendingTransactions")— для generic фильтров- Python: web3.py + asyncio + websockets
- ABI decoder: собственный (Uniswap V3/V4 + Curve + Balancer сигнатуры)
- PostgreSQL:
mempool_log(pending tx + confirmation status) - Telegram Bot API: async push < 5 сек
ABI decode для 4 роутеров:
# Uniswap V3 SwapRouter (0xE592...6317):
exactInputSingle((tokenIn, tokenOut, fee, recipient,
deadline, amountIn, amountOutMinimum,
sqrtPriceLimitX96))
# Uniswap V4 PoolManager:
swap(PoolKey, SwapParams, hookData)
# Curve StableSwap / CryptoSwap:
exchange(i, j, dx, min_dy)
exchange_underlying(i, j, dx, min_dy)
# Balancer Vault:
batchSwap(kind, swaps[], assets[], funds, limits[], deadline)
# Aave V3 Pool:
supply(asset, amount, onBehalfOf, referralCode)
borrow(asset, amount, interestRateMode, ...)
4 типа фильтров:
- Large Swap — DEX swap > $500K USD в одной транзакции; особый интерес: малоликвидные пары (TVL < $5M при сумме > $200K)
- New LP — addLiquidity > $200K USD через router DEX; интерес: первые крупные LP в пулах моложе 7 дней
- Suspicious Approve —
ERC-20 approve(spender, type(uint256).max)WHERE spender NOT IN known_protocols_db AND token_contract.age < 30d → признак подготовки к крупной операции или потенциального exploit - Wallet List Hit — from_address ∈ whale_watchlist_100 OR to_address ∈ whale_watchlist_100 → любая pending tx от кита, минимальная сумма $50K
Источники данных:
- Alchemy WebSocket — единственный доступный публичный pending tx stream на ETH mainnet через web API
- Alchemy фильтр по адресам — до 1000 адресов, только ETH mainnet + Sepolia (L2 не поддерживается)
- BlockNative [одиночный, deprecated] — специализированный mempool API, см. предупреждение ниже
- bloXroute Networks — альтернатива на blocknet-уровне, ~$500+/мес enterprise plan
- Coingecko price cache — для USD value pending tx (TTL 5 мин)
Latency budget (200–700ms total от broadcast):
- WebSocket receive: ~50–200ms (от ноды Alchemy до твоего сервера)
- ABI decode: ~5ms (локально, без сетевых вызовов)
- Price lookup (cache hit): ~1ms (Redis/in-memory)
- Price lookup (cache miss): ~150–300ms (Coingecko REST)
- Filter evaluation: ~2ms (in-memory)
- TG push: ~100–500ms (Telegram Bot API)
- Total: ~200–700ms от broadcast до push в твоём чате
Ключевые формулы:
# USD value pending tx (Uniswap V3 exactInputSingle):
amount_in = decoded_calldata["amountIn"]
token_in = decoded_calldata["tokenIn"]
price_usd = coingecko_cache[token_in] # кэш 5 мин
usd_value = amount_in / 10**decimals * price_usd
# Dropped tx detection:
if tx_hash not confirmed after 30 min:
send_tg_update("⚠️ TX DROPPED: {tx_hash}")
update_mempool_log(status="dropped")
Пример TG-алёрта:
⚡ MEMPOOL ALERT — Large Swap [PENDING]
Протокол: Uniswap V3
Пара: WBTC → USDC (0.3% fee)
Сумма: 45.2 WBTC (~$3.12M)
Адрес: 0x89aB...d4f1 [Smart Money: Fund]
Router: 0xE592...6317 (Uniswap V3 SwapRouter)
Gas: 52 gwei (max), gasLimit 185,000
Ожидаемый impact: ~0.8% на WBTC/USDC
⏱ Broadcast: 14:23:07.412 UTC
🔗 Etherscan pending: https://etherscan.io/tx/0xabc...
▶️ Статус: PENDING — ждём включения в блок
---
[14:23:19 UTC] ✅ ПОДТВЕРЖДЕНО в блоке #21,847,342
Исполнено за: 12 секунд от broadcast
Cost model:
Alchemy WebSocket: входит в план (~$0–15/мес доп. нагрузка)
Decode compute: $0/мес (локально, < 1ms/tx)
TG Bot API: $0/мес (бесплатно)
BlockNative (альт.): pricing по запросу — но shutdown 19.06.2026
bloXroute (альт.): ~$500+/мес enterprise
─────────────────────────────────────────────
Итого: ~$0–15/мес (входит в Alchemy план)
Метрики:
- Latency broadcast → TG push: < 5 сек при нормальной нагрузке (200–700ms реально)
- False positive rate: ~12–18% dropped/replaced transactions
- Coverage: ~60–70% публичного мемпула через Alchemy ноды
- ABI decode success rate: > 95% для Uniswap V3/V4, Curve, Balancer
- Whale list hit accuracy: 100% (детерминированный фильтр по адресам)
[PENDING] и присылает подтверждение после inclusion в блок (или [DROPPED] через 30 мин). Не принимай торговых решений только на основе pending tx без подтверждения — особенно при высокой нагрузке сети.Data Auditor — сверяет всех агентов каждые 6 часов
Шесть агентов работают 24/7. Каждый тянет данные из внешних API, пишет в Postgres, генерирует сигналы. А что если один из них начал врать? Завис API, поехал парсер, устарела ABI — агент продолжает работать, но данные стали мусором. Data Auditor — это контроль качества всего офиса.
Это не мониторинг серверов (uptime). Это контроль качества данных. Сервер может быть alive, CrowdPulse может запускаться каждый час — но если SocialData API вернул 0 твитов и агент записал в DB null sentiment, сигналы стали мусором. Data Auditor это видит.
Архитектура: на входе — PostgreSQL (все агентские таблицы), Alchemy eth_getTransactionByHash (on-chain верификация), Coingecko API + Chainlink оракул + Binance REST (price cross-check), last_crowdpulse.json + last_signals.json (freshness check). На выходе — запись в audit_log + ежедневный health-summary в 09:00 МСК → TG + авто-пауза агента при error. Cadence: cron 0 */6 * * * + немедленный алёрт при error.
Стек:
- Python:
data_auditor.pyв FlowPulse (~100 проверок, 10 секций) - PostgreSQL: таблица
audit_log(agent, check_type, expected, actual, delta, status, timestamp) - Alchemy REST API:
eth_getTransactionByHashдля on-chain верификации - Coingecko API + Binance REST + Chainlink on-chain (price cross-check)
- Telegram Bot: health-summary + instant alerts
SQL-схема audit_log:
CREATE TABLE audit_log (
id SERIAL PRIMARY KEY,
ts TIMESTAMPTZ DEFAULT NOW(),
agent VARCHAR(50),
check_type VARCHAR(50), -- 'onchain' | 'price_cross' | 'freshness'
expected NUMERIC,
actual NUMERIC,
delta_pct NUMERIC,
status VARCHAR(10), -- 'ok' | 'warn' | 'error'
detail JSONB
);
CREATE INDEX ON audit_log (ts, agent, status);
CREATE INDEX ON audit_log (ts DESC);
CREATE INDEX ON audit_log (status, ts DESC) WHERE status != 'ok';
3-уровневая сверка:
- Уровень 1 — On-chain верификация (3-way reconciliation): выборка 5 случайных tx из
whale_activity_logза последние 6ч + 5 случайных позиций из Portfolio Tracker → сравнениеdb_valuevseth_getTransactionByHash().value, threshold delta > 0.01% →error+ auto-pause агента - Уровень 2 — Cross-source price check: для каждого asset (ETH, BTC, USDC, ARB, OP) → опрашиваем Coingecko + Chainlink on-chain + Binance REST. Spread > 2% →
warn+ identify outlier source - Уровень 3 — Freshness check: для каждого агента читаем last write timestamp в DB, сравниваем с threshold (sentiment 20мин, whale 5мин, yield 5ч, portfolio 35мин, mempool 10мин, real_trader 120мин). Превышение → auto-pause + TG-alert
Источники данных:
- PostgreSQL (собственная DB) — исходные данные агентов
- Alchemy
eth_getTransactionByHash— on-chain truth - Coingecko + Binance REST + Chainlink — три независимых источника цен
Python-псевдокод проверок:
# Уровень 1 — On-chain верификация:
sample = random.sample(whale_activity_log_last_6h, k=5)
for record in sample:
db_value = record.usd_value
chain_tx = alchemy.eth_getTransactionByHash(record.tx_hash)
chain_value = chain_tx.value × eth_price_at_tx_time
delta = abs(db_value - chain_value) / chain_value
if delta > 0.0001: # 0.01%
log_audit(status="error",
agent="whale_tracker",
expected=chain_value,
actual=db_value,
delta=delta)
trigger_agent_pause("whale_tracker")
# Уровень 2 — Cross-source price check:
for asset in ["ETH", "BTC", "USDC", "ARB", "OP"]:
sources = {
"coingecko": coingecko_api_price(asset),
"chainlink": onchain_chainlink_price(asset),
"binance": binance_rest_price(asset),
}
max_spread = max(sources.values()) / min(sources.values()) - 1
if max_spread > 0.02: # 2%
outlier = find_outlier(sources)
log_audit(status="warn",
agent="portfolio_tracker",
detail={"asset": asset,
"spread": max_spread,
"outlier": outlier})
# Уровень 3 — Freshness check:
freshness_thresholds = {
"sentiment_engine": 20, # мин
"whale_tracker": 5, # мин
"yield_chaser": 300, # мин (5ч)
"portfolio_tracker": 35, # мин
"mempool_service": 10, # мин
"real_trader": 120, # мин (ежедневный отчёт OK)
}
for agent, threshold in freshness_thresholds.items():
last_write = get_last_db_write(agent)
age_min = (now - last_write).seconds / 60
if age_min > threshold:
auto_pause_agent(agent)
send_tg_alert(f"{agent} STALE: {age_min:.0f}min > {threshold}min")
Пример output:
{
"audit_run": "2026-05-21T06:00:00Z",
"status": "WARN",
"summary": {
"ok": 87,
"warn": 3,
"error": 0
},
"details": [
{
"agent": "sentiment_engine",
"check": "freshness",
"status": "ok",
"last_write_min_ago": 8,
"threshold_min": 20
},
{
"agent": "portfolio_tracker",
"check": "price_cross",
"status": "warn",
"detail": "Coingecko ETH price $3,142 vs Chainlink $3,205 (delta 2.0%) — Coingecko outlier"
},
{
"agent": "whale_tracker",
"check": "onchain",
"status": "ok",
"verified_txs": 5,
"max_delta_pct": 0.0003
}
],
"paused_agents": [],
"next_run": "2026-05-21T12:00:00Z"
}
Cost model:
Alchemy (verification calls): входит в план
(~10 calls per run × 4 runs/day)
Coingecko API: входит в план Portfolio Tracker
Binance REST: $0/мес (бесплатно)
Chainlink on-chain: $0/мес (RPC вызовы)
─────────────────────────────────────────────
Итого: ~$0/мес (отдельно)
Метрики:
- Checks per run: ~100 (10 секций × ~10 проверок каждая)
- Run latency: < 3 мин (параллельные запросы asyncio)
- False positive rate (warn без реальной проблемы): < 5% (price cross при высокой волатильности)
- Detection rate: 100% для freshness failures (детерминированная проверка)
- Auto-pause precision: 98% (2% — ложные паузы при временных API timeouts)
agent_paused = true в конфиге. Сигналы агента игнорируются downstream (Real Trader не принимает решения, Portfolio Tracker не обновляет цены). Сам процесс продолжает работать и логировать — это помогает диагностировать причину. Рестарт: ручная команда через TG-бота после диагностики.Архитектура оркестрации — как 7 агентов общаются
Семь агентов — не семь изолированных скриптов. Они читают данные друг друга, передают сигналы, блокируют downstream при ошибках. Понять оркестрацию — значит понять, как система в целом остаётся целостной при сбое любого одного агента.
Три механизма коммуникации:
- SharedDB (PostgreSQL) — основной канал. Каждый агент пишет в свои таблицы. Другие агенты читают напрямую из DB, не через API. CrowdPulse пишет
last_crowdpulse.json→ FlowPulse/Real Trader читают через файл. Portfolio Tracker пишетpositions→ Webapp читает через FastAPI. Whale Tracker пишетwallet_labels→ Yield Chaser проверяет smart money exposure. Data Auditor читает все таблицы для freshness check. - Signal Files (JSON) — быстрый канал между агентами. Атомарная запись через временный файл + rename. Лёгкое чтение без подключения к БД, удобно для cron-агентов.
- Telegram Bot — user-facing оркестрация. Atlas bot (
@defi_cap_bot, 30 tools) читает все агентские данные через FastAPI. Команды: рестарт агента, изменение порогов, запрос статуса.
Signal Files (потоки данных):
/root/brain/crowdpulse/data/last_crowdpulse.json
← пишет: CrowdPulse каждый час (cron :10)
→ читает: FlowPulse (load_crowdpulse()), Real Trader
/root/brain/flowpulse/data/last_signals.json
← пишет: FlowPulse каждые 30 мин
→ читает: CrowdPulse collector (collectors/flowpulse.py),
Real Trader
/root/brain/flowpulse/data/protocol_opportunities.json
← пишет: Yield Chaser каждые 4ч
→ читает: Real Trader (entry signal),
Data Auditor (freshness)
/root/brain/flowpulse/data/paused_protocols.json
← пишет: Exploit Monitor (15 мин check)
→ читает: Yield Chaser (skip paused),
Real Trader (skip entry)
/root/brain/flowpulse/data/whale_180.json
← пишет: Whale Tracker (rolling 180 дней)
→ читает: CrowdPulse smart_positioning,
Portfolio Tracker (context enrichment)
ASCII-диаграмма системы:
┌─────────────────────────────────────────────────────────────┐
│ CRON SCHEDULE │
│ :10 every hour :30 every 30min */4h */6h daily │
│ │ │ │ │ │ │
│ CrowdPulse FlowPulse YieldChaser Auditor Rpt │
│ (Sentiment) (Signals v6.5) (Pools v4.2) (3-way) TG │
└──────┬──────────────────┬────────────┬───────┬──────────────┘
│ │ │ │
▼ ▼ ▼ │
┌──────────────┐ ┌──────────────┐ ┌──────┐ │
│last_crowd- │ │last_signals │ │proto_│ │
│pulse.json │ │.json │ │opps │ │
└──────┬───────┘ └──────┬───────┘ │.json │ │
│ │ └──┬───┘ │
└─────────────────┴─────────────┘ │
│ │
┌────────▼─────────┐ │
│ Real Trader v2.1│ │
│ (Paper Trading) │ │
└────────┬─────────┘ │
│ │
┌────────▼──────────────────┐ │
│ PostgreSQL (SharedDB) │◄─┘
│ positions / audit_log / │
│ wallet_labels / signals │
└────────┬──────────────────┘
│
┌──────────┼──────────────┐
▼ ▼ ▼
┌──────────┐ ┌──────────┐ ┌──────────┐
│ Whale │ │Portfolio │ │ Mempool │
│ Tracker │ │ Tracker │ │ Service │
│ (WS sub) │ │ (30min) │ │ (WS live)│
└──────┬───┘ └────┬─────┘ └─────┬────┘
│ │ │
└──────────▼─────────────┘
│
┌────────▼──────────┐
│ Telegram Bot │
│ (Atlas v2.2) │
│ 30 tools │
└───────────────────┘
Мониторинг живости агентов:
- Data Auditor freshness check (каждые 6ч) — если агент не писал дольше порога → авто-пауза + TG-алёрт
- API Health checker (
api_health.py) — 14 сервисов, threads, 60-секундный кэш. Endpoint:GET /api/health - Morning Brief — ежедневно в 07:30 МСК Telethon отправляет сводку состояния системы в TG-группу «Управление» / topic 4
- Webapp Agent Dashboard — 20 агентов, 7 групп, live статус из
agent_status.py - Systemd service — все long-running агенты (Whale Tracker, Mempool Service) под systemd с auto-restart
- Heartbeat в TG-канал «Системные» каждые 30 мин — короткий ping от orchestrator
$200–250/мес — постатейно
Не «примерно двести долларов». Постатейно: кому платишь, за что, сколько, и где можно сэкономить.
Базовый бюджет ($59–99/мес) — для 1–2 кошельков:
- VPS (Hostman, 4 CPU / 8GB RAM / 100GB SSD) — $15–20/мес. Сервер 194.87.151.253 для всех агентов
- Alchemy Pay-as-You-Go — $0–15/мес. 30M CU/мес бесплатно, доп. нагрузка ~0.45$/M CU × 20–30M CU
- Coingecko Professional — $29/мес. Historical prices +
/coins/{id}/market_chart - SocialData.tools (Twitter/X) — ~$1.5/мес. 20 CT-инфлюенсеры + retail keywords (~$0.04/день)
- DeBank Cloud API — $10–30/мес. DeFi positions (compute-unit модель), ~50 адресов × 2 раза/час
- Claude API + DeepSeek (LLM) — $3.5/мес. Haiku 4.5 каждые 4ч ($0.40) + Sonnet daily ($1.5) + DeepSeek hourly ($1.4)
- Dune Analytics — $0/мес (2500 кредитов/мес free tier)
Полная нагрузка ($200–250/мес) — для 10+ кошельков:
- VPS upgrade до 8 CPU / 16GB — $30–40/мес
- Alchemy расширенный WebSocket usage — $60–100/мес (увеличенное покрытие мемпула + L2 polling)
- Coingecko Professional + Pro — $29–129/мес (при увеличенном rate limit)
- DeBank Cloud (compute units выше) — $50–80/мес (50+ адресов × частые обновления)
- SocialData.tools расширенный — $5/мес (50 инфлюенсеров вместо 20)
- Claude API расширенный — $10–15/мес (больше Sonnet вызовов для daily premium analytics)
- Backup CDN / S3 archive — $5/мес (исторические данные)
Полный budget breakdown (полная нагрузка):
ИНФРАСТРУКТУРА:
┌─────────────────────────────────────────────────┐
│ VPS (DeFiCap server, 194.87.151.253) │
│ 4 CPU / 8GB RAM / 100GB SSD │
│ Hostman ~$15–20/мес │
├─────────────────────────────────────────────────┤
│ Alchemy Pay-as-You-Go │
│ 30M CU/мес бесплатно │
│ доп. нагрузка ~0.45$/M CU × 20–30M │
│ ~$0–15/мес │
├─────────────────────────────────────────────────┤
│ Dune Analytics API │
│ Free tier: 2500 кредитов/мес │
│ $0/мес │
└─────────────────────────────────────────────────┘
ДАННЫЕ:
┌─────────────────────────────────────────────────┐
│ Coingecko API Professional │
│ Historical prices │
│ $29/мес │
├─────────────────────────────────────────────────┤
│ SocialData.tools (Twitter/X) │
│ ~$0.04/день ~$1.5/мес │
├─────────────────────────────────────────────────┤
│ DeBank Cloud API │
│ ~50 адресов × 2 раза/час ~$10–30/мес │
└─────────────────────────────────────────────────┘
LLM:
┌─────────────────────────────────────────────────┐
│ Claude API (via OpenRouter) │
│ - Haiku 4.5 каждые 4ч ~$0.40/мес │
│ - Sonnet daily 30 запросов ~$1.5/мес │
│ Итого Claude: ~$2/мес │
├─────────────────────────────────────────────────┤
│ DeepSeek Chat (hourly) │
│ 720 запросов × 800 токенов ~$1.4/мес │
└─────────────────────────────────────────────────┘
ПРОЧИЕ (бесплатно или включено):
┌─────────────────────────────────────────────────┐
│ DeFiLlama API $0 (open source) │
│ Binance/Bybit/OKX REST $0 (public) │
│ The Graph subgraphs $0 (free hosted) │
│ FRED API $0 (free) │
│ CoinMetrics Community $0 (free tier) │
│ Reddit API $0 (free tier) │
│ Etherscan v2 $0 (free tier) │
│ Chainlink on-chain $0 (RPC call) │
│ Across Protocol API $0 (free) │
│ rug.build scan $0 (free tier) │
└─────────────────────────────────────────────────┘
ИТОГО (базовый):
─────────────────────────────────────────────────
VPS: $15–20
Alchemy: $0–15
Coingecko: $29
SocialData: $1.5
DeBank: $10–30
Claude+DeepSeek: $3.5
─────────────────────────────────────────────────
TOTAL: $59–99/мес (базовый)
~$200–250/мес (при полной нагрузке)
Сравнение с коммерческими SaaS-аналитиками:
- Nansen Standard — $99/мес (фиксированные метки Smart Money, без кастомизации)
- Nansen VIP — $1899/мес (real-time API + расширенные метки)
- Glassnode Advanced — $799/мес (on-chain метрики, без DeFi-позиций)
- Dune Teams — $349/мес (расширенные кредиты для SQL)
- Coingecko Analyst — $129/мес (исторические + расширенные данные)
- Token Terminal — $399/мес (Pro plan)
- DeFi-аналитик-фриланс — $2000–5000/мес (8ч в день, выходные не работает)
- Итого SaaS-стек — $3000–7000/мес за меньшее покрытие и без персонализации под твой портфель
Где сэкономить, если нужно:
- Coingecko $29 → CoinMetrics Community $0 — только основные активы, нет произвольных исторических цен
- DeBank $10–30 → The Graph напрямую $0 — только Uniswap V3, ручная логика для каждого протокола
- Alchemy $0–15 → publicnode.com $0 — нет WebSocket для мемпула, задержка выше
- SocialData $1.5 → Reddit API только $0 — потеря Twitter coverage для sentiment
- Claude+DeepSeek $3.5 → только DeepSeek $1.4 — потеря premium daily report качества
Как добавить 8-го агента — расширение за выходные
Система спроектирована для расширения. SharedDB, signal files, Data Auditor с freshness checks, Telegram bot — всё это уже работает. Добавить 8-го агента значит: написать один Python-файл, добавить cron-строку, добавить запись в freshness_thresholds.
Алгоритм добавления (5 шагов):
- СПЕЦИФИКАЦИЯ (2–3 часа) — Ответь на 5 вопросов: что мониторит (входной сигнал)? что детектирует (условие срабатывания)? что выдаёт (output: JSON / TG / DB)? как часто работает (cadence)? каким агентам нужны его данные (downstream)?
- MVP (1 день) — Один Python-файл:
fetch → parse → filter → output. Пишет JSON-файл вdata/(не сразу в DB). Тестируешь руками:python3 agent_name.py --test. Задача: работающий артефакт без интеграций. - ИНТЕГРАЦИЯ (2–4 часа) — Добавляешь cron-строку в
crontab. Добавляешь вfreshness_thresholdsData Auditor. Добавляешь запись вagent_status.py(dashboard). Опционально: FastAPI endpointGET /analytics/{agent_name}. - DOWNSTREAM CONNECTIONS (1–2 часа) — Если агент нужен Real Trader — добавляешь его output в
entry_conditionsконфига стратегии. Если нужен CrowdPulse — добавляешь collector вcollectors/+ вес вconfig.py. Добавляешь в Morning Brief (Telethon). - МОНИТОРИНГ (30 мин) — Data Auditor автоматически начинает мониторить через freshness check. Проверяешь в webapp Agent Dashboard. Настраиваешь TG-алёрт при
errorстатусе.
Пример 1 — NFT Tracker:
Краткий бриф: мониторинг NFT-коллекций из watchlist, push-алёрт при whale accumulation, floor drop, smart money entry в новой коллекции.
agent: NFT Tracker
version: 1.0
spec:
monitors: NFT коллекции из watchlist
detects:
- Whale accumulation (> 10 NFT за 24ч одним адресом)
- Floor price drop > 30% за 4ч
- New collection listing с smart money в первых buyers
cadence: каждые 30 минут
output: TG алёрт + nft_signals.json
stack:
- Alchemy NFT API (getFloorPrice, getNFTsForContract)
- OpenSea API (sales events, /events endpoint)
- Reservoir API (cross-marketplace aggregation)
- The Graph (ERC-721 transfer events)
data_sources:
- Alchemy NFT API: $0 (входит в план)
- Reservoir API: $0 (free tier, 1000 req/мес)
- OpenSea API: $49/мес (Starter)
freshness_threshold: 35 минут
downstream: Real Trader (опц., если хочешь paper trade NFT)
estimated_cost: $0–49/мес
estimated_dev_time: 1 выходной (~8ч)
Пример 2 — Tokenomics Auditor:
Краткий бриф: мониторинг unlock schedules, insider dump patterns, governance attacks по токенам из портфеля и watchlist.
agent: Tokenomics Auditor
version: 1.0
spec:
monitors: токены в портфеле и watchlist
detects:
- Unlock schedule (команда разблокирует > 5% supply)
- Insider dump pattern (крупные holders снижают долю)
- Governance attack (whale аккумулирует voting power)
cadence: каждые 24ч
output: weekly digest в TG
stack:
- Dune Analytics SQL (token_holders, vesting schedules)
- DeFiLlama Tokens API
- CoinMetrics Community (supply metrics)
- Alchemy token transfers
data_sources:
- Dune free tier: $0 (2500 кредитов/мес — достаточно)
- DeFiLlama: $0 (бесплатно)
- CoinMetrics: $0 (бесплатно)
freshness_threshold: 28 часов
downstream: Sentiment Engine (новая ось governance_risk),
Real Trader (skip entry на токены с unlock < 7d)
estimated_cost: $0/мес
estimated_dev_time: 1 выходной (~6ч)
$250/мес vs $20K аналитик — выбор сделан
- Sentiment Engine — знаешь настроение рынка по своим монетам раньше, чем оно стало «общим местом» в лентах. С IC-весами, а не интуицией
- Whale Tracker — видишь движение крупных игроков за минуты, а не когда оно уже отразилось в цене. Pending tx, до блока
- Yield Chaser — не пропускаешь реальные возможности выше 15% APR. Нетто, с газом и IL — не gross из интерфейса протокола
- Real Trader — проверяешь логику стратегии на живом рынке с реальными costs без риска. 30 дней симуляции стоит $0
- Portfolio Tracker — знаешь свой реальный P&L с газом, IL и выходами. А не «теоретическую доходность», которую показывает Uniswap
- Mempool Service — получаешь информацию о крупных сделках до подтверждения блока. 200–700мс от broadcast до push
- Data Auditor — уверен, что предыдущие шесть агентов не врут. 3-way reconciliation каждые 6ч, авто-пауза при расхождении
- $60–250/мес — реальные цифры, постатейно. Нижняя граница при минимальной нагрузке — $60
$200–250 в месяц против $20 000+ за DeFi-аналитика-человека — это уже не «AI-эксперимент», это просто инфраструктура. Как VPS или база данных. Включаешь и работает.
Для сравнения: $5K/мес SaaS-аналитика (Nansen VIP $1899 + Glassnode Advanced $799 + Dune Teams $349 + Coingecko Analyst $129 + Token Terminal Pro $399 + прочее) даёт тебе красивые дашборды. Но не знает твоих кошельков, не считает твой реальный P&L с твоим газом, не симулирует твою стратегию на твоих сигналах. Наш стек персонализирован под тебя — это принципиальное отличие.
И ещё: аналитик-человек работает 8 часов в день, берёт выходные, болеет. Mempool Service не берёт выходных. Data Auditor не болеет. Whale Tracker работает, пока ты спишь. 7 агентов × 24/7 × 365 — это 61 320 «рабочих часов» в год за $250/мес. В человеко-часах фриланс-аналитика по $50/ч это эквивалент $3 млн в год.
VPS $15–20 · Alchemy $0–15 · Coingecko Professional $29 · SocialData $1.5 · DeBank Cloud $10–30 · Claude + DeepSeek LLM $3.5 · прочие API $0 (бесплатно).
Итого: $59–99/мес (базовый, 1–2 кошелька), ~$200–250/мес (при высокой нагрузке Portfolio Tracker, 10+ кошельков).
Альтернативы: Nansen VIP $1899/мес · Glassnode Advanced $799/мес · DeFi-аналитик фриланс $2000–5000/мес. SaaS-стек суммарно $3000–7000/мес — за меньшее покрытие.
Забери архитектуру каждого + DB-схему + prompt для каждого агента
Внутри — схемы агентов, системные промпты, DB-schema (все таблицы с типами), конфиги порогов, Dune-запросы для smart money верификации, formulas для IL и APY, инструкция по деплою на VPS за один вечер.
Открыть в Telegram →