我一直在尝试使用python websocket-client模块从交换机接收和存储持续更新.通常,在引发以下错误之前,脚本将平稳运行一天左右:websocket._exceptions.WebSocketConnectionClosedException: Connection is already closed.
我查看了websocket-client源代码,显然代码中的第92行引发了错误if not bytes_:.此外,WebSocketConnectionClosedException应该提出"If remote host closed the connection or some network error happened".
任何人都可以告诉我为什么会这样,以及我能做些什么来阻止或处理它.
我想要完成的是从 Twitter 传输一小时的推文，将推文列表写入文件，清理并运行最近一小时的推文分析，然后无限期地重复该过程。
我遇到的问题是，如果我在处理流的同一脚本中运行推文的清理和分析 - 通过对其进行硬编码或从模块导入功能 - 整个脚本将等待这些过程完成，然后再次开始流式传输。有没有办法在流脚本中调用清理和分析模块，以便它们同时运行，并且在清理和分析发生时流不会停止？
我尝试通过使用subprocess.call('python cleaner.py', shell=True)和来实现此subprocess.Popen('python cleaner.py', shell=True)目的，但我真的不知道如何正确使用这些工具，上面的两个示例导致流媒体停止、cleaner.py运行，然后恢复流媒体。