新框架 bug 暂停

app/main.py

@@ -84,13 +84,13 @@ async def main():
     主函数
     """
     spider_list = TopicGroup().produce()
-    while spider_list:
-        async_tasks = []
-        for spider in spider_list:
-            task = asyncio.create_task(consume_single_message(spider))
-            async_tasks.append(task)
-        await asyncio.gather(*async_tasks)
-        await asyncio.sleep(60)  # 每分钟接收一次MQ,
+    # while spider_list:
+    #     async_tasks = []
+    #     for spider in spider_list:
+    #         task = asyncio.create_task(consume_single_message(spider))
+    #         async_tasks.append(task)
+    #     await asyncio.gather(*async_tasks)
+    #     await asyncio.sleep(60)  # 每分钟接收一次MQ,
 
 
 if __name__ == "__main__":