Update app.py

app.py

@@ -7,6 +7,7 @@ from db_operations.db_operations import DBOperations
 import logging
 import traceback 
 import redis
+import uuid
 from datetime import datetime
 from functools import lru_cache
 from word_cloud import get_frequent_words_html
@@ -16,8 +17,10 @@ from config import NEWS_RETENTION_SECONDS, UK_EDITION_URL
 app = Flask(__name__)
 CORS(app)
 redis_client = redis.Redis(host='localhost', port=6379, decode_responses=True)
-logging.warning(f'Is Redis available?: {redis_client.ping()}') 
+logging.basicConfig(format='%(asctime)s %(message)s')
+logging.warning(f'[session_id: {session_id}] Is Redis available?: {redis_client.ping()}') 
 db = DBOperations()
+session_id = None
 
 
 REFRESH_FREQ = 300 # 300 secs = 5 mins
@@ -25,7 +28,7 @@ REFRESH_FREQ = 300 # 300 secs = 5 mins
 def is_db_fetch_reqd():
     try:
         env_news_time = redis_client.get('NEWSFETCHTIME')
-        logging.warning(f'fetch_time_env_var: {env_news_time}')
+        logging.warning(f'[session_id: {session_id}] fetch_time_env_var: {env_news_time}')
         fetch_flag = 1
         if env_news_time is None:
             redis_client.set("NEWSFETCHTIME", str(datetime.now()))
@@ -46,7 +49,7 @@ def is_db_fetch_reqd():
 
 def correct_date(x):
     if (not isinstance(x, str)) or (str(x).find(":") == -1):
-        logging.warning(f'correct_date() error: {x} is not the right date format')
+        logging.warning(f'[session_id: {session_id}] correct_date() error: {x} is not the right date format')
         return "2020-11-07 00:36:44+05:30"
     return x
 
@@ -59,7 +62,7 @@ def date_time_parser(dt):
     try:
         return int(np.round((dt.now(dt.tz) - dt).total_seconds() / 60, 0))
     except:
-        logging.warning(f'date_time_parser() error: {dt} is not the right date format')
+        logging.warning(f'[session_id: {session_id}] date_time_parser() error: {dt} is not the right date format')
         return 100000
 
 
@@ -104,11 +107,11 @@ def elapsed_time_str(mins):
 
 def fetch_from_db(fetch_flag):
     try:
-        logging.warning(f'fetch_flag: {fetch_flag}')
+        logging.warning(f'[session_id: {session_id}] fetch_flag: {fetch_flag}')
         if fetch_flag == 1:
             final_df = db.read_news_from_db()
             freq_tokens = get_frequent_words_html(final_df)
-            logging.warning('Fetched From DB\n\n')
+            logging.warning(f'[session_id: {session_id}] Fetched From DB\n\n')
 
             final_df['_id'] = final_df['_id'].astype('str')
             
@@ -117,7 +120,7 @@ def fetch_from_db(fetch_flag):
         else:
             final_df = pd.read_json(redis_client.get("NEWSDF"))
             freq_tokens = redis_client.get("NEWSWORDCLOUD")
-            logging.warning('Fetched From Cache\n\n')
+            logging.warning(f'[session_id: {session_id}] Fetched From Cache\n\n')
             
     except Exception as e:
         print(e)
@@ -134,6 +137,8 @@ def index():
     Entry point
     """
     try:
+        global session_id
+        session_id = uuid.uuid4().hex
         src_str = ''
         status_code = 200
         final_df, freq_tokens = fetch_from_db(is_db_fetch_reqd())
@@ -157,7 +162,7 @@ def index():
     except Exception as e:
         final_df = pd.DataFrame({'title': '', 'url': '',
                                  'description': '', 'src_time': ''}, index=[0])
-        logging.warning(traceback.print_exc())
+        logging.warning(f'[session_id: {session_id}] {traceback.print_exc()}')
 
     result_str = f'''
                     <div class="box" id="main">