Python 3.7.1 WebSocket Client にてサーバ接続が頻繁に遮断されてしまう

Question

前提・実現したいこと

Python3.7.1でwebsocketよりAPIを取得してるのですが、
２つあるうちの１つのwebsocketだけが稼働中に頻繁に以下の状態で停止しています。
もう１つは今日の正午から現在も問題なく稼働しています。
また両者のコード自体もAPIの問い合わせ先URLが違うだけで、他のコード内容はすべて同じです。

エラーが起きているのは高頻度にメッセージを受信しているwebsocketで
on_message(): が正常に終了しているにも関わらず on_error():が呼ばれているように見受けられます。

しかし簡易的なエラー内容しか表示されず詳細がわからず行き詰った状況です。

解決方針としてはエラー内容がクライアント側で修正できるものであるならばそうしたいと考えています。

よろしくお願いします。

発生している問題・エラーメッセージ

エラーメッセージ

called on_message

～～～～ 中略 ～～～～～

開始時刻: 2019/04/20 20:28:29
called on_error
Connection is already closed.
called on_close
disconnected streaming server
called on_run
Web Socket process ended.
終了時刻: 2019/04/20 20:32:30

該当のソースコード

    # when we get message
    def on_message(self, ws, message):
        print("called_on_message")
        l_posi = 0
        s_posi = 0

　　　　　～～～～～中略～～～～～

            print("開始時刻:",time)
            l_posi = 0
            s_posi = 0

    # when error occurs
    def on_error(self, ws, error):
        print("called on_error")
        logger.error(error)

    # when websocket closed.
    def on_close(self, ws):
        print("called on_close")
        logger.info('disconnected streaming server')
        
    # when websocket opened.
    def on_open(self, ws):
        print("called on_open")
        logger.info('connected streaming server')
        output_json = json.dumps(
            {'method' : 'subscribe',
            'params' : {'channel' : self.channel}
            }
        )
        ws.send(output_json)

試したこと

エラー内容の箇所を突き止めようとprint分を挟んでみたが、
特にエラー個所が見当たらずプログラム的なミスは今のところ突き止められていない。

補足情報

try - exception の構文で解決できる場合、書き方を教えてください。

Answer 1

Connection is already closed.というエラーは、サーバー側から接続を切断された可能性が高いです。

質問の中にあるコードには、バグはないと思われます。
質問にある問題を解消するためには、サーバー側の接続条件等を調査して、切断された時に再接続をするコード等を追加で作成する必要があると思われます。

Comments

[wiz_planet]

ご回答ありがとうございます！
ちなみに再接続するコードをtry - exceptを書きたいのですが
どこに書けばいいなどおわかりになればアドバイスもらえませんか？？

[wiz_planet]

追記ですが、調べて自分なりに解決コードを以下のように書いてみました。
１．Realtime APIへの 接続部分を関数化
２． メイン関数内のAPI実行のrun()部分の例外処理にAPI接続用の関数を書く
まだエラー自体が起きてないのでなんとも言えませんが、
明日まで回してみて様子見したいと思います。

[YasuhiroNiji]

run()部分の例外処理は既に行われていて、on_error が呼び出されるようになっているため、try - except を書いても何もおこならいと思います。API接続用の関数を書くとすれば、on_error 関数の中ということになるのですが、それでは close を止めれないよう思います。
何かのパッケージを使っているのであれば、パッケージのソースコードを見て'Connection is already closed' というエラーを発生させている箇所を探して、その前に再接続の処理を入れないといけないように思います。結構難しいと思います。
とりあえず、linux系であれば systmed に組み込んで自動起動させるようにしてみたらどうですか。

[wiz_planet]

おっしゃる通り今朝確認したら稼働後2時間くらいで止まってました。
エラー箇所はwebsocket部分が怪しいと思いbokehというフォルダを調べてみましたがエラーをどこで吐いてるか突き止められませんでした。
また自動起動だと一度メモリが飛ぶので蓄積したデータが飛ぶのでプログラム内で完結させたいところですね。。ただメモリ消費が10GBほど使用しておりＰＣが固まった状態だったので、もしかするとここが原因なのかもしれないと思い、メモリ開放の処理を先にやりたいと思います。が、ここも知識がないので調べつつということになるんですが、わからなかったら質問させていただこうと思います。

[wiz_planet]

あれからmac環境で試行錯誤しましたがターミナルのメモリが増大して停止することが確認できました。
プログラムが動作している間、ターミナルが出力文を消去せずに動いていることが原因でした。
プログラム稼働中に定期的に出力文を消す方法を探ってみたいと思います。
ありがとうございました。