python
from flask_socketio import SocketIO
socketio = SocketIO()python
socketio.init_app(app)python
from apps.system.extentions import socketio
from flask_socketio import emit
@socketio.event
def my_event(message):
print("flask recv", message)
emit("my response", {"data": "got it!"})
@socketio.on("message")
def handle_message(data):
print("received message: ", data)
@socketio.on("chat")
def handle_message(data):
print("received chat: ", data)
@socketio.on("cmd")
def handle_message(cmd_data):
print("received cmd: ", cmd_data)
topic_flag = "/baby/v2/{}/cmd".format(cmd_data["mac"])
send_data = {"uuid": str(uuid.uuid4())}
send_data.update(cmd_data)
mqtt.publish(topic_flag, json.dumps(send_data).encode())