Трекинг кошельков в крипте: классификация, сбор и оповещения

Отметим: когда вы отслеживаете 500+ кошельков через публичные RPC, задержка может достигать 10 минут. Коммерческие сигналы требуют реакции в секундах — разница между «кошелёк только что купил токен X» и «купил 5 минут назад» стоит 30% потенциала сделки. Мы разработали систему, которая сокращает лаг до 2–3 секунд: от классификации адресов до real-time оповещений. Наш опыт показывает, что правильная настройка позволяет фиксировать 90% значимых движений до их публичного обсуждения. При этом инфраструктура обходится в $50–100 в месяц — в 3 раза дешевле готовых решений типа Nansen или Arkham. Давайте разберём, что именно требуется для фильтрации смарт-мани — от эвристической разметки до продакшн-пайплайнов на вебхуках. В типовом проекте с 1000 адресов и 5000 транзакций в день мы добиваемся задержки менее 2 секунд за счёт комбинации вебхуков и кэширования.

Классификация smart money кошельков

Нет единого реестра smart money. Это кошельки, чьи движения несут высокую информационную ценность: ранние инвесторы, whale-трейдеры, фонды с доказанным треком, адреса известных протоколов. Источники для построения списка:

• On-chain атрибуция: Etherscan labels (есть в API), Arkham Intelligence (частично публичный), Nansen (платный, но labels экспортируются), Dune Analytics дашборды с community labels.
• Heuristic классификация: кошельки, которые регулярно покупают токены до x10 роста, высокая ROI за 12 месяцев по on-chain данным, ранние участники успешных IDO/ICO.

interface WalletProfile {
  address: string
  labels: string[] // ['vc', 'early-investor', 'dex-whale']
  chain: string
  firstTx: Date
  totalTxCount: number
  watchPriority: 'high' | 'medium' | 'low'
  source: string // откуда пришёл в список
}

Первичный список собирается через:

• Топ-N holders крупных токенов (Uniswap, AAVE, Compound governance tokens)
• Участники early rounds (парсинг Transfer событий от VC-кошельков)
• Профессиональные сервисы: Nansen Smart Money feed, Arkham entity tracking

Почему real-time мониторинг критичен?

Исторические данные хороши для бэктестинга, но торговые сигналы требуют немедленной реакции. Разница между «кошелёк только что купил токен X» и «купил 5 минут назад» может стоить 30% потенциала сделки. Real-time поток строится на вебхуках вместо poll-запросов — это снижает нагрузку и задержку. Мы используем Alchemy Notify — он превосходит Moralis Streams по скорости доставки в 2–3 раза и предлагает встроенную верификацию подписей. Для хранения трансферов применяем TimescaleDB с гипертаблицами — это обеспечивает вставку в 5 раз быстрее стандартного PostgreSQL с ручным партиционированием.

// Подписка через Alchemy Notify API
async function subscribeToWalletActivity(wallets: string[]): Promise<void> {
  const payload = {
    network: 'ETH_MAINNET',
    webhook_type: 'ADDRESS_ACTIVITY',
    webhook_url: `${process.env.APP_URL}/webhooks/alchemy`,
    addresses: wallets,
  }
  const res = await fetch('https://notify.alchemyapi.io/dashboard/webhook-subscriptions', {
    method: 'POST',
    headers: {
      'X-Alchemy-Token': process.env.ALCHEMY_NOTIFY_KEY!,
      'Content-Type': 'application/json',
    },
    body: JSON.stringify(payload),
  })
  console.log('Webhook registered:', await res.json())
}

// Обработчик входящего webhook
app.post('/webhooks/alchemy', async (req, res) => {
  const { event } = req.body
  // Верификация подписи
  const signature = req.headers['x-alchemy-signature']
  if (!verifyAlchemySignature(req.rawBody, signature)) {
    return res.status(401).send()
  }
  await processWalletActivity(event)
  res.status(200).send()
})

Как собирать данные в реальном времени?

Сырые трансферы — не сигнал. Нужна интерпретация. Сбор data осуществляется через вебхуки Alchemy Notify, которые присылают события ADDRESS_ACTIVITY. Каждое событие содержит детали: адрес, токен, сумму, тип транзакции. Далее pipeline анализирует паттерны.

Что даёт аналитика паттернов?

Анализ включает несколько шагов:

1. Собрать все входящие трансферы за последние 24 часа.
2. Исключить токены, которые были в кошельке дольше суток.
3. Оставить токены, купленные минимум тремя smart money кошельками.
4. Отфильтровать транзакции с DEX-свопами (topic-хеш Swap-события).

-- Новые токен-позиции за последние 24 часа
-- (токены, которых не было в кошельке 24ч назад, но есть сейчас)
WITH yesterday_holdings AS (
    SELECT DISTINCT wallet, token_contract
    FROM wallet_transfers
    WHERE direction = 'in'
      AND block_time < NOW() - INTERVAL '24 hours'
),
new_buys AS (
    SELECT t.wallet, t.token_contract, SUM(t.amount) as total_in
    FROM wallet_transfers t
    LEFT JOIN yesterday_holdings y
        ON t.wallet = y.wallet
        AND t.token_contract = y.token_contract
    WHERE t.direction = 'in'
      AND t.block_time >= NOW() - INTERVAL '24 hours'
      AND y.token_contract IS NULL -- не было раньше
    GROUP BY t.wallet, t.token_contract
)
SELECT nb.token_contract,
       COUNT(DISTINCT nb.wallet) AS smart_money_buyers,
       STRING_AGG(nb.wallet, ',') AS buyer_list
FROM new_buys nb
GROUP BY nb.token_contract
HAVING COUNT(DISTINCT nb.wallet) >= 3 -- минимум 3 smart money кошелька
ORDER BY smart_money_buyers DESC

Дополнительные сигналы: аккумуляция (повторные покупки без продаж), крупные перемещения на биржу (вероятная продажа), активность в первые часы после листинга нового токена.

Кейс из практики

Один из проектов требовал мониторинг 300+ кошельков на Ethereum и Polygon. Прямые RPC-запросы давали задержку 5–8 минут для полного сканирования. Переход на Alchemy Asset Transfers + вебхуки сократил задержку до 2–3 секунд. Дополнительно внедрили классификацию транзакций по DEX-протоколам — отсекли 40% ложных срабатываний, связанных с внутренними переводами. Экономия на инфраструктуре составила $15 000 в год за счёт отказа от дорогих third-party API (Nansen, Arkham). При этом подписка на Nansen обходится от $100/мес, но мы заменили его комбинацией бесплатных инструментов, снизив затраты вдвое.

Что входит в реализацию

• Составление списка smart money: подбор источников (Nansen, Arkham, Etherscan, Dune) + эвристики, итого 500–2000 адресов.
• Написание скриптов сбора: исторические данные через Alchemy Asset Transfers и RPC, real-time через вебхуки.
• Развёртывание базы: TimescaleDB для хранения трансферов и метаданных.
• Настройка нотификаций: Telegram / Slack бот с фильтрацией сигналов.
• Дашборд и SQL-аналитика: отчёты по аккумуляции, новым позициям, движению на биржи.
• Документация и обучение: описание архитектуры, API, примеры запросов.

Мы гарантируем экспертизу: более 5 лет в blockchain-разработке, 30+ проектов по on-chain аналитике. Оценим ваш сценарий — свяжитесь, чтобы обсудить детали. Закажите консультацию, и мы подберём оптимальное решение под ваш бюджет.