自动回复抓取

applications/tasks/monitor_tasks/auto_reply_cards_monitor.py

@@ -1,3 +1,4 @@
+import asyncio
 import os
 import json
 import time
@@ -718,6 +719,8 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorMapper):
                         case _:
                             continue
 
+                await asyncio.sleep(5)
+
             await self.update_auto_reply_task_status(
                 task_id, "extract", self.PROCESSING_STATUS, self.SUCCESS_STATUS
             )
@@ -746,6 +749,7 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorMapper):
 
                 for task in tqdm(task_list, desc="解析任务"):
                     await self.extract_single_xml(task)
+                    await asyncio.sleep(10)
 
             case "re_extract_task":
                 pass