update

gongzhonghao/gongzhonghao_author/gongzhonghao3_author.py

@@ -16,7 +16,6 @@ from selenium.webdriver.common.by import By
 from selenium import webdriver
 sys.path.append(os.getcwd())
 from common.common import Common
-# from common.getuser import getUser
 from common.feishu import Feishu
 from common.publish import Publish
 from common.scheduling_db import MysqlHelper

gongzhonghao/gongzhonghao_main/run_gzh3_author.py

@@ -48,7 +48,9 @@ def main(log_type, crawler, topic_name, group_id, env):
                                                       f"ReceiptHandle:{msg.receipt_handle}\n"
                                                       f"Properties:{msg.properties}")
                 # ack_mq_message
+                Common.logger(log_type, crawler).info("回传 ack 消息")
                 ack_message(log_type=log_type, crawler=crawler, recv_msgs=recv_msgs, consumer=consumer)
+                time.sleep(2)
 
                 # 处理爬虫业务
                 task_dict = task_fun_mq(msg.message_body)['task_dict']