打印日志更新

ybw/crawler/account.py

@@ -49,7 +49,9 @@ def get_account(site, crawl_type):
     return data
 
 
-def release_account(uid, crawl_type):
+def release_account(uid, crawl_type, disable_log=False):
+
+
     url = "http://cc.spdata.jianyu360.com/competing_goods/account/release"
     if uid is not None:
         params = {
@@ -63,7 +65,8 @@ def release_account(uid, crawl_type):
                                         params=params,
                                         timeout=10)
                 if response.status_code == 200:
-                    logger.debug(f"release_account >>> {response.json()}")
+                    if not disable_log:
+                        logger.info(f"release_account >>> {response.json()}")
                     break
             except requests.RequestException:
                 logger.error("网络异常,归还账号失败")

ybw/crawler/crawl_scheduler.py

@@ -164,7 +164,7 @@ class Scheduler:
 
     def __exit__(self, exc_type, exc_val, exc_tb):
         logger.info(f'[关闭调度]')
-        release_account(self.account_id, self.crawl_type)
+        release_account(self.account_id, self.crawl_type,disable_log=True)
         self.crawl_start = False
 
         if exc_type is not None:

ybw/release_account.py

@@ -1,8 +1,9 @@
 from crawler.account import read_account, release_account
-
+from utils.log import logger
 
 def _send_message():
     account = read_account()
+    logger.info("[容器重启]{}".format(account))
     if account is not None:
         release_account(**account)