Azure Functions Python v2：如何向Power Automate返回202状态码而不终止函数

你的代码无效的核心原因是：仅创建func.HttpResponse(statuscode=202)对象但不返回，函数会继续执行后续代码直到最终返回200响应，Power Automate最终收到的是200而非预期的202。要实现先返回202再后台执行任务，必须将后续逻辑剥离到独立的执行上下文，不能在同一个HTTP请求线程中处理。

以下是两种可行的实现方案：

方案一：使用Azure Storage队列分离任务 #

通过将任务数据发送到Storage队列，让队列触发函数后台执行原逻辑，HTTP函数仅负责返回202。

步骤1：配置Storage队列连接 #

将Azure Storage连接字符串添加到函数应用的应用设置中（键名默认AzureWebJobsStorage）。

步骤2：修改HTTP触发函数 #

import azure.functions as func
from azure.storage.queue import QueueClient
import os
import json

def auto_assignment(req: func.HttpRequest) -> func.HttpResponse:
    logging.info('Python HTTP trigger function processed a request.')
    
    # 初始化队列客户端
    conn_str = os.environ["AzureWebJobsStorage"]
    queue_client = QueueClient.from_connection_string(conn_str, queue_name="assignment-tasks")
    
    # 将请求数据序列化后发送到队列
    try:
        req_data = req.get_json()
        queue_client.send_message(json.dumps(req_data))
    except Exception as e:
        logging.error(f"发送队列消息失败: {str(e)}")
        return func.HttpResponse("Bad Request", status_code=400)
    
    # 立即返回202 Accepted
    return func.HttpResponse("任务已接受，后台处理中", status_code=202)

步骤3：创建队列触发函数 #

import azure.functions as func
import json

def process_assignment_task(msg: func.QueueMessage) -> None:
    logging.info('开始处理后台任务')
    
    # 解析队列中的任务数据
    try:
        task_data = json.loads(msg.get_body().decode('utf-8'))
        
        # 执行原有的<misc code here>逻辑
        # 示例：处理任务并生成结果
        output_variable = f"处理完成：{task_data.get('task_id')}"
        logging.info(output_variable)
        
    except Exception as e:
        logging.error(f"任务处理失败: {str(e)}")

方案二：使用Durable Functions（适合复杂工作流） #

通过Durable Functions的编排模式，HTTP函数启动后台工作流后立即返回202，后续可通过状态查询接口获取任务进度。

步骤1：启用Durable Functions扩展 #

在函数应用的「扩展」中安装Microsoft.Azure.WebJobs.Extensions.DurableTask扩展。

步骤2：HTTP客户端函数（触发工作流） #

import azure.functions as func
import azure.durable_functions as df

def auto_assignment(req: func.HttpRequest, starter: str) -> func.HttpResponse:
    logging.info('Python HTTP trigger function processed a request.')
    
    # 初始化Durable客户端并启动编排器
    client = df.DurableOrchestrationClient(starter)
    instance_id = client.start_new("assignment-orchestrator", None, req.get_json())
    
    # 返回202响应，包含任务状态查询URL
    return client.create_check_status_response(req, instance_id)

步骤3：Orchestrator函数（编排工作流） #

import azure.durable_functions as df

def orchestrator_function(context: df.DurableOrchestrationContext):
    # 获取传入的任务数据
    task_data = context.get_input()
    
    # 调用Activity函数执行具体逻辑
    output_variable = yield context.call_activity("process-assignment", task_data)
    
    return output_variable

main = df.Orchestrator.create(orchestrator_function)

步骤4：Activity函数（执行具体任务） #

import azure.functions as func

def process_assignment(task_data: dict) -> str:
    logging.info('开始处理分配任务')
    
    # 执行原有的<misc code here>逻辑
    output_variable = f"任务 {task_data.get('task_name')} 处理完成"
    
    return output_variable

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