如何避免在高速公路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 (将#修改为@）

autobahn python twisted