@@ -84,7 +84,8 @@ async def main():
主函数
"""
spider_list = TopicGroup().produce()
- # while spider_list:
+ while spider_list:
+ print("Hello World {}".format(" ".join(spider_list)))
# async_tasks = []
# for spider in spider_list:
# task = asyncio.create_task(consume_single_message(spider))