done

.idea/pythonProject1.iml

+<?xml version="1.0" encoding="UTF-8"?>
+<module type="PYTHON_MODULE" version="4">
+  <component name="NewModuleRootManager">
+    <content url="file://$MODULE_DIR$">
+      <excludeFolder url="file://$MODULE_DIR$/venv" />
+    </content>
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+</module>
\ No newline at end of file

main.py

+
+
+from  scripts.core.services import app
+app()
\ No newline at end of file

scripts/conf/application.conf

+[fastapi_connection]
+link_to_fastapi =scripts.services.main:app
+port_no =8000
+
+[MQTT_Connection]
+broker = 192.168.0.220
+port = 1883
+time_out = 60
+
+[redis_connection]
+host = 127.0.0.1
+redis_port = 6379
+db = 0
+db2 = 2
\ No newline at end of file

scripts/core/config/application_config.py

+from configparser import ConfigParser
+
+try:
+    config = ConfigParser()
+    config.read("conf/application.conf")
+
+    port_no = config.get("fastapi_connection", "port_no")
+    link_to_fastapi = config.get("fastapi_connection", "link_to_fastapi")
+
+    broker = config.get("MQTT_Connection", "broker")
+    mqtt_port = config.get("MQTT_Connection", "port")
+    time_out = config.get("MQTT_Connection", "time_out")
+
+    host = config.get("redis_connection", "host")
+    redis_port = config.get("redis_connection", "redis_port")
+    db = config.get("redis_connection", "db")
+    db2 = config.get("redis_connection", "db2")
+
+except Exception as e:
+    print("Exception-", e)

scripts/core/services/app.py

+import json
+import redis
+import paho.mqtt.client as mqtt
+
+# Initialize the Redis cache
+redis_cache = redis.StrictRedis(host='127.0.0.1', port=6379, db=2)
+
+# MQTT client for subscribing to doctor topics
+mqtt_client = mqtt.Client()
+mqtt_client.connect("192.168.0.220", 1883, 60)
+
+
+def on_message(client, userdata, message):
+    patient_details = json.loads(message.payload.decode())
+    topic = message.topic
+    print("Connected to " + topic)
+    print(f"{topic} - {patient_details}")
+    # Store the patient information in the Redis cache
+    redis_cache.set(topic, message.payload.decode())
+
+
+print("Waiting for messages")
+topic = "hospital/#"
+mqtt_client.subscribe(topic)
+mqtt_client.on_message = on_message
+mqtt_client.message_callback_add(topic, on_message)
+
+mqtt_client.loop_forever()