PythonのWebsocket通信について

Question

##websocketライブラリについて
pythonのwebsocketライブラリ（https://githubja.com/websocket-client/websocket-clientにgithubURLや日本語訳が載っています）について質問があります。

import websocket
import json
import pprint
import time




class RealtimeAPI(object):

    def __init__(self,url,channel):
        self.url = url
        self.channel = channel
        self.ws = websocket.WebSocketApp(self.url,header=None,on_message=self.on_message,\
                                        on_open=self.on_open,on_close=self.on_close,on_error=self.on_error)
        # websocket.enableTrace(True)
        
    def run(self):
        self.ws.run_forever()
        
    def on_message(self,ws,message):
        message = json.loads(message)
        print(message)
    
    def on_error(self,ws,error):
        print(error)
    
    def on_open(self,ws):
        print("websocket connection started.")
        ws.send(json.dumps({"method": "subscribe","params": {"channel": self.channel}}))
    
    def on_close(self,ws):
        print("###websocket connection closed.###")
        
if __name__ == "__main__":
    url = "wss://ws.lightstream.bitflyer.com/json-rpc"
    channel = "lightning_executions_FX_BTC_JPY"
    json_rpc = RealtimeAPI(url=url,channel=channel)
    json_rpc.run()

上のようなコードを作りmessageを表示しようとしたのですが、エラーで止まることはないのですがmessageがprintされません。どこかおかしいところはありますか？なお、中盤のwebsocket.enableTrace(True)を有効にするとrequestとresponseのheaderに加えて

error from callback <bound method RealtimeAPI.on_open of <__main__.RealtimeAPI object at 0x1039bcdd8>>: on_open() missing 1 required positional argument: '
ws'
  File "/anaconda3/lib/python3.6/site-packages/websocket/_app.py", line 343, in _callback
    callback(*args)

と表示されます。
websocket自体他の言語でも扱っていないので、根本的な理解が浅いかもしれませんがよろしくお願いします。

Answer 1

最新のwebsocketは仕様が変更されているようでon_~の関数の引数wsを消してsendをws.sendとすることで動きました。