automatic_crawler/application/common/messageQueue/ack_message.py

from application.common.log import Local
from mq_http_sdk.mq_exception import MQExceptionBase


def ack_message(mode, platform, recv_msgs, consumer):
    """
    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)
        Local.logger(platform, mode).info(
            f"Ack {len(receipt_handle_list)} Message Succeed.\n"
        )

    except MQExceptionBase as err:
        Local.logger(platform, mode).info(f"Ack Message Fail! Exception:{err}\n")