Python Websocketを使ったクラスがすぐCloseされる。

Question

#環境

• Python 3.8
• Win10上のmsys2上のmingwを使っている

　
#解決したいこと。
CoinCHeckのAPIを使って取引情報を逐次とってくるクラスを作りたいなと思っている。
でも、下のコードでは実行しても、何も表示されない。。

import json
from websocket  import WebSocketApp


class CoinCheck_CandleMaker:

    URL = "wss://ws-api.coincheck.com/"
    MAX_CANDLE_LEN = 24 * 60

    def __init__(self,t_sec=60):
        self.__span_T=t_sec
        self._candle=[]

        self.__connect()
    
    def __connect(self):
        self.ws=WebSocketApp(self.URL,
                                on_message=self.__on_message,
                                on_open=self.__on_open,
                                on_close=self.__on_close,
                                on_error=self.__on_error
                                )
        
        try:
            self.ws.run_forever()
        except KeyboardInterrupt:
            self.ws.close()

    def __on_open(self,ws):
        print("open")

        self.ws.send(
            json.dumps({
                "type":"subscribe",
                "channel": "btc_jpy-trades"
            })
        )
    def __on_message(self,ws,message):
        print(message)
    
    def __on_close(self,ws):
        print("close")
    
    def __on_error(self,ws,error):
        print(error)
        self.__reconnect()
    
    def __reconnect(self):
        print("Try reconnect")


if __name__=="__main__":
    test=CoinCheck_CandleMaker()

以下のコードを実行すると自分が期待している動きをする。

import json
from websocket  import WebSocketApp

def On_open(ws):
        print("open")

        ws.send(
            json.dumps({
                "type":"subscribe",
                "channel": "btc_jpy-trades"
            })
        )        

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


ws=WebSocketApp("wss://ws-api.coincheck.com/",on_message=On_message,on_open=On_open)

ws.run_forever() 

...
[164127931,"btc_jpy","3287382.0","0.01","buy"]
[164127932,"btc_jpy","3287382.0","0.005","buy"]
[164127933,"btc_jpy","3287397.0","0.072","buy"]
[164127934,"btc_jpy","3287397.0","0.2","buy"]
[164127935,"btc_jpy","3286636.0","0.0158","sell]
...

#何が問題なんでしょうか？？
ぜひ指摘していただけるとありがたいです、もやっとしたことでも構いません

Answer 1

おそらく根本的な回答

お使いの websocket-client は長らくメンテされていないのでメンテされている websockets を使いましょう。

おそらく根本的でない答え

例えば on_open に関数を渡したとするとこのライブラリはそれが「ただの関数」なのか「オブジェクトのメソッド」なのかによって振る舞いを変えます。単なる関数の場合は渡された関数の第一引数に WebSocketApp の self を渡します。ドキュメントに書かれてあった def on_open(ws): とはそういうことだったのです。もしオブジェクトのメソッドだった場合は self を渡さないだけです。この動作についてはこのあたりに書いてあります。

hidekiti さんが上げていただいたコードの def __on_open(self,ws): という宣言ですが、ws が余計だったのです。オブジェクトのメソッドを渡しているので不要だった、というわけです。

Comments

[hidekiti]

ありがとうございます！
なんでwsを渡すのか不思議だったんです。！
色々解決しました！