Update app.py

app.py

@@ -5,10 +5,22 @@ from datetime import datetime
 import time
 import csv
 import threading
+import os
+from huggingface_hub import HfApi
+
+# Hugging Face credentials
+HF_USERNAME = "abolfazle80"  # Your Hugging Face username
+REPO_NAME = "crypto_data"  # Your dataset repo name
+CSV_FILENAME = "USDT.csv"  # File in your dataset
 
 # Define the markets (cryptocurrencies to monitor)
 markets = ['DOTUSDT', 'BTCUSDT', 'ADAUSDT', 'BNBUSDT', 'SUIUSDT', 'XRPUSDT']
-filename = 'USDT.csv'
+
+# Initialize Hugging Face API
+api = HfApi()
+
+# Flag to control fetching loop
+loop_running = False
 
 # Function to get price and volume data from CoinEx
 def get_crypto_price_from_coinex(symbol):
@@ -23,58 +35,29 @@ def get_crypto_price_from_coinex(symbol):
         if 'data' in data:
             price = data['data']['ticker']['last']
             volume = data['data']['ticker']['vol']
-            return [price, volume]  # Return the price and volume as a list
+            return [price, volume]  # Return as list
         else:
             return ["Symbol not found", "Symbol not found"]
     except requests.exceptions.RequestException as e:
-        st.error(f"Request error: {e}")
         return ["Request error", "Request error"]
     except ValueError as e:
-        st.error(f"JSON decode error: {e}")
         return ["JSON decode error", "JSON decode error"]
 
-# Initialize a flag to control the loop
-loop_running = False
-
-# Check if the file exists and write the header if it doesn't
-file_exists = False
-try:
-    with open(filename, 'r') as file:
-        file_exists = True
-except FileNotFoundError:
-    file_exists = False
-
-if not file_exists:
-    with open(filename, 'w', newline='') as file:
-        writer = csv.writer(file)
-        # Write header: price and volume for all cryptos in markets list, with a timestamp
-        header = []
-        for market in markets:
-            header.append(f'{market} Price')
-            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()
-
+# Function to upload CSV to Hugging Face
 def upload_to_huggingface():
-    """Uploads the CSV file to Hugging Face, preserving all appended data."""
+    """Uploads the CSV file to the Hugging Face dataset repo."""
     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
+            path_or_fileobj=CSV_FILENAME,
+            path_in_repo=CSV_FILENAME,
             repo_id=f"{HF_USERNAME}/{REPO_NAME}",
             repo_type="dataset",
         )
-        print("CSV successfully uploaded to Hugging Face.")
+        print("✅ CSV successfully uploaded to Hugging Face.")
     except Exception as e:
-        print(f"Upload failed: {e}")
+        print(f"❌ Upload failed: {e}")
 
+# Function to fetch and save data
 def fetch_data():
     """Fetches crypto data, appends to CSV, and uploads to Hugging Face."""
     global loop_running
@@ -83,53 +66,52 @@ def fetch_data():
             all_data = []
             for market in markets:
                 crypto_data = get_crypto_price_from_coinex(market)
-                all_data += crypto_data  # Add price and volume
+                all_data += crypto_data  # Append price and volume
 
-            timestamp = datetime.now().strftime('%Y-%m-%d %H:%M:%S')  # Get the current timestamp
-            all_data.append(timestamp)  # Append timestamp to the row
+            timestamp = datetime.now().strftime('%Y-%m-%d %H:%M:%S')  # Timestamp
+            all_data.append(timestamp)  # Append timestamp to row
 
-            # 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:
+            # Append data to the local CSV file
+            file_exists = os.path.isfile(CSV_FILENAME)
+            with open(CSV_FILENAME, "a", newline="") as file:
                 writer = csv.writer(file)
                 if not file_exists:
-                    # Write header if the file is newly created
+                    # Write header if the file was just 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(f"✅ {all_data} added to CSV")
 
-            # Upload the updated CSV to Hugging Face
+            # Upload updated CSV to Hugging Face
             upload_to_huggingface()
 
             time.sleep(1)  # Fetch new data every second
         except Exception as e:
-            st.error(f"An error occurred: {e}")
+            print(f"❌ Error: {e}")
             loop_running = False  # Stop loop if error occurs
 
 # Streamlit UI elements
-st.title("Live Cryptocurrency Data with Start/Stop Loop")
+st.title("📊 Live Crypto Data Fetcher")
 
-# Button to start the loop
+# Start button
 if st.button("Start Fetching Data"):
     if not loop_running:
         loop_running = True
-        # Run the fetch data function in a separate thread so it doesn't block the Streamlit UI
         threading.Thread(target=fetch_data, daemon=True).start()
-        st.success("Started fetching data and saving it to CSV.")
+        st.success("✅ Started fetching data and saving to CSV.")
     else:
-        st.warning("Data fetching is already running.")
+        st.warning("⚠️ Data fetching is already running.")
 
-# Button to stop the loop
+# Stop button
 if st.button("Stop Fetching Data"):
     loop_running = False
-    st.success("Stopped fetching data.")
+    st.success("🛑 Stopped fetching data.")
 
-# Display the latest data from the CSV (if available)
-st.text("Latest Data from CSV:")
+# Show latest data
+st.subheader("📌 Latest Data from CSV:")
 try:
-    df = pd.read_csv(filename)
-    st.write(df.tail())  # Show the last few rows of the CSV
+    df = pd.read_csv(CSV_FILENAME)
+    st.write(df.tail())  # Show last few rows
 except Exception as e:
-    st.error(f"Error reading the CSV: {e}")
+    st.error(f"❌ Error reading CSV: {e}")