Python使用Azure Service Bus设1天锁仍报过期，如何实现消息延迟重试？

一、锁过期问题的原因与修复 #

AutoLockRenewer的max_lock_renewal_duration参数仅控制最长总续期时长，单次消息锁的有效期由队列本身的Lock Duration配置决定，默认仅1分钟，最长可配置为5分钟，续期请求需要在单次锁过期前由客户端后台发出才会生效。你遇到报错的核心原因有两个：

• 代码中一次性拉取100条消息，若单条消息处理耗时较长，后台续期线程来不及为所有消息批量续期，就会出现部分消息锁过期的情况
• 锁过期后服务端已经自动将消息放回队列，此时再手动调用abandon_message方法就会抛出对应异常

修复方案 #

1. 登录Azure门户，进入对应Service Bus队列的配置页，将Lock duration调整为最大值300秒（5分钟），降低续期请求的触发频率
2. 减少单次拉取消息的数量，根据单条消息的平均处理速度调整，建议单次拉取不超过20条，避免续期压力过大
3. 消息处理逻辑中避免长时间阻塞主线程，否则会卡住后台续期请求的发送
4. 加异常捕获逻辑，如果已经触发锁过期报错，不需要再手动调用abandon方法

二、延迟300秒重试的实现方法 #

原生abandon_message方法默认是立即将消息放回队列，要实现延迟重试有两种可行方案：

方案1：使用abandon方法的delay参数（推荐，SDK版本≥7.1.0支持） #

Azure Service Bus Python SDK新版本已经为abandon_message方法新增了delay参数，单位为秒，设置后消息会在指定延迟后才重新进入队列，不需要额外逻辑。
修改后的代码示例：

def abandon_msg(self, msg: ServiceBusMessage, delay: int = 300) -> None:
    # 先捕获锁过期异常，避免报错
    try:
        self.receiver.abandon_message(msg, delay=delay)
    except azure.servicebus.exceptions.ServiceBusError as e:
        if "lock has expired" in str(e):
            # 锁已经过期，消息已经自动回到队列，无需额外处理
            pass
        else:
            raise e

方案2：主动完成消息+调度重发（兼容旧版本SDK） #

如果你的SDK版本不支持delay参数，可以先完成当前消息，再重发一条内容完全一致的消息，设置调度入队时间为当前时间+300秒：

from datetime import datetime, timedelta, timezone
import azure.servicebus.exceptions

def delay_retry_msg(self, msg: ServiceBusMessage, delay: int = 300) -> None:
    try:
        # 先完成当前消息，避免锁过期报错
        self.receiver.complete_message(msg)
        # 构造新消息，保留原消息的内容、应用属性等
        new_msg = ServiceBusMessage(msg)
        # 复制原消息的投递计数，避免丢失重试次数统计
        if "delivery_count" not in new_msg.application_properties:
            new_msg.application_properties["delivery_count"] = 0
        new_msg.application_properties["delivery_count"] += 1
        # 超过最大重试次数直接转入死信，可根据需求调整阈值
        if new_msg.application_properties["delivery_count"] > 10:
            self.receiver.dead_letter_message(msg, reason="max retry limit reached")
            return
        # 设置300秒后入队
        new_msg.scheduled_enqueue_time_utc = datetime.now(timezone.utc) + timedelta(seconds=delay)
        # 发送新消息
        self.sender.send_messages(new_msg)
    except azure.servicebus.exceptions.ServiceBusError as e:
        if "lock has expired" in str(e):
            pass
        else:
            raise e

内容的提问来源于stack exchange，提问作者Vidya