src/app.py

@@ -45,8 +45,7 @@ def on_message(channel, method_frame, header_frame, body):
     if msg_json['probability'] > 0.5:
         r = requests.get(f"http://{config.INPUT_HOSTNAME}/sample/{msg_json['tag']}")
         r.raise_for_status()
-        mqtt.publish(subtopic=r.json()['device_id'],
-                     message=json.dumps({"command": "doAlert"}))
+        mqtt.publish(json.dumps({"deviceID": r.json()['device_id'], "sensorID": "", "command": "doAlert"}))
 
 
 if __name__ == "__main__":

src/mqtt_helper.py

@@ -61,14 +61,10 @@ class MQTT:
                                   transport="tcp")
         self.client.connect(host=self.host, port=self.port, keepalive=60)
 
-    def publish(self, message: str, subtopic: str = "") -> None:
+    def publish(self, message: str) -> None:
         """
         Publish a message
         :param message:
-        :param subtopic:
         :return:
         """
-        if subtopic:
-            self.client.publish(f"{self.topic}/{subtopic}", message, qos=self.qos, retain=self.retain)
-        else:
-            self.client.publish(self.topic, message, qos=self.qos, retain=self.retain)
+        self.client.publish(self.topic, message, qos=self.qos, retain=self.retain)