Разработка модели классификации фейковых новостей в крипто

Крипто-рынок — идеальная среда для дезинформации. Волатильность высока: один фейковый твит о листинге на Binance или о взломе протокола двигает цену на десятки процентов. Pump-and-dump схемы начинаются с информационной манипуляции. Мы разрабатываем модель классификации фейковых новостей в крипто под ключ — от сбора датасета до деплоя. Используем NLP для крипто: fine-tuning FinBERT на крипто-корпусе и on-chain верификацию новостей. Детекция дезинформации крипто — наш профиль. Оценим ваш проект и предложим решение.

Разработка такого классификатора — задача NLP с несколькими специфическими сложностями: узкодоменная терминология, скорость распространения информации (новость устаревает за часы), мультиязычность, намеренная обфускация текста авторами фейков. Мы используем современный стек: PyTorch, HuggingFace Transformers, Fine-tuning FinBERT на крипто-корпусе. В результате вы получаете систему, способную автоматически выявлять дезинформацию с recall > 0.85 и precision > 0.90.

Какие типы фейков мы различаем?

Прежде чем строить модель, нужно понять, что именно классифицируем. «Фейковые новости» — слишком широкое понятие. Мы выделяем следующие категории:

Каждая категория имеет свои текстовые паттерны, источники и методы верификации. Модель классифицирует по категориям, а не бинарно «fake/real».

Как мы собираем данные для обучения?

Главная проблема — отсутствие готового датасета. Существующие датасеты (LIAR, FakeNewsNet) не охватывают крипто-специфику.

Источники данных:

• Twitter/X API: Academic Research API даёт доступ к историческим данным. Фильтруем аккаунты с > 1,000 follower в крипто-нише, хэштеги #bitcoin, #defi, ключевые слова протоколов.
• Telegram: Telethon для парсинга публичных каналов. Важный источник — pump-and-dump каналы.
• Reddit: r/CryptoCurrency, r/Bitcoin, r/CryptoMoonShots через Pushshift API.
• Новостные агрегаторы: CoinDesk, Cointelegraph, Decrypt — верифицированные новости (позитивный класс).

Автоматическая кросс-верификация: если новость появляется в Twitter, но не подтверждается официальными каналами за 24 часа — потенциальный фейк; если противоречит on-chain данным — фейк с высокой вероятностью. Human labeling через crowdsourcing с доменными экспертами. Каждый пример размечается минимум тремя аннотаторами, inter-annotator agreement > 0.7.

from datasets import Dataset import pandas as pd # Структура датасета example_schema = { 'id': str, 'text': str, 'source': str, 'author': str, 'timestamp': str, 'label': int, 'category': str, 'confidence': float, 'verification_sources': list, 'mentioned_tokens': list, 'mentioned_exchanges': list, } def balance_dataset(df: pd.DataFrame, target_ratio: float = 0.4) -> pd.DataFrame: fake = df[df['label'] == 1] real = df[df['label'] == 0] n_fake = len(fake) n_real_target = int(n_fake / target_ratio * (1 - target_ratio)) real_sampled = real.sample(n=min(n_real_target, len(real)), random_state=42) return pd.concat([fake, real_sampled]).sample(frac=1, random_state=42) 

Архитектура модели

Feature Engineering: что важно для крипто-фейков

Текстовые сигналы фейков:

• Чрезмерный hype без конкретики («100x guaranteed», «next bitcoin»)
• Срочность («buy NOW», «last chance»)
• Имена известных проектов/личностей без контекста
• Грамматические ошибки (аккаунты-имитаторы часто небрежны)

Metadata признаки:

• Возраст аккаунта и история публикаций
• Follower/following ratio (0.01 — подозрительно)
• Скорость распространения (виральность за первый час)
• Временной паттерн (публикация в 3:00 UTC)

Baseline: TF-IDF + Logistic Regression / XGBoost. Основная модель: FinBERT (финансовый BERT), fine-tuned на крипто-корпусе. Финальный ансамбль: градиентный бустинг на конкатенации CLS-эмбеддингов и мета-признаков. Такая комбинация значительно точнее: ансамбль в 1.15 раза точнее одиночного FinBERT.

