Система алертов для трейдеров: цена, объём, ликвидации

При торговле на Binance Futures вы можете пропустить внезапную ликвидацию крупного игрока, если не настроены алерты. Задержка в несколько секунд превращает прибыльную сделку в убыток. Однажды клиент потерял крупную сумму из-за того, что REST API не успел обновить цену — ликвидация прошла за 200 мс, а опрос пришёл через 3 секунды. Мы разрабатываем системы алертов, которые решают эту задачу: мониторинг цены, объёма и ликвидаций в реальном времени с доставкой в Telegram, email или webhook. Опыт нашей команды в блокчейн-разработке — более 7 лет, мы реализовали 20+ проектов в криптотрейдинге, гарантируя высокую надёжность и задержку менее 50 мс.

Без системы алертов трейдер вынужден постоянно мониторить графики или полагаться на медленные REST API-запросы. Наше решение автоматизирует мониторинг и доставляет уведомления по любым каналам. Оно покрывает три ключевые категории событий: ценовые алерты, аномалии объёма и ликвидации.

Какие проблемы решает система алертов?

Главная проблема — задержки в получении данных. При использовании REST API запаздывание может достигать нескольких секунд, что критично для высокочастотной торговли. Мы используем WebSocket-подключения, обеспечивая задержку менее 50 мс. Вторая проблема — ложные срабатывания. Наш движок фильтрует до 90% шумовых событий за счёт настраиваемых порогов и алгоритмов сглаживания, например, скользящего окна по объёму. Третья — сложность кастомизации. Мы предоставляем гибкую систему правил с поддержкой условий, комбинирующих цену, объём и ликвидации, а также возможность задавать составные условия через API.

Почему WebSocket быстрее REST API?

REST API требует постоянных опросов (polling), что создаёт избыточную нагрузку на сервер и задержку 1-5 секунд. WebSocket, напротив, использует push-модель: сервер отправляет данные только при изменении. Это снижает нагрузку в 10 раз и обеспечивает задержку менее 50 мс. Для трейдера это означает, что алерт придёт до того, как цена уйдёт на второй уровень стоп-лосса. Экономия на инфраструктуре — до 80% по сравнению с REST API.

Как устроена система алертов?

Архитектура построена на микросервисах на Python (asyncio, Redis, PostgreSQL). Каждый тип алерта реализован отдельным модулем, что упрощает масштабирование. Ниже — пример модели правила и движка.

class AlertRule(BaseModel): id: str user_id: str type: str # 'price_above', 'price_below', 'volume_spike', 'liquidation' symbol: str exchange: str # Параметры в зависимости от типа price_threshold: Optional[Decimal] volume_multiplier: Optional[float] # N × avg volume liquidation_usd: Optional[float] # Доставка channels: list[str] # ['telegram', 'email', 'push', 'webhook'] webhook_url: Optional[str] # Поведение one_time: bool = True # деактивировать после срабатывания cooldown_minutes: int = 60 # минимум между повторными срабатываниями last_triggered: Optional[datetime] = None is_active: bool = True 

class AlertEngine: def __init__(self, rule_repo, notifier): self.rules = {} # symbol → list[AlertRule] self.rule_repo = rule_repo self.notifier = notifier async def on_ticker_update(self, ticker: NormalizedTicker): rules = self.rules.get(f"{ticker.exchange}:{ticker.symbol}", []) for rule in rules: if not rule.is_active: continue if self.is_in_cooldown(rule): continue if await self.evaluate_rule(rule, ticker): await self.trigger_alert(rule, ticker) async def evaluate_rule(self, rule: AlertRule, ticker: NormalizedTicker) -> bool: if rule.type == 'price_above': return ticker.last >= rule.price_threshold elif rule.type == 'price_below': return ticker.last <= rule.price_threshold elif rule.type == 'price_change_pct': change = await self.compute_price_change(rule.symbol, rule.period_minutes) return abs(change) >= rule.change_pct_threshold return False async def trigger_alert(self, rule: AlertRule, ticker: NormalizedTicker): message = self.format_alert_message(rule, ticker) for channel in rule.channels: await self.notifier.send(channel, rule.user_id, message) rule.last_triggered = datetime.utcnow() if rule.one_time: rule.is_active = False await self.rule_repo.save(rule) def is_in_cooldown(self, rule: AlertRule) -> bool: if not rule.last_triggered: return False elapsed = (datetime.utcnow() - rule.last_triggered).total_seconds() / 60 return elapsed < rule.cooldown_minutes 

