new code

main.py

@@ -40,22 +40,43 @@ gcs_bucket = gcs_client.bucket(gcs_bucket_name)
 # File path in GCS bucket
 gcs_file_path = "deepak_6593/db.csv"
 
-# Function to create an empty file in GCS bucket
-def create_empty_file():
+def create_empty_csv():
     # Initialize GCS client
     gcs_client = storage.Client()
     gcs_bucket = gcs_client.bucket(gcs_bucket_name)
     blob = gcs_bucket.blob(gcs_file_path)
 
+    # Define columns for the empty DataFrame
+    columns = [
+        "timestamp",
+        "time",
+        "Vibration (mm/s)",
+        "Temperature (°C)",
+        "Pressure (psi)",
+        "Flow Rate (L/min)",
+        "Level (%)",
+        "Current (A)",
+        "Humidity (%)",
+        "Oil Quality (%)",
+        "pump_status",
+        "location"
+    ]
+
+    # Create an empty DataFrame with the specified columns
+    empty_df = pd.DataFrame(columns=columns)
+
+    # Convert the empty DataFrame to CSV format
+    csv_data = empty_df.to_csv(index=False)
+
     # Delete file if it exists
     if blob.exists():
         blob.delete()
 
-    # Create an empty file
-    blob.upload_from_string("", content_type="text/csv")
+    # Upload the CSV data to the GCS bucket
+    blob.upload_from_string(csv_data, content_type="text/csv")
 
-# Check and create file before endpoint is accessed
-create_empty_file()
+# Create an empty CSV file before endpoint is accessed
+create_empty_csv()
 
 def read_csv(location="tambaram"):
     global stop_reading