from transformers import AutoTokenizer, AutoModelForSequenceClassification import torch import numpy as np from sklearn.ensemble import GradientBoostingClassifier class CryptoFakeNewsClassifier: def __init__(self, model_name: str = 'ProsusAI/finbert'): self.tokenizer = AutoTokenizer.from_pretrained(model_name) self.text_model = AutoModelForSequenceClassification.from_pretrained( model_name, num_labels=6 ) self.meta_classifier = GradientBoostingClassifier( n_estimators=300, max_depth=6, learning_rate=0.05 ) def extract_text_features(self, texts: list[str]) -> np.ndarray: self.text_model.eval() all_embeddings = [] batch_size = 32 for i in range(0, len(texts), batch_size): batch = texts[i:i+batch_size] inputs = self.tokenizer( batch, max_length=512, truncation=True, padding=True, return_tensors='pt' ) with torch.no_grad(): outputs = self.text_model(**inputs, output_hidden_states=True) cls_embeddings = outputs.hidden_states[-1][:, 0, :] all_embeddings.append(cls_embeddings.numpy()) return np.vstack(all_embeddings) def extract_meta_features(self, posts: list[dict]) -> np.ndarray: features = [] for post in posts: account_age_days = ( pd.Timestamp.now() - pd.Timestamp(post['account_created']) ).days feature_vector = [ account_age_days, post.get('followers_count', 0), post.get('following_count', 1), post.get('followers_count', 0) / max(post.get('following_count', 1), 1), post.get('tweet_count', 0), post.get('retweet_count', 0), post.get('like_count', 0), int(post.get('verified', False)), len(post.get('text', '')), post.get('text', '').count('!'), post.get('text', '').count('$'), np.sin(2 * np.pi * pd.Timestamp(post['created_at']).hour / 24), np.cos(2 * np.pi * pd.Timestamp(post['created_at']).hour / 24), int('http' in post.get('text', '')), sum(1 for token in KNOWN_TOKENS if token.lower() in post.get('text', '').lower()), ] features.append(feature_vector) return np.array(features) def predict(self, posts: list[dict]) -> dict: texts = [p['text'] for p in posts] text_features = self.extract_text_features(texts) meta_features = self.extract_meta_features(posts) combined = np.hstack([text_features, meta_features]) probabilities = self.meta_classifier.predict_proba(combined) predictions = self.meta_classifier.predict(combined) return { 'predictions': predictions, 'probabilities': probabilities, 'labels': ['real', 'fake_listing', 'fake_partnership', 'fake_exploit', 'shill', 'impersonation'] } 

Fine-tuning на крипто-домен

FinBERT обучался на финансовых новостях, но не специализирован для крипто. Fine-tuning на крипто-корпусе значительно улучшает качество: recall для фейков вырастает на 5–7%. Используем кастомные веса классов для балансировки: фейковые классы получают больший штраф за пропуск.

from transformers import Trainer, TrainingArguments training_args = TrainingArguments( output_dir='./crypto-fake-news-model', num_train_epochs=5, per_device_train_batch_size=16, per_device_eval_batch_size=32, warmup_steps=500, weight_decay=0.01, evaluation_strategy='epoch', save_strategy='epoch', load_best_model_at_end=True, metric_for_best_model='f1_macro', ) 

Почему on-chain верификация важна?

Уникальное преимущество крипто-домена: многие заявления верифицируемы on-chain. Заявлен листинг на Uniswap V3 — проверяем через Uniswap Subgraph, существует ли пул. Заявлен exploit — проверяем изменение TVL в DeFiLlama за указанный период. Заявлено партнёрство — ищем on-chain взаимодействие между контрактами. Это детерминированная проверка, которая значительно повышает точность для категорий с on-chain следом.

