@@ -299,7 +299,8 @@ async def periodic_task():
while True:
rule = get_task_rule()
await run_spider(rule_dict=rule) # 直接在当前事件循环中运行异步任务
- await asyncio.sleep(30 * 60) # 等待30分钟
+ wait_time = random.randint(20 * 60, 40 * 60)
+ await asyncio.sleep(wait_time) # 随机等待 20-40min
async def main():