|
|
@@ -134,6 +134,7 @@ def title_generate_main():
|
|
|
|
|
|
# msg.next_consume_time前若不确认消息消费成功，则消息会被重复消费。
|
|
|
# 消息句柄有时间戳，同一条消息每次消费拿到的都不一样。
|
|
|
+ log_.info(f"receipt_handle_list: {receipt_handle_list}")
|
|
|
consumer.ack_message(receipt_handle_list)
|
|
|
log_.info({
|
|
|
'ackMessage': {
|
|
|
@@ -164,6 +165,7 @@ def title_generate_main():
|
|
|
|
|
|
except Exception as e:
|
|
|
log_.error("Consume Message Fail! Exception:%s\n" % e)
|
|
|
+ continue
|
|
|
|
|
|
|
|
|
class FlaskApp(Flask):
|
