mqtt_client.py

#my code
from flask import Flask, request
import threading 
import paho.mqtt.client as mqtt
import requests
import json

import os

response = ""
######added now........unique = ['1','mars', 'elvis', 'Kori', 'brian','205', 'keith']    
mqtt_data = {}

def start_mqtt_subscriber():
    #####i doubt whether this 2 lines of code are functional
    clientid="14"
    client = mqtt.Client(client_id=clientid)

    def on_connect(client, userdata, flags, rc):
        if rc == 0:
            # data = request.get_json()
        # Perform an HTTP request
            # url = data.get('url')
            # response = requests.get(url)
            client.subscribe("keith",0)  # Subscribe to all topics under the client's ID
           
            
            print("Connected to MQTT broker")
            
        else:
            print(f"Connection failed with code {rc}")
    
    def on_message(client, userdata, message):
        
        topic = message.topic
        answer = message.payload.decode()
        #payload = message.payload.decode()
        print(f"Received message on topic: {topic}, payload: {answer}")
        if topic == "P1":
            mqtt_data["P1"]=answer
        if topic == "P2":
            mqtt_data["P2"]=answer
        if topic == "P3":
            mqtt_data["P3"]=answer
        if topic == "P4":
            mqtt_data["P4"]=answer
        if topic == "P5":
            mqtt_data["P5"]=answer
        if topic == "P6":
            mqtt_data["P6"]=answer
        

        # Process the incoming MQTT message here above
        
        url = 'http://localhost:5000/post_data'
        # payload = {'temp': 10}
        r = requests.post(url, json=mqtt_data)
        print(r.text)
        
        
    client.on_connect = on_connect
    client.on_message = on_message
    broker_address = "mqtt.eclipseprojects.io"  # Replace with your broker's address
    client.connect(broker_address, 1883, 30)
    
    
    
    
    # Start the MQTT subscriber loop
    client.loop_forever()

if __name__ == '__main__':
    start_mqtt_subscriber()