first

.env

+MONGO_URI = mongodb://192.168.0.220:2717
+MONGO_USER = admin
+MONGO_PASS = iLensDevMongo783
+DB_NAME = ilens_configuration
+COLLECTION_NAME = tag_hierarchy
+HIERARCHY_ID = site_107
+PROJECT_ID = project_id
+PORT_API = 8000

.idea/.gitignore

+# Default ignored files
+/shelf/
+/workspace.xml

.idea/inspectionProfiles/Project_Default.xml

+<component name="InspectionProjectProfileManager">
+  <profile version="1.0">
+    <option name="myName" value="Project Default" />
+    <inspection_tool class="PyPep8NamingInspection" enabled="true" level="WEAK WARNING" enabled_by_default="true">
+      <option name="ignoredErrors">
+        <list>
+          <option value="N801" />
+        </list>
+      </option>
+    </inspection_tool>
+  </profile>
+</component>
\ No newline at end of file

.idea/inspectionProfiles/profiles_settings.xml

+<component name="InspectionProjectProfileManager">
+  <settings>
+    <option name="USE_PROJECT_PROFILE" value="false" />
+    <version value="1.0" />
+  </settings>
+</component>
\ No newline at end of file

.idea/misc.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectRootManager" version="2" project-jdk-name="Python 3.9 (send_data)" project-jdk-type="Python SDK" />
+</project>
\ No newline at end of file

.idea/modules.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectModuleManager">
+    <modules>
+      <module fileurl="file://$PROJECT_DIR$/.idea/send_data.iml" filepath="$PROJECT_DIR$/.idea/send_data.iml" />
+    </modules>
+  </component>
+</project>
\ No newline at end of file

.idea/send_data.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

.idea/vcs.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="VcsDirectoryMappings">
+    <mapping directory="$PROJECT_DIR$" vcs="Git" />
+  </component>
+</project>
\ No newline at end of file

handles/tags.py

+import pandas as pd
+from pymongo import MongoClient
+
+from script.config.appconfig import mongo_uri, mongo_user, mongo_pass, db_name, collection_name
+
+client = MongoClient(mongo_uri,
+                     username=mongo_user,
+                     password=mongo_pass)
+database = client[db_name]
+collection = database[collection_name]
+projected = [
+    {
+        '$lookup': {
+            'from': 'tags',
+            'localField': 'parameter_id',
+            'foreignField': 'id',
+            'as': 'tag_details'
+        }
+    }, {
+        '$unwind': '$tag_details'
+    }, {
+        '$project': {
+            'site_id': '$site_id',
+            'line_id': '$line_id',
+            'equipment_id': '$equipment_id',
+            'site_name': '$site_name',
+            'line_name': '$line_name',
+            'equipment_name': '$equipment_name',
+            'id': '$id',
+            'tag_name': '$tag_details.tag_name',
+            '_id': 0
+        }
+    }
+]
+datas = list(collection.aggregate(projected))
+df = pd.DataFrame(datas)
+print(df)
+

main.py

+from script.config.appconfig import mongo_uri, db_name, collection_name, mongo_user, mongo_pass, hierarchy_id
+from pymongo import MongoClient
+
+client = MongoClient(mongo_uri,
+                     username=mongo_user,
+                     password=mongo_pass)
+database = client[db_name]
+collection = database[collection_name]
+
+
+class extract_data:
+    @staticmethod
+    def fetch_data():
+        try:
+            query = {}
+            hierarchies = hierarchy_id.split('$')
+            for each_hierarchy in hierarchies:
+                if "site_" in each_hierarchy:
+                    query["site_id"] = each_hierarchy
+                elif "line_" in each_hierarchy:
+                    query["line_id"] = each_hierarchy
+                elif "equipment_" in each_hierarchy:
+                    query["equipment_id"] = each_hierarchy
+                elif "parameter_" in each_hierarchy:
+                    query["parameter_id"] = each_hierarchy
+            filter_dict = {"_id": 0, "site_id": 1, "line_id": 1, "equipment_id": 1,
+                           "site_name": 1, "line_name": 1, "equipment_name": 1, "id": 1, "tag_name": 1}
+            documents = collection.find(query, filter_dict)
+            for document in documents:
+                print(document)
+        except Exception as e:
+            print(e)
+
+
+mongo_obj = extract_data()
+mongo_obj.fetch_data()

script/config/appconfig.py

+import os
+
+from dotenv import load_dotenv
+load_dotenv()
+mongo_uri = os.getenv("MONGO_URI")
+mongo_user = os.getenv("MONGO_USER")
+mongo_pass = os.getenv("MONGO_PASS")
+db_name = os.getenv("DB_NAME")
+collection_name = os.getenv("COLLECTION_NAME")
+hierarchy_id = os.getenv("HIERARCHY_ID")
+project_id = os.getenv("PROJECT_ID")
+api_port = os.getenv("PORT_API")
+mqtt_broker = os.getenv("MQTT_BROKER")
+mqtt_port = os.getenv("MQTT_PORT")
+mqtt_time = os.getenv("MQTT_TIME")