Azure WebJobs无法被Azure Storage Queue触发问题求助

环境背景 #

• Azure 环境，Python 3.12 / Linux
• Django 已部署在 Azure App Service
• Django Celery 作为同一 App Service 下的 Azure WebJobs 部署，Celery 运行正常，但配置的 Storage Queue 触发器完全不生效，手动发送队列消息无响应

已提供的配置文件 #

function.json #

{
    "bindings": [
        {
            "name": "myQueueItem",
            "type": "queueTrigger",
            "direction": "in",
            "queueName": "%AZURE_STORAGE_QUEUE_NAME%",
            "connection": "AzureWebJobsStorage"
        }
    ],
    "disabled": false
}

settings.job #

{
    "stopping_wait_time": 60,
    "is_singleton": true
}

run.sh #

#!/bin/bash
# Activate the Python environment
echo "Triggerd"

已尝试的解决步骤 #

1. 使用托管身份配置环境变量：

AzureWebJobsStorage__credential: 'managedidentity'
AzureWebJobsStorage__accountName: storageAccount.name
AzureWebJobsStorage__queueServiceUri: 'https://${storageAccount.name}.queue.${storageSuffix}/'

2. 使用存储账户连接字符串配置，本地测试连接正常
3. 尝试过上述两种方式的组合及function.json的不同配置，均无效
4. 已为 App Service 分配Storage Blob Data Contributor和Storage Queue Data Contributor权限

排查与解决方案建议 #

1. 检查 WebJobs 运行状态与日志 #

• 登录 Azure 门户，进入 App Service → 左侧菜单「WebJobs」，确认目标 WebJob 的运行状态为「Running」
• 进入 WebJob 详情页查看日志，重点排查是否存在QueueNotFound、AuthenticationFailed等报错，这类信息直接指向连接或权限问题

2. 修正环境变量配置格式 #

托管身份模式注意事项：

• Linux 环境下，App Service 应用设置名称不支持双下划线__，需替换为单下划线_或全大写格式（例如AZUREWEBJOBSTORAGE_CREDENTIAL）
• 替换占位符：将storageAccount.name改为实际存储账户名，${storageSuffix}改为对应区域后缀（如core.windows.net）
• 托管身份模式无需配置queueServiceUri，仅保留AzureWebJobsStorage__accountName和AzureWebJobsStorage__credential=managedidentity（注意调整为Linux兼容的变量名）

连接字符串模式验证：

• 确认AzureWebJobsStorage应用设置是完整的存储账户连接字符串，无多余空格或转义字符
• 确认AZURE_STORAGE_QUEUE_NAME的值与实际存储队列名称完全一致（队列名称区分大小写）

3. 完善触发器脚本逻辑 #

当前run.sh仅输出日志，未执行实际任务触发逻辑，需补充激活环境并调用Celery任务的代码：

#!/bin/bash
# 激活虚拟环境（根据实际路径调整）
source /home/site/wwwroot/venv/bin/activate
# 切换至Django项目根目录
cd /home/site/wwwroot
# 调用Celery任务处理队列消息（替换为实际项目和任务名）
python -m celery -A your_django_project tasks.process_queue "$myQueueItem"
echo "Processed queue message: $myQueueItem"

4. 验证托管身份权限细节 #

• 若使用用户分配托管身份，需额外添加应用设置AzureWebJobsStorage__clientId=<托管身份Client ID>
• 确认存储账户IAM中，Storage Queue Data Contributor权限已分配给正确的托管身份，且权限范围为存储账户级别

5. 检查WebJobs运行模式 #

• Queue触发器需配置为连续型WebJob，触发型WebJob仅按计划运行，不会监听队列
• is_singleton=true限制单实例运行，若App Service有多实例，需确认当前运行实例是否在执行触发器逻辑

6. 测试基础队列连接 #

在run.sh中添加测试代码，验证存储队列连接是否正常：

#!/bin/bash
source /home/site/wwwroot/venv/bin/activate
cd /home/site/wwwroot
python -c "
from azure.storage.queue import QueueClient
import os
try:
    if os.getenv('AZUREWEBJOBSTORAGE_CREDENTIAL') == 'managedidentity':
        queue_url = f'https://{os.getenv("AZUREWEBJOBSTORAGE_ACCOUNTNAME")}.queue.core.windows.net/{os.getenv("AZURE_STORAGE_QUEUE_NAME")}'
        queue_client = QueueClient.from_queue_url(queue_url, credential='managedidentity')
    else:
        queue_client = QueueClient.from_connection_string(os.getenv('AzureWebJobsStorage'), os.getenv('AZURE_STORAGE_QUEUE_NAME'))
    props = queue_client.get_queue_properties()
    print(f'Queue connected, message count: {props.approximate_message_count}')
except Exception as e:
    print(f'Connection failed: {str(e)}')
"

运行后查看日志，确认连接是否成功

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