同Azure Function中定时触发函数调用HTTP触发函数无需等待的实现方案

1. 用Azure Queue Storage解耦任务（最推荐） #

• 定时触发函数别直接调用HTTP触发函数了，把耗时任务的参数打包成消息，扔到Azure Queue Storage的队列里就行。
• 把原来的高耗时HTTP触发函数改成Queue触发函数，让它直接监听这个队列，有消息就自动执行耗时任务。
• 这样定时触发函数发完消息就能立刻结束，完全不用等耗时任务跑完，而且Azure Queue会保证消息的可靠性——没处理成功的话会自动重试，直到达到设定的次数。
• 简单代码示例：
  定时触发函数：

  public static async Task Run([TimerTrigger("0 */5 * * * *")] TimerInfo myTimer, ILogger log, [Queue("long-running-tasks")] IAsyncCollector<MyTaskData> queueCollector)
  {
      var taskData = new MyTaskData { /* 填好任务需要的参数 */ };
      await queueCollector.AddAsync(taskData);
      log.LogInformation("任务消息已发去队列，定时函数完事了");
  }
  

  队列触发函数：

  public static async Task Run([QueueTrigger("long-running-tasks")] MyTaskData taskData, ILogger log)
  {
      // 这里写高耗时任务的逻辑
      await DoLongRunningWork(taskData);
      log.LogInformation("耗时任务执行完了");
  }
  

2. 用Azure Service Bus做异步消息传递 #

• 如果需要更复杂的消息功能，比如事务支持、死信队列、主题订阅这些，就换用Azure Service Bus代替Queue Storage。
• 定时触发函数把消息发到Service Bus的队列或主题里，专门的Service Bus触发函数处理耗时任务，原理和Queue Storage一样，彻底解耦两个函数的执行，定时函数不用等。

3. 调整HTTP触发函数的调用方式（应急用，不推荐） #

• 要是必须保留HTTP触发的调用方式，想让定时函数不用等，还得保证HTTP函数能跑完，得注意别让Azure Functions宿主把后台任务掐断。
• 可以用HttpClient发请求时设置HttpCompletionOption.ResponseHeadersRead，这样只要收到响应头就返回，不用等响应体。但要注意：HTTP触发函数返回响应后继续执行代码的话，得配置好函数的超时时间（在host.json里改functionTimeout），而且这种方式没重试机制，任务崩了就没了，只适合非关键任务。
• 代码示例：
  定时触发函数：

  public static async Task Run([TimerTrigger("0 */5 * * * *")] TimerInfo myTimer, ILogger log)
  {
      using var httpClient = new HttpClient();
      var request = new HttpRequestMessage(HttpMethod.Post, "https://你的函数应用域名.azurewebsites.net/api/你的HTTP函数");
      request.Content = new StringContent(JsonSerializer.Serialize(taskData), Encoding.UTF8, "application/json");
      // 只等响应头，不等响应体
      var response = await httpClient.SendAsync(request, HttpCompletionOption.ResponseHeadersRead);
      log.LogInformation("HTTP请求发出去了，定时函数完事");
  }
  

  HTTP触发函数：

  public static async Task<IActionResult> Run([HttpTrigger(AuthorizationLevel.Function, "post", Route = null)] HttpRequest req, ILogger log)
  {
      // 先返回响应
      var response = new OkObjectResult("Function is running");
      // 后台跑耗时任务
      _ = Task.Run(async () =>
      {
          await DoLongRunningWork();
          log.LogInformation("耗时任务跑完了");
      });
      return response;
  }
  

4. 用Durable Functions（适合复杂工作流） #

• 如果耗时任务有多个步骤，或者需要跟踪任务状态，就用Azure Durable Functions。
• 定时触发函数作为客户端函数，启动一个Durable编排实例后直接返回；编排器函数调用活动函数执行耗时任务，活动函数在后台运行，Durable框架会管它的生命周期和可靠性。
• 代码示例：
  定时触发客户端函数：

  public static async Task Run([TimerTrigger("0 */5 * * * *")] TimerInfo myTimer, [DurableClient] IDurableOrchestrationClient client, ILogger log)
  {
      var instanceId = await client.StartNewAsync("LongRunningOrchestrator", null);
      log.LogInformation($"已启动编排实例 {instanceId}，定时函数完事");
  }
  

  编排器函数：

  public static async Task LongRunningOrchestrator([OrchestrationTrigger] IDurableOrchestrationContext context)
  {
      await context.CallActivityAsync("DoLongRunningTask", null);
  }
  

  活动函数：

  public static async Task DoLongRunningTask([ActivityTrigger] string input, ILogger log)
  {
      // 模拟高耗时任务，比如跑1小时
      await Task.Delay(3600000);
      log.LogInformation("耗时任务执行完了");
  }
  

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