Untitled

import paho.mqtt.client as mqtt

# MQTT broker settings
broker_address = "localhost"
broker_port = 1883
topic = "test_topic"

# Callback function to handle received messages
def on_message(client, userdata, message):
    print("Received message: ", str(message.payload.decode("utf-8")))

# Create MQTT client and connect to broker
client = mqtt.Client()
client.connect(broker_address, broker_port)

# Set callback function for received messages
client.on_message = on_message

# Subscribe to the topic
client.subscribe(topic)

# Start the MQTT client loop
client.loop_forever()