Интеграция бота с API Binance

Интеграция бота с API Binance

Binance — крупнейшая криптобиржа по объёму торгов. API хорошо документировано, стабильное, с широкими возможностями: spot, margin, futures, options. Для большинства торговых ботов Binance — первый выбор из-за ликвидности и зрелости API.

Типы API Binance

• Spot API: базовая торговля, балансы, история
• Margin API: маржинальная торговля
• Futures API (FAPI): USD-M perpetual futures
• Coin-M Futures (DAPI): COIN-M futures
• WebSocket Streams: реалтайм рыночные данные

Подключение через CCXT

import ccxt.async_support as ccxt

# Spot
spot = ccxt.binance({
    'apiKey': API_KEY,
    'secret': SECRET,
    'options': {'defaultType': 'spot'},
    'enableRateLimit': True,
})

# Futures (USDT-M Perpetual)
futures = ccxt.binance({
    'apiKey': API_KEY,
    'secret': SECRET,
    'options': {'defaultType': 'future'},
})

async def get_ticker(symbol: str):
    return await spot.fetch_ticker(symbol)

async def place_futures_order(symbol: str, side: str, quantity: float, leverage: int = 10):
    # Устанавливаем плечо
    await futures.set_leverage(leverage, symbol)
    
    return await futures.create_order(symbol, 'market', side, quantity)

WebSocket для реалтайм данных

import websockets, json, asyncio

async def subscribe_streams():
    streams = [
        'btcusdt@bookTicker',  # лучшие bid/ask
        'btcusdt@aggTrade',    # агрегированные сделки
        'btcusdt@kline_1m',    # свечи 1m
    ]
    
    url = f"wss://stream.binance.com:9443/stream?streams={'/'.join(streams)}"
    
    async with websockets.connect(url) as ws:
        async for message in ws:
            data = json.loads(message)
            stream = data['stream']
            payload = data['data']
            
            if '@bookTicker' in stream:
                process_book_ticker(payload)
            elif '@aggTrade' in stream:
                process_trade(payload)
            elif '@kline' in stream:
                process_kline(payload['k'])

User Data Stream (приватный WebSocket)

Для реалтайм обновлений ордеров и балансов без polling:

async def start_user_data_stream():
    # 1. Получаем listen key
    listen_key = await get_listen_key()  # REST: POST /api/v3/userDataStream
    
    # 2. Подписываемся
    url = f"wss://stream.binance.com:9443/ws/{listen_key}"
    
    async with websockets.connect(url) as ws:
        # 3. Keepalive каждые 30 минут
        asyncio.create_task(keepalive_listen_key(listen_key))
        
        async for message in ws:
            event = json.loads(message)
            
            if event['e'] == 'executionReport':
                # Обновление ордера
                order_id = event['i']
                status = event['X']  # NEW, PARTIALLY_FILLED, FILLED, CANCELED
                filled_qty = event['z']
                last_price = event['L']
                
                process_order_update(order_id, status, filled_qty, last_price)
            
            elif event['e'] == 'outboundAccountPosition':
                # Обновление баланса
                for asset in event['B']:
                    process_balance_update(asset['a'], asset['f'], asset['l'])

Rate Limits

Binance имеет два типа лимитов:

• Request Weight Limit: 6000 weight/минуту. Разные эндпоинты имеют разный вес (GET /ticker/price = 1, GET /depth?limit=5000 = 250)
• Order Rate Limit: 10 ордеров/сек, 100,000 ордеров/24 часа

# Проверяем rate limit headers в каждом ответе
async def check_rate_limits(response_headers: dict):
    used_weight = int(response_headers.get('X-MBX-USED-WEIGHT-1M', 0))
    order_count = int(response_headers.get('X-MBX-ORDER-COUNT-10S', 0))
    
    if used_weight > 5000:  # > 83% лимита — замедляемся
        await asyncio.sleep(1)
    if order_count > 8:  # > 80% лимита — pause
        await asyncio.sleep(0.5)

Интеграция торгового бота с Binance API (spot или futures) с WebSocket потоком данных и user data stream: 1–2 недели. Binance sandbox (https://testnet.binance.vision/) доступен для тестирования без реальных денег.