新框架 bug 再次测试

app/main.py

@@ -86,14 +86,14 @@ async def main():
     """
     spider_list = TopicGroup().produce()
     while spider_list:
-        print(spider_list)
-        # tasks = [consume_single_message(spider) for spider in spider_list]
-        # await asyncio.gather(*tasks)
-        await asyncio.sleep(60)
+        # print(spider_list)
+        tasks = [consume_single_message(spider) for spider in spider_list]
+        await asyncio.gather(*tasks)
+        await asyncio.sleep(600)
 
 
         # print("Hello World {}".format(" ".join(spider_list)))
-        async_tasks = []
+        # async_tasks = []
         # print(spider_list)
         # for spider in spider_list:
         #     print(json.dumps(spider))

application/common/messageQueue/ack_message.py

@@ -3,8 +3,14 @@ from mq_http_sdk.mq_exception import MQExceptionBase
 
 
 def ack_message(mode, platform, recv_msgs, consumer):
-    # msg.next_consume_time前若不确认消息消费成功，则消息会被重复消费。
-    # 消息句柄有时间戳，同一条消息每次消费拿到的都不一样。
+    """
+    msg.next_consume_time前若不确认消息消费成功，则消息会被重复消费。
+    消息句柄有时间戳，同一条消息每次消费拿到的都不一样。
+    :param mode:
+    :param platform:
+    :param recv_msgs:
+    :param consumer:
+    """
     try:
         receipt_handle_list = [msg.receipt_handle for msg in recv_msgs]
         consumer.ack_message(receipt_handle_list)