Update thingspeak_to_firebase.py

thingspeak_to_firebase.py

@@ -1,107 +1,107 @@
-import requests
-import firebase_admin
-from firebase_admin import credentials, firestore
-import time
-
-# Replace with your actual credentials
-THINGSPEAK_API_KEY = "P54KXM40TA3CB6W4"
-CHANNEL_ID = "2784385"
-FIREBASE_CREDENTIALS_PATH = r"E:\static\snippetscript-37175-firebase-adminsdk-cf1z8-7d509b09fd.json"
-
-# Global variable to track the last entry ID
-last_entry_id = None
-
-def initialize_firebase():
-    """Initialize Firebase connection"""
-    try:
-        # Initialize Firebase app (only once)
-        cred = credentials.Certificate(FIREBASE_CREDENTIALS_PATH)
-        firebase_admin.initialize_app(cred)
-        
-        # Create Firestore client
-        return firestore.client()
-    except Exception as e:
-        print(f"Firebase initialization error: {e}")
-        return None
-
-def fetch_thingspeak_data():
-    """Fetch data from ThingSpeak"""
-    global last_entry_id
-    try:
-        url = f"https://api.thingspeak.com/channels/2784385/feeds.json?api_key=P54KXM40TA3CB6W4"
-        response = requests.get(url)
-        response.raise_for_status()  # Raise an exception for bad responses
-        data = response.json()
-        
-        # Check if there are feeds
-        if not data.get('feeds'):
-            print("No new feeds found.")
-            return None
-        
-        # Get the latest feed
-        latest_feed = data['feeds'][-1]
-        
-        # Check if this is a new entry
-        current_entry_id = latest_feed.get('entry_id')
-        
-        if current_entry_id != last_entry_id:
-            last_entry_id = current_entry_id
-            return latest_feed
-        
-        print("No new entries since last check.")
-        return None
-    
-    except requests.RequestException as e:
-        print(f"ThingSpeak data fetch error: {e}")
-        return None
-
-def store_data_in_firestore(firestore_client, data):
-    """Store data in Firestore"""
-    try:
-        # Validate data
-        if not data:
-            print("No data to store.")
-            return
-        
-        # Create a document with timestamp
-        doc_data = {
-            'field1': data.get('field1'),
-            'field2': data.get('field2'),
-            'entry_id': data.get('entry_id'),
-            'timestamp': firestore.SERVER_TIMESTAMP
-        }
-        
-        # Add to Firestore collection
-        firestore_client.collection('thingspeak_data').add(doc_data)
-        print("New data successfully stored in Firestore")
-    except Exception as e:
-        print(f"Firestore storage error: {e}")
-
-def main():
-    # Initialize Firebase
-    firestore_client = initialize_firebase()
-    
-    if not firestore_client:
-        print("Failed to initialize Firestore. Exiting.")
-        return
-    
-    # Main data collection loop
-    try:
-        while True:
-            # Fetch data from ThingSpeak
-            thingspeak_data = fetch_thingspeak_data()
-            
-            if thingspeak_data:
-                # Store data in Firestore only if there's a new entry
-                store_data_in_firestore(firestore_client, thingspeak_data)
-            
-            # Wait before next iteration
-            time.sleep(5)  # Adjust interval as needed
-    
-    except KeyboardInterrupt:
-        print("Data collection stopped by user.")
-    except Exception as e:
-        print(f"Unexpected error: {e}")
-
-if __name__ == "__main__":
+import requests
+import firebase_admin
+from firebase_admin import credentials, firestore
+import time
+
+# Replace with your actual credentials
+THINGSPEAK_API_KEY = "P54KXM40TA3CB6W4"
+CHANNEL_ID = "2784385"
+FIREBASE_CREDENTIALS_PATH = r"snippetscript-37175-firebase-adminsdk-cf1z8-7d509b09fd.json"
+
+# Global variable to track the last entry ID
+last_entry_id = None
+
+def initialize_firebase():
+    """Initialize Firebase connection"""
+    try:
+        # Initialize Firebase app (only once)
+        cred = credentials.Certificate(FIREBASE_CREDENTIALS_PATH)
+        firebase_admin.initialize_app(cred)
+        
+        # Create Firestore client
+        return firestore.client()
+    except Exception as e:
+        print(f"Firebase initialization error: {e}")
+        return None
+
+def fetch_thingspeak_data():
+    """Fetch data from ThingSpeak"""
+    global last_entry_id
+    try:
+        url = f"https://api.thingspeak.com/channels/2784385/feeds.json?api_key=P54KXM40TA3CB6W4"
+        response = requests.get(url)
+        response.raise_for_status()  # Raise an exception for bad responses
+        data = response.json()
+        
+        # Check if there are feeds
+        if not data.get('feeds'):
+            print("No new feeds found.")
+            return None
+        
+        # Get the latest feed
+        latest_feed = data['feeds'][-1]
+        
+        # Check if this is a new entry
+        current_entry_id = latest_feed.get('entry_id')
+        
+        if current_entry_id != last_entry_id:
+            last_entry_id = current_entry_id
+            return latest_feed
+        
+        print("No new entries since last check.")
+        return None
+    
+    except requests.RequestException as e:
+        print(f"ThingSpeak data fetch error: {e}")
+        return None
+
+def store_data_in_firestore(firestore_client, data):
+    """Store data in Firestore"""
+    try:
+        # Validate data
+        if not data:
+            print("No data to store.")
+            return
+        
+        # Create a document with timestamp
+        doc_data = {
+            'field1': data.get('field1'),
+            'field2': data.get('field2'),
+            'entry_id': data.get('entry_id'),
+            'timestamp': firestore.SERVER_TIMESTAMP
+        }
+        
+        # Add to Firestore collection
+        firestore_client.collection('thingspeak_data').add(doc_data)
+        print("New data successfully stored in Firestore")
+    except Exception as e:
+        print(f"Firestore storage error: {e}")
+
+def main():
+    # Initialize Firebase
+    firestore_client = initialize_firebase()
+    
+    if not firestore_client:
+        print("Failed to initialize Firestore. Exiting.")
+        return
+    
+    # Main data collection loop
+    try:
+        while True:
+            # Fetch data from ThingSpeak
+            thingspeak_data = fetch_thingspeak_data()
+            
+            if thingspeak_data:
+                # Store data in Firestore only if there's a new entry
+                store_data_in_firestore(firestore_client, thingspeak_data)
+            
+            # Wait before next iteration
+            time.sleep(5)  # Adjust interval as needed
+    
+    except KeyboardInterrupt:
+        print("Data collection stopped by user.")
+    except Exception as e:
+        print(f"Unexpected error: {e}")
+
+if __name__ == "__main__":
     main()