Wie wird WebSocket in Python Tornado an den Child-Prozess übergeben?

Question

Ich habe einen Tornado-Server mit einigen Websockethandlern. Ich möchte einen Pool von Arbeitern schaffen, um einen Arbeiter als Kindprozess zu starten und eine Websocket-Verbindung zum Arbeiter herzustellen. Nachdem der Arbeiter fertig ist, sollte er eine Antwort an den Kunden senden.

def worker(message): 
    inp_dict = json.loads(message) 
    t = inp_dict["time"] 
    time.sleep(t) 
    return "Hello, World! "*int(t) 

class WebSocket(tornado.websocket.WebSocketHandler): 
    def check_origin(self, origin): 
     return True 

    def open(self): 
     print("WebSocket opened") 

    def on_message(self, message):  
     self.write_message(worker(message)) 

    def on_close(self): 
     print("WebSocket closed") 

Wie geht das?

Answer 1

Verbindungen zwischen Prozessen Passing wird nicht unterstützt. Lassen Sie stattdessen die Verbindungen im Hauptprozess und verwenden Sie z. a multiprocessing.Queue um einfache Objekte (einfache alte Daten) hin und her zu den Child-Prozessen zu senden.