Разработка Telegram-бота для мониторинга криптопортфеля

Разработка Telegram-бота для мониторинга криптопортфеля

Типичная ситуация: у трейдера активы разбросаны по 5–10 сетям — в пулах ликвидности Uniswap, стейкинге Lido, lending на Aave. Чтобы оценить общую экспозицию и риски ликвидации, приходится открывать 6 вкладок и собирать данные вручную. Наш Telegram-бот агрегирует данные из всех сетей в реальном времени: показывает единый портфель, настраиваемые алерты и критичные события. Решение окупается за неделю, если оно предотвращает хотя бы одну ликвидацию на сумму свыше $1000 — именно такую экономию фиксируют наши пользователи. А ещё наш бот заменяет платные мониторинговые сервисы стоимостью до $100/мес — вы получаете те же данные без ежемесячной подписки. Наша команда имеет 5+ лет опыта в блокчейн-разработке и 50+ реализованных проектов по мониторингу. Свяжитесь с нами — мы бесплатно протестируем бота на ваших кошельках и покажем, как он работает.

Проблемы, которые решаем

Фрагментация данных по сетям

Каждая сеть требует отдельного RPC или API-ключа. Мы подключаем Ethereum, Polygon, Arbitrum, Optimism, Base и BNB Chain через Moralis Web3 API для балансов токенов и DeBank API для DeFi-позиций. Для Bitcoin и Solana — отдельные адаптеры. Все данные собираются асинхронно через asyncio.gather. Время ответа бота — менее 2 секунд даже при 50+ кошельках.

Задержка в ценовых алертах

Пуллинг цены каждые 10 секунд — дорого и неточно. Вместо этого подписываемся на WebSocket стримы Binance и Bybit (бесплатно) для top-100 монет. Для остальных — используем события Chainlink price feed. Потери ценовых движений исключены: алерт приходит за 1–2 секунды. WebSocket-алерты приходят в 10 раз быстрее, чем пуллинг каждые 10 секунд.

Мониторинг health factor в lending-протоколах

Health factor Aave зависит от цены залога и долга. Отслеживаем его через события контрактов (Alchemy webhook) при любом изменении, а также через периодическую проверку при движении цены. Если HF падает ниже 1.2 — автоматический алерт с рекомендацией действий.

Как настроить алерт по health factor?

Пошаговая инструкция для встроенной команды /addalert:

1. Выберите из подсказок health_factor.
2. Укажите адрес кошелька, который уже добавлен командой /addwallet.
3. Установите порог: например, 1.2.
4. Выберите протокол (Aave V3, Compound V3). Бот автоматически определит активные позиции и начнёт мониторинг. При изменении HF бот пришлёт сообщение с текущим значением и ссылкой на Etherscan.

Архитектура бота

Telegram Bot API (polling/webhook) ↓ Bot handler (aiogram 3.x, Python 3.11) ↓ Portfolio aggregator service ├── Price service (Binance WebSocket + CoinGecko REST) ├── Balance fetcher (Moralis Balance API / Alchemy Token API) ├── DeFi positions (DeBank API + прямые вызовы к Aave/Compound) └── Event listener (Alchemy webhooks для on-chain событий) ↓ Database (PostgreSQL + Redis cache) ├── user wallets (public addresses) ├── alert configurations └── cached portfolio snapshots (TTL: цены 30s, балансы 2-5 min) ↓ Alert scheduler (APScheduler cron + event-driven triggers) 

Redis критичен для кэша: каждый запрос /portfolio не ходит к внешним API, а берёт данные из кэша. Это снижает нагрузку на сторонние сервисы и ускоряет ответ в 3–5 раз.

Сравнение источников данных

Выбор в пользу Moralis и Alchemy вместо платного Zerion экономит до $50/мес на подключениях к данным.

Типы алертов

Как мы это делаем: стек и реализация

Стек: Python 3.11 + aiogram 3.x + asyncio. Для каждого пользователя храним список кошельков в PostgreSQL (один запрос при команде). Агрегатор собирает данные параллельно:

async def get_portfolio(wallets: list[str]) -> Portfolio: async with asyncio.TaskGroup() as tg: balance_task = tg.create_task(balance_fetcher.fetch_all(wallets)) defi_task = tg.create_task(defi_fetcher.fetch_all(wallets)) price_task = tg.create_task(price_service.fetch_prices()) return Portfolio(balances=balance_task.result(), positions=defi_task.result(), usd_values=price_task.result()) 

Форматирование вывода — HTML с эмодзи, таблицами, ссылками на Etherscan. Пример:

/portfolio Ваш портфель (обновлено 2 сек назад): **Ethereum** ETH: 2.345 ($7,850) ↗ 1.2% USDC: 15,000.00 ($15,000) ▸ 0% Aave: депозит 10 ETH, долг 5,000 USDC, Health Factor: 1.45 **Polygon** MATIC: 5000 ($4,200) ↗ 3.1% Uniswap V3: MATIC/USDC (0.05%) — $2,300 

Почему безопасность выходит на первый план?

Бот работает только с публичными адресами. Пользователь никогда не вводит приватные ключи или seed-фразы. В onboarding мы явно сообщаем: «Никаких приватных данных». Если бот детектирует попытку ввести похожий на private key текст (64 hex-символа или 12/24 слова) — команда игнорируется, пользователь получает предупреждение. Адреса хранятся в зашифрованной колонке PostgreSQL. Для защиты от флуда — rate limiting на уровне aiogram: не более 30 команд/мин на пользователя.

На каждом этапе используем проверенные решения: например, Chainlink documentation для ценовых фидов или официальные Aave контракты для HF. Это обеспечивает надёжность, подтверждённую сотнями аудитов.

Процесс работы над заказом

1. Аналитика — обсуждаем какие сети, протоколы, алерты нужны. 2. Проектирование архитектуры — выбираем источники данных, провайдеров, кэш. 3. Реализация бота — Python/aiogram, интеграция с Telegram Bot API, подключение API и WebSocket. 4. Тестирование — юнит-тесты на обработчики команд, интеграционные тесты с моками API, стресс-тест на 100+ кошельков. 5. Деплой — на Railway, Fly.io или ваш VPS с Docker. Предоставляем документацию и инструкцию по эксплуатации.

Что входит в работу

• База: команды /addwallet, /removewallet, /portfolio, /alerts.
• Алерты по цене, health factor, крупным транзакциям.
• Поддержка всех EVM-сетей (Bitcoin/Solana — опционально).
• Кэширование в Redis для быстрого отклика.
• Документация по администрированию и развёртыванию.
• Гарантия работоспособности и доработки в течение месяца после сдачи.

Сроки ориентировочно

Базовая версия — от 2 до 3 рабочих дней. Расширенная с DeFi-позициями и WebSocket — от 5 до 10 дней. Стоимость рассчитывается индивидуально после анализа требований. Свяжитесь с нами для обсуждения вашего сценария — подберём оптимальную архитектуру. Закажите разработку Telegram-бота для мониторинга криптопортфеля — получите консультацию по вашему кейсу.

@router.message(Command("portfolio")) async def portfolio_command(message: Message): user = await get_user(message.from_user.id) if not user.wallets: await message.answer("Сначала добавьте кошелёк командой /addwallet 0x...") return async with asyncio.TaskGroup() as tg: pf = tg.create_task(aggregator.get_portfolio(user.wallets)) prices = tg.create_task(price_service.get_all_prices()) portfolio = pf.result() text = format_portfolio(portfolio, prices.result()) await message.answer(text, parse_mode="HTML")