49 lines
963 B
Python
49 lines
963 B
Python
import paho.mqtt.publish as publish
|
|
|
|
|
|
class MqttClient:
|
|
def __init__(self, config):
|
|
self._config = config
|
|
|
|
def publish(self, messages):
|
|
publish.multiple(list(map(lambda m: m.as_dict, messages)),
|
|
hostname=self.hostname,
|
|
auth={'username': self.username, 'password': self.password})
|
|
|
|
@property
|
|
def hostname(self):
|
|
return self._config['host']
|
|
|
|
@property
|
|
def username(self):
|
|
return self._config['username']
|
|
|
|
@property
|
|
def password(self):
|
|
return self._config['password']
|
|
|
|
|
|
class MqttMessage:
|
|
def __init__(self, topic=None, payload=None):
|
|
self._topic = topic
|
|
self._payload = payload
|
|
|
|
@property
|
|
def topic(self):
|
|
return self._topic
|
|
|
|
@topic.setter
|
|
def topic(self, new_topic):
|
|
self._topic = new_topic
|
|
|
|
@property
|
|
def payload(self):
|
|
return self._payload
|
|
|
|
@property
|
|
def as_dict(self):
|
|
return {
|
|
'topic': self.topic,
|
|
'payload': self.payload
|
|
}
|