Код:
импорт потоковая
импорт WebSocket
импорт JSON
Класс mtgox (threading.Thread):
Защита пробег (Я):
websocket.enableTrace (True)
URL = 'WS: //websocket.mtgox.com/mtgox Валюта = USD'
self.socket = websocket.WebSocketApp (URL, ON_OPEN = self.on_open)
self.socket.run_forever ()
Защиту подписаться (я, канал):
Выход = { 'оп': 'mtgox.subscribe', 'типа': канал}
выход = json.dumps (выход)
self.socket.send (выход)
Защиту ON_OPEN (я, сокет):
self.subscribe ( 'глубина')
self.subscribe ( 'лаг')
self.subscribe ( 'тикер')
self.subscribe ( 'сделка')
если __name__ == '__main__':
mtgox = mtgox ()
mtgox.start ()
импорт WebSocket
импорт JSON
Класс mtgox (threading.Thread):
Защита пробег (Я):
websocket.enableTrace (True)
URL = 'WS: //websocket.mtgox.com/mtgox Валюта = USD'
self.socket = websocket.WebSocketApp (URL, ON_OPEN = self.on_open)
self.socket.run_forever ()
Защиту подписаться (я, канал):
Выход = { 'оп': 'mtgox.subscribe', 'типа': канал}
выход = json.dumps (выход)
self.socket.send (выход)
Защиту ON_OPEN (я, сокет):
self.subscribe ( 'глубина')
self.subscribe ( 'лаг')
self.subscribe ( 'тикер')
self.subscribe ( 'сделка')
если __name__ == '__main__':
mtgox = mtgox ()
mtgox.start ()
Когда я запускаю этот код я получаю информер и глубины сообщения, но без задержек или торговых сообщений. Кроме того, я не получаю ответы на мои команды mtgox.subscribe, что документация, кажется, обещает. Однако, когда я отправить команду mtgox.subscribe с параметром неправильного типа, я получаю сообщение об ошибке "Неизвестный mtgox тип сообщения", Так что кажется, мои подписываются команды получены и приняты.
Может кто-нибудь пожалуйста, скажите мне, почему я не получаю торговые и отсроченные сообщения?