如何解决Logic Apps触发超2分钟运行的Azure Function超时重复请求问题？

核心问题分析 #

你之前用多线程的方式失败，本质是Azure Function的宿主机制导致的：当Function返回响应后，宿主进程可能会被回收，后台线程会被强制终止，根本没法完成后续的文件处理任务。必须用持久化的异步任务处理方式，不能依赖内存中的线程。

可行解决方案 #

1. 用Azure队列（Storage Queue/Service Bus Queue）实现异步解耦 #

• 步骤：
  • 当Logic Apps调用Function时，Function不直接处理文件，而是把任务参数（比如源文件路径、目标路径、转换规则）写入Azure Storage Queue或者Service Bus Queue，然后立刻返回202 Accepted给Logic Apps，同时返回一个唯一的任务ID。
  • 再创建一个触发型Azure Function（比如Queue Trigger），监听这个队列，一旦有新消息就执行文件读取、转换、写入的完整流程。
  • Logic Apps这边可以添加一个循环逻辑，每隔一段时间（比如30秒）调用另一个Function端点查询任务状态（基于任务ID，状态可以存在Azure Table Storage或者Cosmos DB里），直到任务标记为完成或超时。

2. 改用Azure Durable Functions处理长时任务 #

Durable Functions是专门为长时、有状态任务设计的，自带异步HTTP模式：

• 步骤：
  • 创建一个Orchestrator Function来定义文件处理的完整流程（读取、转换、写入）。
  • 创建一个Client Function作为入口，接收Logic Apps的请求后，启动Orchestrator并立刻返回202 Accepted，同时附带一个状态查询URL和任务ID。
  • Logic Apps通过轮询这个状态URL，直到获取到任务完成的结果。
  • 这种方式不需要自己管理队列和状态存储，Durable Functions会自动处理任务持久化和宿主回收的问题，比手动写队列更可靠。

3. 替换长时任务到Azure Data Factory（ADF） #

如果你的文件转换是标准的ETL操作，可以把核心任务放到ADF里：

• 步骤：
  • 在ADF中创建一个管道，实现文件读取、格式转换、写入的流程。
  • Logic Apps直接调用ADF的"触发管道"动作，ADF会异步执行任务，没有2分钟超时限制。
  • 可以在ADF管道完成后，通过Webhook或者Logic Apps的"等待管道完成"动作来获取结果，避免重复触发。

总结 #

不要用内存线程来处理异步任务，必须依赖Azure的持久化服务（队列、Durable Functions、ADF）来解耦Logic Apps的请求响应和长时任务执行，这样就能避免Logic Apps因超时重复触发的问题。

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