如何通过其他服务触发Azure Container App执行长时间运行任务

一、用Azure Container Apps Jobs运行30分钟Python脚本 #

Azure Container Apps提供Jobs功能，专门用于处理一次性、长时间运行的任务（最长支持24小时执行时长），完全满足你30分钟脚本的需求。

1. 打包Python脚本为容器镜像 #

• 写好你的Python脚本（比如long_task.py），然后创建Dockerfile：

# 使用官方Python基础镜像
FROM python:3.11-slim

# 设置工作目录
WORKDIR /app

# 复制脚本到容器内
COPY long_task.py .

# 安装依赖（如果有脚本依赖第三方库）
# RUN pip install --no-cache-dir -r requirements.txt

# 运行脚本
CMD ["python", "long_task.py"]

• 把镜像推送到Azure Container Registry（ACR）或者其他容器镜像仓库。

2. 创建Container App Job #

• 在Azure门户中找到「Container Apps」，选择「Jobs」标签页，点击「创建」。
• 配置基本信息：订阅、资源组、Job名称。
• 配置容器：选择你推送的镜像，设置资源（CPU/内存，根据脚本需求调整），设置执行超时时间为30分钟以上（比如35分钟，避免脚本因超时被终止）。
• 配置触发器：先选「手动」，后续再配置外部触发。

二、用其他Azure服务触发Job执行 #

你可以用多种Azure服务触发Container App Job的执行，以下是几个常用方案：

1. Azure Logic Apps #

• 创建一个Logic App工作流，添加触发源（比如HTTP请求、Blob存储文件上传、定时调度等）。
• 添加「Azure Container Apps」动作，选择「触发Job」，配置你的Job名称、资源组等信息，即可在触发源事件发生时启动任务。

2. Azure Functions #

• 写一个简单的Azure Function（比如HTTP触发、定时器触发），在函数代码中调用Azure Container Apps的REST API来触发Job：

import requests
import os
from azure.identity import DefaultAzureCredential

def main(req):
    credential = DefaultAzureCredential()
    token = credential.get_token("https://management.azure.com/.default").token
    
    subscription_id = os.environ["SUBSCRIPTION_ID"]
    resource_group = os.environ["RESOURCE_GROUP"]
    job_name = os.environ["JOB_NAME"]
    
    url = f"https://management.azure.com/subscriptions/{subscription_id}/resourceGroups/{resource_group}/providers/Microsoft.App/jobs/{job_name}/trigger?api-version=2023-05-01"
    
    headers = {
        "Authorization": f"Bearer {token}",
        "Content-Type": "application/json"
    }
    
    response = requests.post(url, headers=headers)
    response.raise_for_status()
    
    return "Job triggered successfully"

• 给Function的服务主体分配「Container App Job Contributor」角色，确保有权限触发Job。

3. Azure Event Grid #

如果需要基于事件触发（比如存储账户文件上传、数据库数据更新），可以配置Event Grid订阅，将事件路由到Logic App或Azure Function，再由它们触发Container App Job。

三、注意事项 #

• 确保你的容器镜像能正常运行脚本，先在本地测试后再推送到镜像仓库。
• 调整Job的资源配置（CPU/内存），避免因资源不足导致脚本运行缓慢或失败。
• 可以在Job配置中设置重试策略，防止因临时故障导致任务失败。

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