pubsub.py

from mqtt import MQTTClient
import time

def pub(server, topic, messaage):
    client = MQTTClient("ESP32_Client", server)
    client.connect()
    client.publish(bytearray(topic), bytearray(messaage))
    time.sleep(1)
    client.disconnect()

def read_msg(tpc, msg):
    print(tpc, msg)

def sub(server, topic):
    client = MQTTClient("ESP32_Client", server)
    client.set_callback(read_msg)
    client.connect()
    client.subscribe(bytearray(topic))

    while True:
        if True:
            client.wait_msg()
        else:
            client.chech_msg()
            time.sleep(1)
    client.disconnect()