如何解决如何避免在高速公路Python中使用ReactorNotRestartable
我有一个基于python的页面,该页面通过POST接收数据,然后使用Autobahn(Wamp)将其转发到Crossbar服务器。前1-2次效果很好,但是之后再次调用它会抛出ReactorNotRestartable
。
现在,我需要此方法以尽可能的方式工作,或者通过基于条件检查的方式重新使用此“反应器”,或者在每次运行后适当地停止它。 (第一个比较可取,因为它可以减少执行时间)
感谢您的帮助!
编辑:
这是在网页( Django View )中,因此它需要运行与加载页面/通过POST发送数据一样多的次数。
from twisted.internet import reactor
from twisted.internet.defer import inlineCallbacks
from twisted.internet.endpoints import TCP4ClientEndpoint
from twisted.application.internet import ClientService
from autobahn.wamp.types import ComponentConfig
from autobahn.twisted.wamp import ApplicationSession,WampWebSocketClientFactory
class MyAppSession(ApplicationSession):
def __init__(self,config):
ApplicationSession.__init__(self,config)
def onConnect(self):
self.join(self.config.realm)
def onChallenge(self,challenge):
pass
@inlineCallbacks
def onJoin(self,details):
yield self.call('receive_data',data=message)
yield self.leave()
def onLeave(self,details):
self.disconnect()
def ondisconnect(self):
reactor.stop()
message = "data from POST[]"
session = MyAppSession(ComponentConfig('realm_1',{}))
transport = WampWebSocketClientFactory(session,url='ws://127.0.0.1:8080')
endpoint = TCP4ClientEndpoint(reactor,'127.0.0.1',8080)
service = ClientService(endpoint,transport)
service.startService()
reactor.run()
我通过使用多处理并在函数调用之后将reactor.stop()
放在onJoin()
中,发现了一种可能不太好用的方法。这样,我不必担心“扭曲在主线程中运行”的事情,因为一旦我的工作完成,它的进程就会被杀死。
有更好的方法吗?
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。