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

Типова ситуація: у трейдера активи розкидані по 5–10 мережах — у пулах ліквідності Uniswap, стейкінгу Lido, lending на Aave. Щоб оцінити загальну експозицію та ризики ліквідації, доводиться відкривати 6 вкладок і збирати дані вручну. Наш Telegram-бот агрегує дані з усіх мереж у реальному часі: показує єдиний портфель, налаштовувані алерти та критичні події. Рішення окупається за тиждень, якщо воно запобігає хоча б одній значній ліквідації — саме таку економію фіксують наші користувачі (середня ліквідація $10k+). А ще наш бот замінює платні моніторингові сервіси — ви отримуєте ті ж дані без щомісячної підписки за $50–200. Наша команда має 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 дає значну економію на підключеннях до даних.

Типи алертів

Як ми це робимо: стек і реалізація

Стек: 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")