new code

main.py

@@ -40,6 +40,20 @@ gcs_bucket = gcs_client.bucket(gcs_bucket_name)
 # File path in GCS bucket
 gcs_file_path = "deepak_6593/db.csv"
 
+# Function to check if file exists in GCS bucket
+def check_create_file():
+    # Initialize GCS client
+    gcs_client = storage.Client()
+    gcs_bucket = gcs_client.bucket(gcs_bucket_name)
+    blob = gcs_bucket.blob(gcs_file_path)
+
+    # Check if file exists
+    if not blob.exists():
+        # Create an empty file
+        blob.upload_from_string("", content_type="text/csv")
+
+# Check and create file before endpoint is accessed
+check_create_file()
 
 def read_csv(location="tambaram"):
     global stop_reading