How can I implement a pub-sub system in Python?

How can I implement a pub-sub system in Python?

You can implement a pub-sub system in Python using libraries like Paho MQTT or Redis. Would you like a code example?

Yes, please provide a simple code example using Paho MQTT.

Here's a basic example:

import paho.mqtt.client as mqtt

# Callback when a message is received
def on_message(client, userdata, message):
    print(f'Message received: {message.payload.decode()}')

client = mqtt.Client()
client.on_message = on_message

client.connect('mqtt.eclipse.org')
client.subscribe('test/topic')

client.loop_start()

# Publish a message
client.publish('test/topic', 'Hello, World!')

# Keep the script running
import time
time.sleep(10)
client.loop_stop()
client.disconnect()

What are the advantages of using a pub-sub model?

The pub-sub model decouples publishers and subscribers, allowing for scalable and flexible communication. It also supports asynchronous messaging.