Websocket не открывает соединение ⇐ Python
-
Anonymous
Websocket не открывает соединение
Я пытаюсь использовать websocket вместо rest API, но событие on_open, похоже, не работает. Я получаю событие on_close только через некоторое время, но не могу найти никаких проблем. Скрипт завершается без ошибок. Я не понимаю, что такое параметр ws в методе on_open и где он определен.
Пример ниже взят с
. импортировать веб-сокет импорт потоков импортировать _thread импортировать JSON класс SocketConn(websocket.WebSocketApp): def __init__(self, url, params=[]): super().__init__(url=url, on_open=self.on_open) self.params = параметры self.on_message = лямбда ws, сообщение: self.message(msg) self.on_error = лямбда ws, e: print('Error', e) self.on_close = лямбда ws: print('Закрытие') self.run_forever() def on_open(self, ws,): print('Веб-сокет был открыт') защита запуска (* аргументы): tradeStr = { "method":"SUBSCRIPTION", "params":self.params } ws.send(json.dumps(tradeStr)) _thread.start_new_thread(запустить, ()) сообщение def (я, сообщение): печать (сообщение) threading.Thread(target=SocketConn, args=('wss://wbs.mexc.com/ws',["spot@public.deals.v3.api@BTCUSDT"])).start()
Я пытаюсь использовать websocket вместо rest API, но событие on_open, похоже, не работает. Я получаю событие on_close только через некоторое время, но не могу найти никаких проблем. Скрипт завершается без ошибок. Я не понимаю, что такое параметр ws в методе on_open и где он определен.
Пример ниже взят с
. импортировать веб-сокет импорт потоков импортировать _thread импортировать JSON класс SocketConn(websocket.WebSocketApp): def __init__(self, url, params=[]): super().__init__(url=url, on_open=self.on_open) self.params = параметры self.on_message = лямбда ws, сообщение: self.message(msg) self.on_error = лямбда ws, e: print('Error', e) self.on_close = лямбда ws: print('Закрытие') self.run_forever() def on_open(self, ws,): print('Веб-сокет был открыт') защита запуска (* аргументы): tradeStr = { "method":"SUBSCRIPTION", "params":self.params } ws.send(json.dumps(tradeStr)) _thread.start_new_thread(запустить, ()) сообщение def (я, сообщение): печать (сообщение) threading.Thread(target=SocketConn, args=('wss://wbs.mexc.com/ws',["spot@public.deals.v3.api@BTCUSDT"])).start()
