Adding implementation

Author: JBris

README.md

@@ -1,2 +1,3 @@
 # mqtt-docker-python
-Testing MQTT using Docker and the Python client
+
+Testing MQTT using Docker and the Paho Python client

config/mosquitto.conf

@@ -0,0 +1,11 @@
+allow_anonymous true
+listener 1883
+protocol mqtt
+listener 9001
+protocol websockets
+socket_domain ipv4
+persistence true
+# password_file /mosquitto/config/pwfile
+persistence_file mosquitto.db
+persistence_location /mosquitto/data/
+log_type all

docker-compose.yaml

@@ -0,0 +1,22 @@
+services:
+  mqtt:
+    image: eclipse-mosquitto:2.0-openssl
+    ports:
+      - 1883:1883
+      - 9001:9001
+    volumes:
+      - ./config:/mosquitto/config:rw
+      - mqtt-data:/mosquitto/data
+
+  mqtt_client:
+    image: emqx/mqttx-web:v1.12.0
+    ports:
+      - 9000:80
+      
+networks:
+  default:
+    name: mqtt_docker
+    driver: bridge
+
+volumes:
+  mqtt-data: {}

poetry.lock

@@ -0,0 +1,36 @@
+import paho.mqtt.client as mqtt
+import time
+import random
+import json
+
+def on_message(client, userdata, msg):
+    payload = msg.payload.decode()
+    print(f"Received message: {msg.topic} -> {payload}")
+
+    payload_dict = json.loads(payload)
+
+    if payload_dict["value"] == "exit":
+        print("Exiting")
+        client.exit_flag = True
+
+topic = "paho/temperature"
+mqttc = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2)
+mqttc.on_message = on_message
+mqttc.exit_flag = False 
+
+mqttc.connect("localhost", 1883, 60)
+mqttc.subscribe(topic)
+
+mqttc.loop_start()
+
+while not mqttc.exit_flag:
+    sensor_reading = random.uniform(5, 15)
+    print(sensor_reading)
+
+    json_message = json.dumps({"value": sensor_reading })
+    mqttc.publish(topic, json_message)
+
+    time.sleep(5)
+
+mqttc.loop_stop()
+mqttc.disconnect()

pub_sub_mqtt.py

@@ -0,0 +1,15 @@
+[tool.poetry]
+name = "mqtt-docker-python"
+version = "0.1.0"
+description = ""
+authors = ["James Bristow <james.bristow@plantandfood.co.nz>"]
+readme = "README.md"
+
+[tool.poetry.dependencies]
+python = "^3.10"
+paho-mqtt = "^2.1.0"
+
+
+[build-system]
+requires = ["poetry-core"]
+build-backend = "poetry.core.masonry.api"

pyproject.toml

@@ -0,0 +1,50 @@
+import paho.mqtt.client as mqtt
+import time
+import json
+from enum import Enum, auto
+
+class State(Enum):
+    IDLE = auto()
+    RUNNING = auto()
+    PAUSED = auto()
+    STOPPED = auto()
+    ERROR = auto()
+    MAINTENANCE = auto()
+
+class Vehicle:
+    def __init__(self):
+        self.state = State.IDLE
+
+car = Vehicle()
+
+def on_message(client, userdata, msg):
+    payload = msg.payload.decode()
+    print(f"Received message: {msg.topic} -> {payload}")
+
+    payload_dict = json.loads(payload)
+    event = payload_dict.get("value")
+    
+    if event is None:
+        print("Value not provided in message")
+
+    try:
+        vehicle_state = State[event]
+        car.state = vehicle_state
+        print(car.state)
+    except KeyError:
+        print(f"Invalid state: {event}")
+
+topic = "paho/temperature"
+mqttc = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2)
+mqttc.on_message = on_message
+mqttc.exit_flag = False 
+
+mqttc.connect("localhost", 1883, 60)
+mqttc.subscribe(topic)
+mqttc.loop_start()
+
+while car.state != State.STOPPED:
+    time.sleep(5)
+
+mqttc.loop_stop()
+mqttc.disconnect()