如何在Service Bus触发的Python Azure Function中无异常放回消息队列

要实现不抛出异常但将消息放回队列重试的需求，可以通过以下两种方式手动控制Service Bus消息的生命周期：

方法1：注入ServiceBusReceiver并调用abandon_message #

在函数参数中注入ServiceBusReceiver实例，直接调用其abandon_message方法将消息放回队列，同时函数正常返回成功状态。

示例代码：

import azure.functions as func

async def main(message: func.ServiceBusMessage, receiver: func.ServiceBusReceiver):
    try:
        # 调用第三方API逻辑
        call_third_party_api(message.get_body().decode())
        # API调用成功，手动完成消息
        await receiver.complete_message(message)
    except ThirdPartyApiError:
        # 第三方API出错，手动放弃消息使其重回队列
        await receiver.abandon_message(message)
    
    # 函数正常返回，无异常抛出
    return

方法2：配置手动完成模式（autoComplete=False） #

在function.json中设置autoComplete为false，禁用运行时自动完成/放弃消息的逻辑，完全由代码控制消息状态：

修改function.json的绑定配置：

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "name": "message",
      "type": "serviceBusTrigger",
      "direction": "in",
      "queueName": "your-queue-name",
      "connection": "ServiceBusConnectionString",
      "autoComplete": false
    }
  ]
}

对应函数代码：

import azure.functions as func

async def main(message: func.ServiceBusMessage, receiver: func.ServiceBusReceiver):
    try:
        # 调用第三方API逻辑
        call_third_party_api(message.get_body().decode())
        await receiver.complete_message(message)
    except ThirdPartyApiError:
        await receiver.abandon_message(message)
    
    return

关键注意事项 #

• 队列配置：建议设置队列的Max Delivery Count（最大传递次数），避免消息无限重试，超过次数后消息会被移入死信队列，方便后续排查处理。
• PeekLock模式：Service Bus触发器默认使用PeekLock模式，消息被取出后会被锁定一段时间，调用abandon_message会释放锁并将消息放回队列，等待下一次触发。
• 函数状态：只要函数不抛出异常，无论调用abandon_message还是complete_message，都会被标记为成功执行，不会出现在失败函数列表中。

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