import paho.mqtt.client as mqtt, json, ssl
class MQTTPublisher:
    def __init__(self, host, port, prefix):
        self.prefix = prefix
        self.cli = mqtt.Client()
        self.cli.connect(host, port, keepalive=60)
    def publish(self, device_id: str, payload: dict):
        topic = f"{self.prefix}/{device_id}/dose"
        print(topic)
        self.cli.publish(topic, json.dumps(payload), qos=1)