Update db_operations/db_operations.py

db_operations/db_operations.py

@@ -22,6 +22,7 @@ class DBOperations:
             _ = self.__client.list_database_names()
         except Exception as conn_exception:
             self.__error = 1
+            logging.critical(f"Error in DBOperations.connect(): {conn_exception}")
             self.__client = None
             raise
 
@@ -35,12 +36,14 @@ class DBOperations:
             if (len(docs) == 0) and (ntry < maxtries):
                 for doc in coll.find():
                     docs.append(doc)
-                ntry += 1
+                logging.info(f"DB Read try: {ntry}")
+                conn_exception
                 time.sleep(5)
                 
             rss_df = pd.DataFrame(docs)
         except Exception as insert_err:
             self.__error = 1
+            logging.critical(f"Error in DBOperations.read(): {insert_err}")
             rss_df = pd.DataFrame({'_id': '', 'title': '', 'url': '',
                                    'description': '', 'parsed_date': '',
                                    'src': ''}, index=[0])
@@ -61,7 +64,7 @@ class DBOperations:
             if self.__error == 0:
                 rss_df = await self.__read()
             if self.__error == 0:
-                print("Read Successful")
+                logging.info("Read Successful")
             if self.__client is not None:
                 self.__close_connection()
         return rss_df