import aiohttp async def verify_listing_claim(token_address: str, dex: str = 'uniswap_v3') -> dict: if dex == 'uniswap_v3': query = """ query PoolsForToken($token: String!) { pools(where: { or: [ { token0: $token }, { token1: $token } ] }, first: 5) { id token0 { symbol } token1 { symbol } liquidity totalValueLockedUSD createdAtTimestamp } } """ async with aiohttp.ClientSession() as session: async with session.post( 'https://api.thegraph.com/subgraphs/name/uniswap/uniswap-v3', json={'query': query, 'variables': {'token': token_address.lower()}} ) as response: data = await response.json() pools = data.get('data', {}).get('pools', []) return { 'listing_exists': len(pools) > 0, 'pools': pools, 'total_tvl': sum(float(p['totalValueLockedUSD']) for p in pools) } async def verify_exploit_claim(protocol: str, claimed_amount_usd: float, claim_timestamp: int) -> dict: async with aiohttp.ClientSession() as session: async with session.get( f'https://api.llama.fi/protocol/{protocol}' ) as response: data = await response.json() tvl_history = data.get('tvl', []) before_tvl = get_tvl_at_timestamp(tvl_history, claim_timestamp - 3600) after_tvl = get_tvl_at_timestamp(tvl_history, claim_timestamp + 3600) tvl_drop = before_tvl - after_tvl if before_tvl > after_tvl else 0 return { 'tvl_drop_detected': tvl_drop > 0, 'detected_amount': tvl_drop, 'claimed_amount': claimed_amount_usd, 'plausible': abs(tvl_drop - claimed_amount_usd) / claimed_amount_usd < 0.3 } 

Как оценить качество модели?

Для детекции фейков accuracy — неправильная метрика. Если 90% примеров реальные, модель, всегда предсказывающая «real», получит 90% accuracy. Основные метрики: precision, recall, F1 по классам. Особое внимание — recall для fake классов: пропуск фейка хуже ложной тревоги.

Целевые показатели для production: Fake detection recall > 0.85, real precision > 0.90, F1 macro > 0.82. Мониторим temporal stability: модель должна сохранять качество на новых данных, поэтому раз в месяц проводим переобучение.

Сравнение подходов:

Наша архитектура даёт F1 на 18% выше, чем TF-IDF + XGBoost. Типичный ущерб от одного успешного фейкового твита оценивается в $10,000–$500,000.

from sklearn.metrics import classification_report, roc_auc_score import pandas as pd def evaluate_model(y_true, y_pred, y_proba, class_names): report = classification_report( y_true, y_pred, target_names=class_names, output_dict=True ) df_report = pd.DataFrame(report).T fake_classes = [c for c in class_names if c != 'real'] fake_f1_avg = df_report.loc[fake_classes, 'f1-score'].mean() print(f"Fake detection F1 (macro avg): {fake_f1_avg:.3f}") print(f"Real precision: {df_report.loc['real', 'precision']:.3f}") binary_labels = (y_true > 0).astype(int) binary_proba = 1 - y_proba[:, 0] auc = roc_auc_score(binary_labels, binary_proba) print(f"AUC-ROC (fake vs real): {auc:.3f}") return df_report 

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

• Сбор и разметка датасета (50 000+ примеров) с автоматической и ручной верификацией
• Fine-tuning FinBERT на вашем корпусе (или нашем публичном)
• Разработка пайплайна с on-chain верификацией через The Graph, DeFiLlama
• Деплой в Docker-контейнере с FastAPI, Kafka для потоковой обработки, мониторинг concept drift
• Алертинг при обнаружении фейков с настраиваемыми порогами
• Документация по API и руководство пользователя

Процесс работы

1. Аналитика: изучаем ваши источники данных, определяем целевые категории фейков
2. Проектирование: выбираем стек, проектируем датасет и пайплайн верификации
3. Реализация: сбор данных, обучение baseline и transformer модели, итерации
4. Тестирование: оценка на исторических и свежих данных, A/B-тестирование
5. Деплой: развёртывание в вашей инфраструктуре, интеграция с существующими сервисами

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

От 3 до 4 месяцев до production-ready системы. Сбор и разметка датасета — 6–8 недель, обучение моделей — 4–6 недель, деплой и мониторинг — 3–4 недели. Стоимость рассчитывается индивидуально.

Наша команда имеет 8+ лет опыта в NLP и блокчейне, выполнила 30+ проектов по классификации контента. Экономия от предотвращения потерь на фейковых новостях может достигать сотен тысяч долларов. Свяжитесь с нами для оценки вашего проекта — мы подберём оптимальное решение. Закажите разработку модели уже сегодня.