exchange_websocket.py 文件源码

def run(self) -> None:
        log.startLogging(open(datetime.now().strftime('logs/websocket_%d_%m_%Y.log'), 'a'))
        factory = MyClientFactory(self.URL)
        factory.protocol = self.protocol
        connectWS(factory)

        default_handler = signal.getsignal(signal.SIGINT)

        signal.signal(signal.SIGINT, signal.SIG_IGN)
        reactor.run()
        signal.signal(signal.SIGINT, default_handler)
        if reactor.running:
            reactor.stop()