Commit
•
5179dac
1
Parent(s):
4ed8f54
Update db_operations/db_read.py
Browse files- db_operations/db_read.py +3 -0
db_operations/db_read.py
CHANGED
@@ -2,6 +2,7 @@ import pymongo
|
|
2 |
import os
|
3 |
import pandas as pd
|
4 |
from config import DATABASE, COLLECTION
|
|
|
5 |
|
6 |
|
7 |
class DBRead:
|
@@ -45,6 +46,7 @@ class DBRead:
|
|
45 |
self.__client = None
|
46 |
|
47 |
def read_news_from_db(self):
|
|
|
48 |
rss_df = pd.DataFrame({'_id': '', 'title': '', 'url': '',
|
49 |
'description': '', 'parsed_date': '',
|
50 |
'src': ''}, index=[0])
|
@@ -57,4 +59,5 @@ class DBRead:
|
|
57 |
print("Read Successful")
|
58 |
if self.__client is not None:
|
59 |
self.__close_connection()
|
|
|
60 |
return rss_df
|
|
|
2 |
import os
|
3 |
import pandas as pd
|
4 |
from config import DATABASE, COLLECTION
|
5 |
+
from logger import get_logger
|
6 |
|
7 |
|
8 |
class DBRead:
|
|
|
46 |
self.__client = None
|
47 |
|
48 |
def read_news_from_db(self):
|
49 |
+
logger.warning('Entering read_news_from_db() to read old news')
|
50 |
rss_df = pd.DataFrame({'_id': '', 'title': '', 'url': '',
|
51 |
'description': '', 'parsed_date': '',
|
52 |
'src': ''}, index=[0])
|
|
|
59 |
print("Read Successful")
|
60 |
if self.__client is not None:
|
61 |
self.__close_connection()
|
62 |
+
logger.warning('Entering read_news_from_db()')
|
63 |
return rss_df
|