default_data_store.py 1.4 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546
  1. from utils.logger_helper import LoggerHelper
  2. from stores.data_store_interface import IDataStore
  3. class DefaultDataStore(IDataStore):
  4. logger = LoggerHelper.get_logger()
  5. def __init__(self):
  6. pass
  7. def query_one_collect_url(self, url: str) :
  8. self.logger.info(f"Default: fetch_one_url")
  9. def insert_collect_data(self, data , is_batch=True):
  10. self.logger.info(f"Default: insert_collect_data")
  11. def save_collect_data(self, is_force=False):
  12. self.logger.info("Default: SAVE")
  13. def query_urls_to_process(self):
  14. self.logger.info("Default: QUERY_TO_PROCESS")
  15. def query_one_collect_by_url(self, url):
  16. self.logger.info("Default: QUERY_ONE_PROCESS")
  17. def query_one_process_by_no(self, no):
  18. self.logger.info(f"Default: query_one_process_by_no")
  19. def insert_process_data(self, data):
  20. self.logger.info("Default: INSERT_PROCESS_DATA")
  21. def save_process_data(self, is_force=False):
  22. self.logger.info("Default: SAVE_PROCESS_DATA")
  23. def set_process_other_urls(self, url, other_urls: str):
  24. self.logger.info("Default: SET_PROCESS_OTHER_URLS")
  25. def query_to_send(self):
  26. self.logger.info("Default: QUERY_TO_SEND")
  27. def set_send(self, no: str):
  28. self.logger.info("Default: SET_SEND")
  29. def get_email_by_area(self, area: str):
  30. self.logger.info("Default: GET_EMAIL_BY_AREA")