У меня есть служба веб-сокетов, которая открывает поток, принимает сообщения и т. Д. Я могу создать обработчик событий, который открывает новое соединение, но он не работает для будущих событий.Они будут обрабатываться новым работником, так как взаимодействовать с работающими работниками / зелеными нитями?
class ServiceA:
""" Event dispatching service. """
name = "service_a"
dispatch = EventDispatcher()
@rpc
def dispatching_method(self, payload):
self.dispatch("start_socket", payload)
class ServiceB:
""" Event listening service. """
name = "service_b"
@event_handler("service_a", "start_socket")
def start_socket(url):
sock = websocket.start_socket(url)
gr = eventlet.spawn(sock.run_forever)
Как мне взаимодействовать с sock
или gr
из ServiceA
после вызова start_socket()
?