Azure Functions Python函数抛出异常时未进入死信队列的问题排查

看起来你遇到了Azure Service Bus触发的Python函数中，即使抛出异常也没有将消息移入死信队列，并且函数执行状态仍显示成功的问题，我来帮你一步步排查可能的原因并给出解决方案：

一、优先排查自定义装饰器@failsafe_logger的影响 #

你的testable_main函数使用了@failsafe_logger装饰器，这很可能是异常被“吃掉”的核心原因：

• 很多自定义日志装饰器内部会包含try-except块来捕获异常并记录日志，但如果装饰器没有重新抛出异常，Azure Functions运行时就无法感知到错误，会默认认为函数执行成功并自动完成Service Bus消息。
• 你需要检查这个装饰器的实现代码，确保它在捕获异常后会将异常传递出去。例如：

def failsafe_logger(response_type=ResponseType.AZURE_SERVICE_BUS):
    def decorator(func):
        def wrapper(*args, **kwargs):
            try:
                return func(*args, **kwargs)
            except Exception as e:
                # 执行你的日志记录逻辑
                logging.error(f"Failsafe logger caught error: {str(e)}", exc_info=True)
                # 关键：重新抛出异常，让Azure Functions运行时感知到
                raise
        return wrapper
    return decorator

二、验证Azure Functions Service Bus触发器的配置 #

Service Bus触发的函数能否将失败消息移入死信队列，和host.json中的配置密切相关：

1. 检查maxDeliveryCount：设置消息的最大重试次数，当重试次数耗尽后，消息会被移入死信队列。示例配置：

{
  "version": "2.0",
  "extensions": {
    "serviceBus": {
      "messageHandlerOptions": {
        "maxConcurrentCalls": 1,
        "autoComplete": true,
        "maxAutoRenewDuration": "00:05:00",
        "maxDeliveryCount": 3
      }
    }
  }
}

2. 注意autoComplete的行为：
   • 当autoComplete: true（默认值），函数成功执行完毕后会自动完成消息；只有当未被捕获的异常传递到函数入口时，运行时才会标记消息为失败，触发重试。
   • 如果你的代码中所有异常都被装饰器或内部逻辑捕获，运行时会认为函数执行成功，直接完成消息，不会触发重试和死信。

三、检查异常抛出的传递路径 #

你尝试在代码中重新抛出异常但未生效，可能是异常在传递到运行时的过程中被拦截了：

1. 确保create_subscription、update_subscription、delete_subscription这些方法抛出的异常没有被自身的try-except块捕获吃掉，必须让异常传递到testable_main函数。
2. 可以暂时移除@failsafe_logger装饰器，测试直接运行testable_main逻辑，看抛出异常时函数是否会标记为失败，消息是否进入死信队列。如果此时正常，说明装饰器是问题根源。

四、通过最小化案例验证运行时环境 #

为了排除Azure Functions运行时或Service Bus本身的问题，建议创建一个极简的测试函数：

import azure.functions as func
import logging

def main(msg: func.ServiceBusMessage):
    logging.info('Python Service Bus trigger test function processed message.')
    # 直接抛出异常，测试是否触发死信
    raise Exception("Test exception to trigger dead letter queue")

• 如果这个测试函数能正常将消息移入死信队列，说明你的业务代码中的异常处理逻辑存在问题（比如装饰器、内部方法的异常捕获）。
• 如果测试函数也无法触发死信，需要检查：
  • 函数应用使用的azure-functions和azure-functions-servicebus版本是否与之前正常工作时一致（可以查看requirements.txt或函数应用的扩展版本）。
  • Service Bus队列/主题的死信配置是否正常，比如是否启用了死信。

五、检查函数执行日志 #

在Azure门户的函数应用中，通过监控>日志或Application Insights查看详细的执行日志，确认：

• 异常是否真的被抛出并记录了？
• 异常的堆栈跟踪显示它被哪个环节捕获了？这能帮你快速定位异常被吃掉的位置。

备注：内容来源于stack exchange，提问作者Cha26