web.py 文件源码

def callback(self, channel, method, header, body):
        machine = method.routing_key.split(".")[0]
        data = json.loads(body.decode("utf-8"))
        data['machine'] = machine
        try:
            self.write_message(data)
        except websocket.WebSocketClosedError as e:
            self.on_close()