Azure Service Bus Python SDK：避免函数应用闲置后发消息延迟

问题根源 #

Azure函数在闲置数分钟后会进入冷状态，同时你当前的代码每次运行都会创建新的ServiceBusClient和主题发送者，闲置期间连接会被释放，再次触发时需要重新建立连接，这就是耗时飙升的原因。ServiceBusClient和主题发送者本身是线程安全的，设计上支持长期复用，不需要每次请求都重新实例化。

解决方案：复用ServiceBusClient和发送者 #

在Azure函数中，将ServiceBusClient和主题发送者定义为全局变量，让它们在函数实例的生命周期内保持存活，避免重复创建和连接。

修改后的代码示例 #

import azure.functions as func
from azure.servicebus import ServiceBusClient, ServiceBusMessage

# 全局变量：复用ServiceBusClient和发送者
service_bus_client = None
topic_sender = None

def main(req: func.HttpRequest) -> func.HttpResponse:
    global service_bus_client, topic_sender
    conn_string = "<conn_string>"
    topic_name = "<topic>"

    # 仅在首次调用或连接失效时初始化
    if not service_bus_client:
        service_bus_client = ServiceBusClient.from_connection_string(conn_string)
    if not topic_sender:
        topic_sender = service_bus_client.get_topic_sender(topic_name)

    # 发送消息
    try:
        message = ServiceBusMessage("<message>", subject="<subject>")
        topic_sender.send_messages(message)
        return func.HttpResponse("消息发送成功", status_code=200)
    except Exception as e:
        # 连接失效时重置实例，下次调用重新初始化
        service_bus_client = None
        topic_sender = None
        return func.HttpResponse(f"发送失败: {str(e)}", status_code=500)

额外优化建议 #

• 配置连接池参数：初始化ServiceBusClient时可以调整连接池设置，比如增加最大连接数、设置连接超时，减少连接等待时间：

  service_bus_client = ServiceBusClient.from_connection_string(
      conn_string,
      connection_pool_size=10,  # 根据业务场景调整
      socket_timeout=30
  )
  

• 启用函数预热：如果你的函数使用高级计划或专用计划，可以开启函数预热功能，让函数实例保持活跃，避免冷启动带来的延迟。
• 针对性捕获连接异常：捕获ServiceBusConnectionError这类连接相关的异常，及时重置客户端实例，避免后续请求因无效连接持续失败。

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