Работа с Binance через WebSockets

Добрый день, можете подсказать, что означает эта ошибка при выполнении:
"wss://stream.binance.com:9443/ws/ethbtc@kline_5m"
### connected ###
{"e":"kline","E":1535014904715,"s":"ETHBTC","k":{"t":1535014800000,"T":1535015099999,"s":"ETHBTC","i":"5m","f":78705608,"L":78705736,"o":"0.04261000","c":"0.04259300","h":"0.04262500","l":"0.04259200","v":"47.97100000","n":129,"x":false,"q":"2.04394491","V":"24.24100000","Q":"1.03311231","B":"0"}}
'>' not supported between instances of 'float' and 'NoneType'
### closed ###

Андрей, спасибо за быстрый ответ. 
Мне понятно, что означает это сообщение (его перевод), но непонятно как оно вообще может возникнуть при выполнении скрипта с этой страницы, где нет никаких сравнений переменных и т.п.
Возможно ошибка возникает при отработке WebSocketApp, причем вначале 1 раз возникает событие on_message (все ок), а затем on_error (с этой ошибкой)

До этого устанавливался 0.51.0, удалил потом и установил pip install websocket-client==0.21.0
и всё равно Пишит:
Traceback (most recent call last):
  File "websocket.py", line 17, in <module>
    ws = websocket.WebSocketApp("wss://stream.binance.com:9443/ws/ltcbtc@aggTrade/ethbtc@aggTrade",
AttributeError: module 'websocket' has no attribute 'WebSocketApp'
>>> 
первый код</module>

Доброго времени суток... Скажите пожалуйста, в одной из статей Вы упомянули что биржа Бинансе каждому зарегистрированному пользователю присваевает свой ID-номер. Можно ли в через websocket или  api получать связку данных по торгам ввиде ID-user+order(параметры ордера такие как размер ордера, тип ордера) для анализа ситуации по стакану? Или для отслеживания торгового поведения пользователя (например крупного игрока)?

Да, взято с официального описания. Может быть, в источнике что-то добавится, но пока тенденции к этому не было
https://github.com/binance-exchange/binance-official-api-docs/blob/master/web-socket-streams.md
Еще есть полузакрытые источники - https://github.com/binance-exchange/binance-official-api-docs/blob/master/user-data-stream.md
Там можно отслеживать состояние своего баланса и получать информацию по своим ордерам.
Что бы эмулировать активность, наверное нужно подписаться на все trades и делать выводы самостоятельно

Добрый день!
Не могу разобраться в сборе локального ордербука.
После того как вытаскивается текущий стакан с https://www.binance.com/api/v1/depth?symbol=BNBBTC&limit=1000 мы обновляем его данными накопленными со стрима. 
Паралельно с поступлением обновленией ордербука происходит торговля, т.е. некоторые ордера уже реализованы.
Возможно есть примеры реализации локальных стаканов?.
Заранее благодарен!

Насчет примера - да, можете расковырять код из статьи https://bablofil.ru/inner-arbitrage/
Там как раз формируются стаканы по всем парам и поддерживаются в актуальном состоянии.
Технически, как только вы совершаете куплю/продажу, прилетает сообщение из сокета, так что прям уж рассинхрона быть не должно

скажите, если возможность подписаться сразу на все пары альтернативным способом чес этот ? 
"wss://stream.binance.com:9443/ws/ethbtc@kline_1m/ltcbtc@kline_1m/bnbbtc@kline_1m/neobtc@kline_1m/qtumeth@kline_1m.................." etc...

А то получается очень длинная строка если подписаться сразу на все ~400 пар. Это мне нужно для создания базы истории торгов.

Спасибо за ответ. 
Еще я заметила странность, если запросить цены '/api/v3/ticker/price' то я получаю 412 уникальных пар, а вот если добавить их в /ws/ethbtc@kline_1m/все_412_пар/   то биржа выдает в стрим 382 свечи со статусом "x":true. Причем всегда  одинаково 382.
Интересно куда деваются 30 свечей как думаете ?

А зачем вы вручную пары указываете? Я беру при старте exchangeInfo через rest, оттуда беру каждую пару 
ws = websocket.WebSocketApp("wss://stream.binance.com:9443/ws/" +
                                        '/'.join([symbol['symbol'].lower() + '@kline_1m' for symbol in limits['symbols'] ....

Спасибо за совет. Как раз для этого решила перейти на Couchbase Server.

Доделываю этот скриптик, но проблема. Состояние позиции и работа моего цикла  асинхронны.  В цикле через слишком быстрый while получаю цены, из за чего отправленные заявки дублируются. Замедление решит проблему, но это слишком просто).  В двух словах подскажите как избежать дублирование заявок?

Андрей, здравствуйте! Подскажите по Binance API... Я подписался на стримы Trade и aggTrade  - как мне понять где Buy или Sell, цель отслеживать крупные сделки по парам....
{ e: 'trade',
  E: 1552973882978,
  s: 'BTCUSDT',
  t: 107095642,
  p: '3980.42000000',
  q: '0.00293000',
  b: 291269640,
  a: 291269650,
  T: 1552973882973,
  m: true,
  M: true }

Интересует поле

"m": true,        // Is the buyer the market maker?

Тут на самом деле вопрос с подвохом, т.к. если один купил а другой продал, то это покупка или продажа?
В истории торгов на самой бирже зеленым подсвечиваются сделки, у которых isBuyerMaker == false, и маджентой - у кого true
Соответственно, если у вас поле m == true, то оно на бирже подсветилось бы красным, а если false, то зеленым

import json
import websocket

def on_message(ws, message):
    obj = json.loads(message)
    print(obj['s'], obj['p'])

def on_error(ws, error):
    print(error)

def on_close(ws):
    print("### closed ###")

def on_open(ws):
    print("### connected ###")

if __name__ == "__main__":
    ws = websocket.WebSocketApp("wss://stream.binance.com:9443/ws/ltcbtc@aggTrade/ethbtc@aggTrade",
                              on_message = on_message,
                              on_error = on_error,
                              on_close = on_close)
    ws.on_open = on_open
    ws.run_forever()

Добавьте, плиз:
    #print( message )
    print( json.dumps( json.loads(message), indent=3, separators=(',',': ') ) )

Замучался искать, по инетам, у Вас же и нашел в "Чего бы с биржи стянуть? Изучаем API и способы работы с ним."

Огромное спасибо за статью!
Благодаря Вам наконец-то сделал "криптотикер", который не останавливается из-за превышения ограничений по REST запросам
может кому нужно..выкладываю код , работает на старом нетбуке 2009 года выпуска.
import websocket
import json
from turtle import *
import time

t = Turtle()
t.screen.setup(800,550)
t.screen.bgcolor("#002137")
t.color('yellow')
b=1
def on_message(ws, message):
    obj = json.loads(message)
    print(obj["s"], obj["p"])
    price=float(obj["p"])
    print(price)
    t.clear()
    t.color('yellow')
    t.goto(-400,130)
    t.write((price),font=("Arial", 100, "bold"))
    t.color('yellow')
    t.goto(-400,20)
    t.write(('BINANCE BTC USDT'),font=("Arial", 50, "bold"))
    time.sleep(1)
    
def on_error(ws, error):
    print(error)

def on_close(ws):
    print("### closed ###")

def on_open(ws):
    print("### connected ###")

if __name__ == "__main__":
    #ws = websocket.WebSocketApp("wss://stream.binance.com:9443/stream?streams=ltcbtc@aggTrade/ethbtc@aggTrade",
    ws = websocket.WebSocketApp("wss://stream.binance.com:9443/ws/btcusdt@aggTrade",
                              on_message = on_message,
                              on_error = on_error,
                              on_close = on_close)
"""
    t.clear()
    t.color('yellow')
    t.goto(-400,130)
    t.write((price),font=("Arial", 100, "bold"))
    t.color('yellow')
    t.goto(-400,20)
    t.write(('BINANCE SPOT Account'),font=("Arial", 50, "bold"))
"""
ws.on_open = on_open
ws.run_forever()

Я правильно понял, что klines тут возвращает только текущую свечу? Нельзя, как тут https://api.binance.com/api/v1/klines?symbol=LTCBTC&interval=5m, получать, скажем 100 последних свечей?

Здравствуйте! Спасибо за ваши статьи!
Может вы знаете как обработать одновременно данные со спот и срочного рынков?

import multiprocessing.dummy as multiprocessing
import websocket
def on_message(ws, message):
    print(message)

def on_error(ws, error):
    print(error)

def on_close(ws):
    print("Отключен")

def on_open(ws):
    print("Подключен")


def a():
    ws = websocket.WebSocketApp("wss://stream.binance.com:9443/ws/ethusdt@aggTrade",
                              on_message = on_message,
                              on_error = on_error,
                              on_close = on_close)
    ws.on_open = on_open
    ws.run_forever()
def b():
    ws = websocket.WebSocketApp("wss://fstream.binance.com:9443/ws/ethusdt@aggTrade",
                              on_message = on_message,
                              on_error = on_error,
                              on_close = on_close)
    ws.on_open = on_open
    ws.run_forever()

p1 = multiprocessing.Process(target=a) 
p2 = multiprocessing.Process(target=b) 

p1.start() 
p2.start() 

p1.join() 
p2.join() 

Почему-то выводит только первый вебсокет. Что я делаю не так?

Потому то первый уходит в бесконечный цикл, так задумано, а второй  ждет когда он закончит.
Запускайте в разных потоках, посмотрите эту статью https://bablofil.com/python-multithreading/