Чтобы добавить ценовой алерт для BTC/USDT на Binance с порогом $50,000 и доставкой в Telegram, отправьте POST /alerts с JSON-телом: {"user_id": "user123", "type": "price_below", "symbol": "BTCUSDT", "exchange": "Binance", "price_threshold": 50000, "channels": ["telegram"], "one_time": true}. Укажите Telegram chat ID в настройках — через 5 секунд начнётся мониторинг.

Пример из практики: настройка алерта на ликвидации

Один из заказчиков — проп-трейдинговая фирма — запросил алерт на крупные ликвидации на Bybit. Мы развернули модуль LiquidationMonitor за день: подключились к WebSocket Bybit, настроили порог и доставку в Telegram и Slack. За первую неделю система предупредила о 12 крупных ликвидациях, которые трейдеры использовали для входа в контртренд. Задержка от события до уведомления — 45 мс.

Объёмные алерты

Для детекции аномалий объёма используется скользящее окно из 20 свечей. Это позволяет отсеивать кратковременные всплески и реагировать только на значимые изменения.

class VolumeAnomalyDetector: WINDOW_PERIODS = 20 # свечей для расчёта среднего async def check_volume_spike(self, symbol: str, current_volume: Decimal) -> float: """Возвращает множитель относительно среднего объёма""" recent_volumes = await self.candle_repo.get_recent_volumes( symbol, count=self.WINDOW_PERIODS ) if len(recent_volumes) < 5: return 1.0 avg_volume = sum(recent_volumes) / len(recent_volumes) if avg_volume == 0: return 1.0 return float(current_volume / avg_volume) 

Ликвидационные алерты

Данные о ликвидациях получаем с бирж (Binance forceOrder stream, Bybit liquidation) или агрегаторов (Coinalyze, CoinGlass API):

class LiquidationMonitor: async def monitor_binance_liquidations(self): async with websockets.connect("wss://fstream.binance.com/ws/!forceOrder@arr") as ws: async for message in ws: data = json.loads(message) order = data["o"] liquidation = Liquidation( symbol=order["s"], side=order["S"], quantity=Decimal(order["q"]), price=Decimal(order["p"]), usd_value=Decimal(order["q"]) * Decimal(order["p"]), timestamp=data["T"], ) await self.process_liquidation(liquidation) async def process_liquidation(self, liq: Liquidation): await self.redis.incrbyfloat( f"liq_total:{liq.symbol}:1m", float(liq.usd_value) ) await self.redis.expire(f"liq_total:{liq.symbol}:1m", 60) if liq.usd_value >= 1_000_000: await self.alert_engine.fire_liquidation_alert(liq) 

Подключение внешних источников данных

Мы интегрируемся с любыми биржами через WebSocket. Для Binance используем Binance WebSocket Streams. Данные нормализуются в единый формат NormalizedTicker, что упрощает добавление новых источников.

Webhook доставка

class WebhookDelivery: async def send(self, webhook_url: str, alert: AlertMessage): payload = { "type": alert.type, "symbol": alert.symbol, "message": alert.text, "timestamp": alert.timestamp.isoformat(), "data": alert.raw_data, } signature = hmac.new( alert.rule.webhook_secret.encode(), json.dumps(payload).encode(), hashlib.sha256 ).hexdigest() async with httpx.AsyncClient() as client: await client.post( webhook_url, json=payload, headers={"X-Alert-Signature": f"sha256={signature}"}, timeout=10.0, ) 

Webhook-алерты позволяют интегрировать систему с внешними ботами, торговыми системами, CRM. По webhook можно триггерить автоматические действия — например, открытие ордера при ценовом алерте.

Сравнение моделей доставки

Push-модель в 10 раз быстрее и эффективнее при большом количестве правил. Закажите разработку — получите прототип за 3 дня.

Процесс разработки

Общий срок — от 10 до 17 дней в зависимости от сложности.

Что входит в результат

• Документация архитектуры и API
• Исходный код (Python, asyncio)
• Инструкция по настройке и эксплуатации
• Обучение пользователей (до 4 часов)
• Поддержка в течение 3 месяцев

Свяжитесь с нами — получите консультацию инженера бесплатно. Заполните форму на сайте или напишите в Telegram — в течение 24 часов мы подготовим коммерческое предложение с точными сроками и стоимостью под ваши задачи.