Update app.py

app.py

@@ -54,33 +54,59 @@ if not file_exists:
             header.append(f'{market} Volume')
         header.append('Timestamp')  # Add timestamp to the end
         writer.writerow(header)
+from huggingface_hub import HfApi
+import os
+
+HF_USERNAME = "abolfazle80"  # Your Hugging Face username
+REPO_NAME = "crypto_data"  # Your dataset repo
+
+api = HfApi()
+
+def upload_to_huggingface():
+    """Uploads the CSV file to Hugging Face, preserving all appended data."""
+    try:
+        api.upload_file(
+            path_or_fileobj="USDT.csv",  # Upload the local CSV
+            path_in_repo="USDT.csv",  # Save as USDT.csv in the repo
+            repo_id=f"{HF_USERNAME}/{REPO_NAME}",
+            repo_type="dataset",
+        )
+        print("CSV successfully uploaded to Hugging Face.")
+    except Exception as e:
+        print(f"Upload failed: {e}")
 
-# Function to fetch data in a loop
 def fetch_data():
+    """Fetches crypto data, appends to CSV, and uploads to Hugging Face."""
     global loop_running
     while loop_running:
         try:
             all_data = []
             for market in markets:
                 crypto_data = get_crypto_price_from_coinex(market)
-                all_data += crypto_data  # Add price and volume to the list
+                all_data += crypto_data  # Add price and volume
 
             timestamp = datetime.now().strftime('%Y-%m-%d %H:%M:%S')  # Get the current timestamp
-            all_data.append(timestamp)  # Add the timestamp to the data list
+            all_data.append(timestamp)  # Append timestamp to the row
 
-            # Append the data to the CSV file
-            with open(filename, 'a', newline='') as file:
+            # Append the data to the CSV file (do not overwrite)
+            file_exists = os.path.isfile("USDT.csv")  # Check if file exists
+            with open("USDT.csv", "a", newline='') as file:
                 writer = csv.writer(file)
-                writer.writerow(all_data)
+                if not file_exists:
+                    # Write header if the file is newly created
+                    header = [f"{m} Price" for m in markets] + [f"{m} Volume" for m in markets] + ["Timestamp"]
+                    writer.writerow(header)
+                writer.writerow(all_data)  # Append new row
+
+            print(f"{all_data} added to CSV")
 
-            # Print confirmation to console
-            print(f'{all_data} data added')
+            # Upload the updated CSV to Hugging Face
+            upload_to_huggingface()
 
-            # Sleep for 1 second before the next iteration
-            time.sleep(1)
+            time.sleep(1)  # Fetch new data every second
         except Exception as e:
             st.error(f"An error occurred: {e}")
-            loop_running = False  # Stop the loop in case of an error
+            loop_running = False  # Stop loop if error occurs
 
 # Streamlit UI elements
 st.title("Live Cryptocurrency Data with Start/Stop Loop")