Update

.gitignore

@@ -5,3 +5,4 @@
 *.ali
 *.idea
 *app.py
+*.env

main.py

@@ -7,6 +7,7 @@ import streamlit as st
 from utilities.py.styling import streamlit_style
 from utilities.py import plots
 from utilities.py import summary_tables
+from utilities.py import mongodb
 
 from pypfopt import EfficientFrontier
 from pypfopt import risk_models
@@ -250,3 +251,5 @@ if number_of_symbols > 1:
 
             st.write("Montly Return")
             st.dataframe(merged_monthly_returns_data, use_container_width=True)
+
+        mongodb.mongodb_push_data(company_name_to_symbol, number_of_symbols)

utilities/py/mongodb.py

@@ -3,27 +3,36 @@ import socket
 from dotenv import load_dotenv
 import os
 import urllib
+import streamlit as st
 
 load_dotenv()
-def mongodb_push_data (company_name_to_symbol, number_of_symbols):
+
+
+def mongodb_push_data(company_name_to_symbol, number_of_symbols):
+
     username = urllib.parse.quote_plus(os.environ.get("USERNAME"))
     password = urllib.parse.quote_plus(os.environ.get("PASSWORD"))
+    # client = "mongodb+srv://bhanuprasanna:<password>@capiport.xtnx5it.mongodb.net/"
+    MONGO_DB_URI = "mongodb+srv://%s:%s@capiport.xtnx5it.mongodb.net/" % (
+        username,
+        password,
+    )
 
-    MONGO_DB_URI = "mongodb+srv://%s:%s@capiport.xtnx5it.mongodb.net/" % (username, password)
+    st.write(MONGO_DB_URI)
 
-    client = MongoClient (MONGO_DB_URI)
-    if "capiport" in client. list_database_names():
-        db = client ["capiport"]
-    else:
-        db = client ["capiport"]
-    collection = db ["stocks they picked"]
-    hostname = socket.gethostname()
-    ip_address = socket. gethostbyname(hostname)
-    data = {
-        "hostname": hostname,
-        "stocks_picked": company_name_to_symbol,
-        'number_of_stocks_picked': number_of_symbols,
-        "ip_address": ip_address
-    }
-    collection. insert_one(data)
-    client. close ()
+    # client = MongoClient(MONGO_DB_URI)
+    # if "capiport" in client.list_database_names():
+    #     db = client["capiport"]
+    # else:
+    #     db = client["capiport"]
+    # collection = db["stocks they picked"]
+    # hostname = socket.gethostname()
+    # ip_address = socket.gethostbyname(hostname)
+    # data = {
+    #     "hostname": hostname,
+    #     "stocks_picked": company_name_to_symbol,
+    #     "number_of_stocks_picked": number_of_symbols,
+    #     "ip_address": ip_address,
+    # }
+    # collection.insert_one(data)
+    # client.close()