Python3 Websocket Callback не может назначать функции-члены класса

Question

Я использую Python 3.6 в Ubuntu 18.04.

У меня есть класс, и я пытаюсь добавить к нему сервер WebSocket.Я использую модуль веб-сокетов Python, найденный здесь: https://github.com/websocket-client/websocket-client

Этот проект имеет пример, который выглядит следующим образом:

import websocket

def on_message(ws, message):
    print(message)

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

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

def on_open(ws):
    def run(*args):
        for i in range(3):
            time.sleep(1)
            ws.send("Hello %d" % i)
        time.sleep(1)
        ws.close()
        print("thread terminating...")
    thread.start_new_thread(run, ())


if __name__ == "__main__":
    websocket.enableTrace(True)
    ws = websocket.WebSocketApp("ws://echo.websocket.org/",
                              on_message = on_message,
                              on_error = on_error,
                              on_close = on_close)
    ws.on_open = on_open
    ws.run_forever()

В моем коде я делаю следующее вКонструктор для моего класса:

# Configure a command and control websocket
self.commandWebsocket = None
self.commandWebsocketThread = threading.Thread(target=self.configureAndRunCommandChannelWebsocket, args=(commandAndControlPort,))
self.commandWebsocketThread.daemon = True
self.commandWebsocketThread.start()

И настроить веб-сокет следующим образом:

def onCommandChannelWebsocketMessage(self, ws, message):
    self.debugPrint("Websocket Message: %s"%(message))

def onCommandChannelWebsocketError(self, ws, error):
    self.debugPrint("Websocket Error: %s"%(error))

def onCommandChannelWebsocketClose(self, ws):
    self.debugPrint("Websocket Closed ...")

def onCommandChannelWebsocketOpen(self, ws):
    self.debugPrint("Websocket Opened ...")
    def run(*args):
        for i in range(30000):
            time.sleep(1)
            ws.send("Hello %d" % i)
        time.sleep(1)
        ws.close()
    #thread.start_new_thread(run, ())

def configureAndRunCommandChannelWebsocket(self,wsPort):

    self.debugPrint("Configuring Command and Control Websocket with: %s ..."%(wsPort))
    websocket.enableTrace(True)
    self.commandWebsocket = websocket.WebSocketApp("ws://0.0.0.0:%s/"%(wsPort))
    self.commandWebsocket.on_message = self.onCommandChannelWebsocketMessage
    self.commandWebsocket.on_error = self.onCommandChannelWebsocketError
    self.commandWebsocket.on_close = self.onCommandChannelWebsocketClose
    self.commandWebsocket.on_open = self.onCommandChannelWebsocketOpen
    self.commandWebsocket.run_forever()

Однако я всегда получаю ошибку:

error from callback <bound method Camera.onCommandChannelWebsocketError of <Cameras.Camera.Camera object at 0x7f34316a58>>: onCommandChannelWebsocketError() missing 1 required positional argument: 'error'
[Camera.py / Camera]: Pipeline: v4l2src device=/dev/video2 ! video/x-raw, width=(int)160, height=(int)120,format=GRAY16_LE ! appsink
  File "/usr/local/lib/python3.6/dist-packages/websocket/_app.py", line 343, in _callback
    callback(*args)
error from callback <bound method Camera.onCommandChannelWebsocketClose of <Cameras.Camera.Camera object at 0x7f34316a58>>: onCommandChannelWebsocketClose() missing 1 required positional argument: 'ws'
[Camera.py / Camera]: Initializing a Generic Camera
  File "/usr/local/lib/python3.6/dist-packages/websocket/_app.py", line 343, in _callback
    callback(*args)

Что яделаю не так и как можно это исправить?Спасибо!

Answer 1

Измените настройки на следующие:

def onCommandChannelWebsocketMessage(self, message):
    self.debugPrint("Websocket Message: %s"%(message))

def onCommandChannelWebsocketError(self, error):
    self.debugPrint("Websocket Error: %s"%(error))

def onCommandChannelWebsocketClose(self):
    self.debugPrint("Websocket Closed ...")

def onCommandChannelWebsocketOpen(self):
    self.debugPrint("Websocket Opened ...")
    def run(*args):
        for i in range(30000):
            time.sleep(1)
            self.send("Hello %d" % i)
        time.sleep(1)
        self.close()
    #thread.start_new_thread(run, ())

def configureAndRunCommandChannelWebsocket(self,wsPort):

    self.debugPrint("Configuring Command and Control Websocket with: %s ..."%(wsPort))
    websocket.enableTrace(True)
    self.commandWebsocket = websocket.WebSocketApp("ws://0.0.0.0:%s/"%(wsPort))
    self.commandWebsocket.on_message = self.onCommandChannelWebsocketMessage
    self.commandWebsocket.on_error = self.onCommandChannelWebsocketError
    self.commandWebsocket.on_close = self.onCommandChannelWebsocketClose
    self.commandWebsocket.on_open = self.onCommandChannelWebsocketOpen
    self.commandWebsocket.run_forever()