Update app.py

app.py

@@ -72,6 +72,33 @@ st.title("🌍 Smart Renewable Pole Monitoring - Multi-Site")
 # Fetch Salesforce data
 st.subheader("Salesforce Poles Data")
 poles_data = fetch_salesforce_data()
+from simple_salesforce import Salesforce, SalesforceMalformedRequest
+
+def fetch_salesforce_data():
+try:
+        # Authenticate with Salesforce
+        sf = Salesforce(
+            username='greenenergy@vedavathi.com',
+            password='Vedavathi@04',
+            security_token='jqe4His8AcuFJucZz5NBHfGU'
+        )
+
+        # Run SOQL query
+        query = """
+            SELECT Id, Name, Latitude__c, Longitude__c, 
+                   Solar_Output__c, Wind_Output__c 
+            FROM Pole__c
+        """
+        poles_data = sf.query(query)
+        
+        return poles_data
+
+    except SalesforceMalformedRequest as e:
+        print("Salesforce Query Error:")
+        print("  Message :", e.content[0].get("message", "No message"))
+        print("  ErrorCode :", e.content[0].get("errorCode", "Unknown"))
+        print("  Fields   :", e.content[0].get("fields", []))
+        raise  # Re-raise the exception for debugging/logging
 
 if not poles_data.empty:
     # Rename columns to match simulated data for consistency