我有两个python程序无限运行。在
第一个进程使用Twisted和Autobahn从WebSocket提要接收数据。这是一个无限循环。
第二个进程使用自定义库从Pusher WebSocket feed接收数据。它也是一个无限循环
我正在寻找一种方法,使这两个进程与第三个进程通信。第三个进程必须能够与两个进程进行双向通信。因此,第三个进程必须能够推送并接收来自两个程序的消息。在
我尝试使用多处理和队列,但没有成功。在
这是第一个过程:
from twisted.internet import reactor
from autobahn.twisted.websocket import WebSocketClientFactory, WebSocketClientProtocol, connectWS
import json
class ClientProtocol(WebSocketClientProtocol):
...
def onMessage(self, msg, binary):
...
# Send data to third process
...
if __name__ == '__main__':
factory = WebSocketClientFactory("wss://feed.com")
factory.protocol = ClientProtocol
connectWS(factory)
reactor.run()
这是第二个过程:
^{pr2}$
目前没有回答
相关问题 更多 >
编程相关推荐