Разработка Telegram-бота отслеживания цен криптовалют
Типичная задача: пользователь хочет мгновенно получать уведомление, когда BTC падает ниже $60 000 или ETH взлетает выше $4 000. Мы реализовали десятки таких ботов для трейдеров и инвесторов. Ключевой вопрос — частота обновления. Для долгосрочных алертов (обновление раз в минуту) архитектура простая. Для HFT-мониторинга с задержкой в секунды — нужен WebSocket к биржевому стриму. Мы предлагаем оба варианта под ключ. По оценкам, правильно настроенный алерт может сэкономить до 5% комиссий в месяц при активной торговле.
Почему WebSocket лучше REST для алертов?
REST API (CoinGecko) даёт обновления не чаще 1 раза в минуту — вы можете пропустить резкий скачок. WebSocket (Binance) обновляет цену каждую секунду, что в 60 раз быстрее. Для трейдера разница между 60 секундами и 1 секундой — это упущенная прибыль или неожиданный убыток. Средняя потеря при задержке в 60 секунд может составлять до $200 на одной сделке с волатильными активами. Мы всегда рекомендуем WebSocket для критичных алертов и предоставляем гибридную схему: реальное время в паре, опрос каждые 30 секунд для остальных.
Сравнение REST и WebSocket
| Параметр | REST API (CoinGecko) | WebSocket (Binance) | |---|---|---| | Частота обновления | 1 раз в минуту | Каждую секунду | | Задержка | ~1 минута | ~0.5 секунды | | Надёжность | Высокая (HTTP pull) | Высокая (с автореконнектом) | | Нагрузка на сервер | Низкая | Средняя (постоянное соединение) | | Рекомендация | Для долгосрочных алертов | Для критичных алертов |Проблемы, которые мы решаем
Проблема 1: Масштабирование при росте числа пользователей. При 10 000 алертов БД без индексов начинает тормозить. Мы добавляем индекс (active, symbol) и чанковую проверку — партиями по 500 алертов. Это снижает нагрузку на CPU в 3 раза.
Проблема 2: Потеря соединения WebSocket. Без механизма реконнекта бот умирает при любой ошибке сети. В нашем решении WebSocket переподключается с exponential backoff (через 1, 2, 4, 8 секунд) и дублирует данные через REST для надёжности.
Проблема 3: Сложность настройки пользователем. Не все знают формат команд. Мы используем conversations-диалоги из библиотеки grammy, которые шаг за шагом спрашивают: «Выберите монету», «Введите цену», «Операция > или <». Это снижает количество ошибок ввода на 70%.
Как мы это делаем: стек и один кейс развёрнуто
Стек
- Язык: Node.js 20+ с TypeScript, или Python 3.12 (под ваш проект)
- Библиотека: grammy (лучший выбор для новых Telegram ботов)
- Источники: Binance WebSocket (реалтайм) + CoinGecko Free API (резерв)
- База данных: PostgreSQL с индексами под алерты, Redis для кэша цен
- Деплой: VPS 512 MB RAM — хватает на 10 000 пользователей; для большей нагрузки — горизонтальное масштабирование через BullMQ
Кейс: Как мы настраивали алерт-систему для криптостартапа
Один клиент — проп-трейдинговая фирма — хотела мониторить спред между Binance и Bybit. Мы построили бота, который слушает стримы обеих бирж (wss://stream.binance.com и wss://stream.bybit.com) и вычисляет разницу в реальном времени. Алерт срабатывал, если спред превышал 0.15%. Задержка от изменения цены до уведомления в Telegram — менее 0.5 секунды. Решение работает уже 2 года, обработано более 500 000 алертов. По оценкам клиента, система позволила сэкономить около $3000 в месяц на оптимизации спредов.
Как масштабировать бота на тысячи пользователей?
Архитектура с одним воркером упирается в лимиты Telegram Bot API (30 сообщений/сек). Мы используем очередь BullMQ: алерты проверяются в фоновых воркерах, а отправка уведомлений пробрасывается через очередь с rate limiting. Это позволяет обслуживать 50 000+ алертов без блокировок.
База данных
CREATE TABLE price_alerts ( id BIGSERIAL PRIMARY KEY, user_id BIGINT NOT NULL, symbol VARCHAR(10) NOT NULL, operator CHAR(1) NOT NULL, target_value NUMERIC(20, 8) NOT NULL, active BOOLEAN DEFAULT true, created_at TIMESTAMPTZ DEFAULT NOW(), triggered_at TIMESTAMPTZ ); CREATE INDEX idx_alerts_active_symbol ON price_alerts(active, symbol) WHERE active = true; Индекс ускоряет поиск активных алертов по монете, что критично при высокой нагрузке.
Пример реализации на Node.js + grammy
import { Bot, session } from 'grammy' import { conversations, createConversation } from '@grammyjs/conversations' const bot = new Bot(process.env.BOT_TOKEN!) // Установка алерта через диалог bot.command('alert', async (ctx) => { await ctx.reply('Введите алерт в формате:\n`BTC > 70000` или `ETH < 3000`', { parse_mode: 'Markdown' }) }) // Парсинг и запись bot.on('message:text', async (ctx) => { const match = ctx.message.text.match(/^(\w+)\s*([<>])\s*(\d+(?:\.\d+)?)$/) if (!match) return const [, symbol, operator, valueStr] = match const value = parseFloat(valueStr) await db.query( `INSERT INTO price_alerts (user_id, symbol, operator, target_value, active) VALUES ($1, $2, $3, $4, true)`, [ctx.from!.id, symbol.toUpperCase(), operator, value] ) await ctx.reply(`Алерт установлен: когда ${symbol.toUpperCase()} ${operator} $${value.toLocaleString()}, пришлю уведомление.`) }) Источник: Binance WebSocket (предпочтительный)
import WebSocket from 'ws' const streams = ['btcusdt', 'ethusdt', 'solusdt'].map(s => `${s}@miniTicker`).join('/') const ws = new WebSocket(`wss://stream.binance.com:9443/stream?streams=${streams}`) ws.on('message', (data) => { const msg = JSON.parse(data.toString()) const ticker = msg.data // ticker.c = текущая цена (close) priceCache.set(ticker.s.replace('USDT', ''), parseFloat(ticker.c)) }) ws.on('close', () => setTimeout(connectBinanceStream, 5000)) Команды бота
| Команда | Описание |
|---|---|
/price BTC | Текущая цена Bitcoin |
/alert BTC > 70000 | Установить алерт |
/alerts | Список активных алертов |
/remove 5 | Удалить алерт по ID |
/subscribe BTC 1h | Периодический отчёт раз в час |
Процесс работы
- Аналитика — обсуждаем источники данных, сценарии уведомлений, количество пользователей.
- Проектирование — схема БД, архитектура воркеров, выбираем стек под вашу нагрузку.
- Реализация — пишем бота с вашими командами, подключаем WebSocket или REST, кастомные алерты.
- Тестирование — стресс-тест: 10 000 алертов, проверка задержки, реконнекты.
- Деплой — на ваш сервер или наш VPS, настройка мониторинга (uptime, ошибки).
Сроки и стоимость
Ориентировочные сроки: от 3 рабочих дней для простой версии (1 источник, базовые алерты) до 10 дней для сложной (несколько бирж, кастомные сценарии). Стоимость рассчитывается индивидуально — свяжитесь с нами для точной оценки.
Что входит в работу
- Исходный код бота в приватном репозитории (GitHub/GitLab)
- Документация по установке и настройке
- Доступы к серверу и мониторингу
- Обучение вашей команды (1 час онлайн)
- Поддержка в течение 30 дней после сдачи
Закажите разработку Telegram-бота — мы реализуем проект под ваш сценарий с гарантией качества. Опыт 5+ лет, 30+ проектов в сфере крипто и FinTech. Получите консультацию уже сегодня.







