新框架 bug 暂停

app/main.py

@@ -85,9 +85,11 @@ async def main():
     """
     spider_list = TopicGroup().produce()
     while spider_list:
-        print("Hello World {}".format(" ".join(spider_list)))
-    #     async_tasks = []
-    #     for spider in spider_list:
+        # print("Hello World {}".format(" ".join(spider_list)))
+        async_tasks = []
+        print(spider_list)
+        for spider in spider_list:
+            print(spider)
     #         task = asyncio.create_task(consume_single_message(spider))
     #         async_tasks.append(task)
     #     await asyncio.gather(*async_tasks)