stream.py 文件源码

def stream(self):
        ws_app = websocket.WebSocketApp(
            self.url,
            on_message=self._on_message,
            on_error=self._on_error,
            on_close=self._on_close
        )
        # FIXME: {'Authorization': os.environ.get('RISEML_APIKEY')}
        ws_app.run_forever()