Интеграция с провайдерами ликвидности под ключ для биржи

class ResilientLPManager: def __init__(self, providers: list, fallback_amm=None): self.providers = {p.name: p for p in providers} self.provider_health = {p.name: True for p in providers} self.fallback_amm = fallback_amm # DEX как fallback async def get_quote_with_fallback(self, symbol, side, qty) -> LPQuote: for provider_name, provider in self.providers.items(): if not self.provider_health[provider_name]: continue try: quote = await asyncio.wait_for( provider.get_quote(symbol, side, qty), timeout=2.0 ) return quote except (asyncio.TimeoutError, LPError) as e: logger.warning(f"LP {provider_name} failed: {e}") await self.mark_unhealthy(provider_name) if self.fallback_amm: return await self.fallback_amm.get_quote(symbol, side, qty) raise NoLiquidityAvailable("All LP providers failed") 

Дополнительно настраиваем Heartbeat-мониторинг: если провайдер не отвечает 5 секунд, автоматически исключаем его из ротации и уведомляем дежурного.

Агрегация ликвидности от нескольких провайдеров

Отметим: когда подключаете несколько LP, нужно агрегировать котировки и выбирать лучшую. Класс LiquidityAggregator реализует сбор и фильтрацию устаревших котировок:

class LiquidityAggregator: def __init__(self, providers: list[BaseLPClient]): self.providers = providers self.quotes: dict[str, list[LPQuote]] = {} def on_quote_update(self, quote: LPQuote): symbol = quote.symbol if symbol not in self.quotes: self.quotes[symbol] = [] self.quotes[symbol] = [ q for q in self.quotes[symbol] if q.provider != quote.provider ] self.quotes[symbol].append(quote) def get_best_bid_ask(self, symbol: str) -> BestBidAsk: quotes = self.quotes.get(symbol, []) valid = [q for q in quotes if not q.is_stale()] if not valid: return None best_bid = max(valid, key=lambda q: q.bid) best_ask = min(valid, key=lambda q: q.ask) return BestBidAsk( bid=best_bid.bid, bid_size=best_bid.bid_size, bid_provider=best_bid.provider, ask=best_ask.ask, ask_size=best_ask.ask_size, ask_provider=best_ask.provider, spread_bps=int((best_ask.ask - best_bid.bid) / best_bid.bid * 10000) ) 

Что такое Smart Order Routing и как он работает?

SmartOrderRouter выбирает оптимального провайдера для ордера. Для market-ордеров используем дробление (TWAP), чтобы не проскальзывать:

class SmartOrderRouter: def route(self, order: ClientOrder, aggregator: LiquidityAggregator) -> RoutingPlan: available = aggregator.get_all_quotes(order.symbol) if order.type == 'market': return self.route_market(order, available) elif order.type == 'limit': return self.route_limit(order, available) def route_market(self, order: ClientOrder, quotes: list[LPQuote]) -> RoutingPlan: remaining = order.quantity plan = [] sorted_quotes = sorted( quotes, key=lambda q: q.ask if order.side == 'buy' else -q.bid ) for quote in sorted_quotes: if remaining <= 0: break fill_qty = min(remaining, quote.ask_size if order.side == 'buy' else quote.bid_size) plan.append(RoutingLeg( provider=quote.provider, quantity=fill_qty, expected_price=quote.ask if order.side == 'buy' else quote.bid )) remaining -= fill_qty if remaining > 0: raise InsufficientLiquidity(f"Could not route full order, {remaining} remaining") return RoutingPlan(legs=plan, total_quantity=order.quantity) 

Подробнее о принципах SOR можно прочитать в Wikipedia.

Что выбрать: CEX LP или DEX/AMM?

Aggregated CEX LP (B2Broker) даёт спреды 0.01–0.05% для топ-пар, но требует KYB и ежемесячного объёма. DEX/AMM (Uniswap) не требует KYC и доступен для любых токенов, но спреды могут быть выше (0.05–1%) и есть риск impermanent loss при использовании собственного пула. Лучшая стратегия — комбинировать: основные пары через CEX LP, long-tail через DEX. Экономия на спреде может достигать 50% по сравнению с рыночными ордерами без SOR. Средняя стоимость интеграции LP для биржи варьируется от $20 000 до $100 000 в зависимости от сложности, количества провайдеров и требований к latency.

Процесс работы: от запроса до production

Процесс включает этапы: аналитика (1-2 дня), проектирование (2-3 дня), реализация (1-2 недели), тестирование (3-5 дней), деплой (1-2 дня) и пост-поддержка. Оценим ваш проект за 1 день — свяжитесь с нами для консультации. Закажите интеграцию LP под ключ и получите готовую архитектуру за 2-4 недели. Получите готовую интеграцию LP с гарантией uptime 99.95%.