import paho.mqtt.client as m

def recv_msg(client, userdate, msg):
    print(f"MSG: {msg.payload.decode()} TOPIC: {msg.topic}")


    c = m.Client("skenz_actuator_2")
    c.connect("broker.emqx.io")

    if float(msg.payload.decode()) > 20.0:
        fan = "ON"
    else:
        fan = "OFF"
    print(fan)
    c.publish("classroom1/fan", fan)


client = m.Client("skenz_server")
client.connect("broker.emqx.io") # Other broker: broker.emqx.io                                                        
client.on_message = recv_msg
client.subscribe("classroom1/temp")

client.loop_forever()