zynthian_websocket_handler.py 文件源码

def on_message(self, message):
        if message:
            decoded_message = jsonpickle.decode(message)
            logging.info("incomding ws message %s " % decoded_message)
            handler = ZynthianWebSocketMessageHandlerFactory(decoded_message['handler_name'], self)
            handler.on_websocket_message(decoded_message['data'])
            self.handlers.append(handler)

    # client disconnected