Azure Functions Service Bus触发器部署后无法正常工作求助

我的Python Azure Functions代码本地运行正常，能从Service Bus队列获取消息，但部署到云端后，使用相同连接字符串却无法接收消息。已确认：

• 应用设置中配置了ServiceBusConnectionString
• 触发器已关联该应用设置变量

函数代码 #

import logging
import json

app = func.FunctionApp()
logging.info("Function starting...")
print("Function starting...")

import os 

def process_message(message: func.ServiceBusMessage):
    try:
        logging.info("Processing service bus message")
        # Join all chunks and decode to string
        body_bytes = message.get_body()
        body_str = body_bytes.decode('utf-8')
        try:
            result = json.loads(body_str)
        except json.JSONDecodeError:
            result = body_str
        logging.info(f"Processed service bus message: {result}")
        return result

    except Exception as e:
        print(f"Error processing message: {str(e)}  ")

@app.service_bus_queue_trigger(arg_name="azservicebus", queue_name="new-user", connection="ServiceBusConnectionString") 
def new_user_job_recommendation(azservicebus: func.ServiceBusMessage):
    logging.info("Function called...")
    user_id = process_message(message=azservicebus)
    logging.info(f"Received message from queue: {user_id}")

    logging.info("Function completed.")

排查建议 #

• 验证连接字符串权限：确认连接字符串对应的Service Bus共享访问密钥拥有Listen权限，RootManageSharedAccessKey默认包含所有权限，但自定义SAS密钥需明确配置Listen权限
• 检查队列名称大小写：Azure Service Bus队列名称区分大小写，确保云端队列名称与代码中new-user完全一致
• 查看云端日志：
  • 在Azure门户函数的监控>日志中查看logging输出，排查初始化或权限错误
  • 到日志流中查看print语句的输出，捕获未被logging记录的异常
• 对齐运行时版本：确认云端函数的Python版本与本地开发环境完全一致（如3.10/3.11），版本不兼容可能导致触发器初始化失败
• 检查连接字符串格式：确认应用设置中的ServiceBusConnectionString格式正确，无多余空格或特殊字符，格式应为：Endpoint=sb://<namespace>.servicebus.windows.net/;SharedAccessKeyName=<keyName>;SharedAccessKey=<key>
• 检查触发器状态：在Azure门户函数的触发器标签中确认状态为Running，若为Disabled需手动启用；同时清理队列中的死信消息，排查消息锁未释放导致的阻塞
• 直接测试连接：在云端Kudu控制台执行以下脚本验证Service Bus连接是否正常：

import os
from azure.servicebus import ServiceBusClient

conn_str = os.environ["ServiceBusConnectionString"]
queue_name = "new-user"

with ServiceBusClient.from_connection_string(conn_str) as client:
    with client.get_queue_receiver(queue_name=queue_name, max_wait_time=5) as receiver:
        messages = receiver.receive_messages(max_message_count=1)
        print(f"Received {len(messages)} messages")

若脚本能收到消息，说明问题出在函数触发器配置或代码逻辑；若收不到，需排查连接字符串或队列权限问题

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