!

app.py

@@ -10,7 +10,7 @@ uvicorn app:app --host 0.0.0.0 --port 10000
 import os , sys
 import datetime , requests , random , logging , time , timeit
 import simplejson as json
-from fastapi import FastAPI
+from fastapi import FastAPI , Request
 from fastapi.responses import PlainTextResponse , HTMLResponse , Response , JSONResponse
 # from fastapi import Request
 from starlette.requests import Request
@@ -48,6 +48,7 @@ BOT_AGENTS = [
 
 # MONGODB-ATLAS SETUP
 MONGOATLAS_URI = os.environ.get('MONGOATLAS_URI') or None
+AK = os.environ.get('AK') or None
 
 ##############################################################################
 #
@@ -69,7 +70,11 @@ console_logger.setFormatter(logging.Formatter('%(message)s'))
 logger.addHandler(console_logger)
 
 if not MONGOATLAS_URI:
-    logger.warning('Coulf not read the database URI')
+    logger.warning('Could not read the database URI')
+
+if not MONGOATLAS_URI:
+    logger.warning('Could not read the access key')
+
 
 # Disable urllib3 warnings (sent by requests)
 # requests.packages.urllib3.disable_warnings()
@@ -102,7 +107,7 @@ def remote_ip(request:Request):
     return PlainTextResponse(client_host , 200)
 
 @app.get("/task/faa_scrap_sold_listings_featured")
-def faa_scrap_sold_listings_featured_local():
+def faa_scrap_sold_listings_featured_local(request:Request):
 
     global proxies
 
@@ -115,6 +120,11 @@ def faa_scrap_sold_listings_featured_local():
     if not MONGOATLAS_URI:
         return PlainTextResponse("ERROR: MONGOATLAS_URI is undefined" , status_code=500)
 
+    access_key = request.args.get('AK')
+    if access_key != AK:
+        return PlainTextResponse("ERROR: Unauthorized call" , status_code=401)
+
+
     cnt_dbs = 4
 
     headers = {