Update main.py

main.py

@@ -4,7 +4,7 @@ from fastapi.middleware.cors import CORSMiddleware
 import requests
 import pandas as pd
 import json
-
+import httpx
 app = FastAPI()
 
 app.add_middleware(
@@ -23,37 +23,39 @@ async def your_continuous_function():
     import requests
     import json
     global page
-    while True:
-        print("data fetcher running.....")
-        
-        # Initialize an empty DataFrame to store the combined data
-        combined_df = pd.DataFrame()
-        
-              # Update the payload for each page
-        url = "https://dev3.api.curfox.parallaxtec.com/api/ml/order-list?sort=id&paginate=500&page="+str(page)
-        
-        payload = {}
-        headers = {
-                'Accept': 'application/json',
-                'X-Tenant': 'royalexpress'
-              }
-        
-        response = requests.request("GET", url, headers=headers, data=payload)
-        
-              # Sample JSON response
-        json_response = response.json()
-              # Extracting 'data' for conversion
-        data = json_response['data']
-        
-        df = pd.json_normalize(data)
-        
-              # Concatenate the current page's DataFrame with the combined DataFrame
-        combined_df = pd.concat([combined_df, df], ignore_index=True)
-        
-        data = combined_df[combined_df['status.name'].isin(['RETURN TO CLIENT', 'DELIVERED'])]
-        print("data collected from page : "+str(page))
-        page+=1
-        await asyncio.sleep(60)  # Adjust the sleep interval as needed
+    async with httpx.AsyncClient() as client:
+
+        while True:
+            print("data fetcher running.....")
+            
+            # Initialize an empty DataFrame to store the combined data
+            combined_df = pd.DataFrame()
+            
+                  # Update the payload for each page
+            url = "https://dev3.api.curfox.parallaxtec.com/api/ml/order-list?sort=id&paginate=500&page="+str(page)
+            
+            payload = {}
+            headers = {
+                    'Accept': 'application/json',
+                    'X-Tenant': 'royalexpress'
+                  }
+            
+            response = requests.request("GET", url, headers=headers, data=payload)
+            
+                  # Sample JSON response
+            json_response = response.json()
+                  # Extracting 'data' for conversion
+            data = json_response['data']
+            
+            df = pd.json_normalize(data)
+            
+                  # Concatenate the current page's DataFrame with the combined DataFrame
+            combined_df = pd.concat([combined_df, df], ignore_index=True)
+            
+            data = combined_df[combined_df['status.name'].isin(['RETURN TO CLIENT', 'DELIVERED'])]
+            print("data collected from page : "+str(page))
+            page+=1
+            await asyncio.sleep(60)  # Adjust the sleep interval as needed
 
 # Create a startup event.
 @app.on_event("startup")