如何手动触发带额外数据的Azure Function并解决长任务超时问题？

一、读取手动触发Time Trigger时传入的字典数据 #

手动触发Time Trigger函数时，传入的JSON字典可通过函数的触发请求对象读取，以下是主流语言的实现示例：

Python示例 #

import azure.functions as func
import json
import logging

def main(timer: func.TimerRequest) -> None:
    # 默认处理今日数据
    target_date = "Today"
    
    # 读取手动传入的参数
    if timer.request:
        try:
            req_payload = timer.request.get_json()
            # 从传入的字典中获取date字段，不存在则保留默认值
            target_date = req_payload.get("date", target_date)
        except ValueError:
            logging.warning("传入的JSON格式无效，将使用默认日期")
    
    logging.info(f"开始处理日期：{target_date}")
    # 你的数据处理逻辑写在这里

C#示例 #

using Microsoft.Azure.WebJobs;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json.Linq;
using System.IO;

public static void Run(TimerInfo myTimer, ILogger log, HttpRequest req)
{
    string targetDate = "Today";
    
    if (req != null)
    {
        string requestBody = new StreamReader(req.Body).ReadToEnd();
        if (!string.IsNullOrEmpty(requestBody))
        {
            JObject payload = JObject.Parse(requestBody);
            targetDate = payload["date"]?.ToString() ?? targetDate;
        }
    }
    
    log.LogInformation($"Processing data for date: {targetDate}");
    // 数据处理逻辑
}

手动触发时可通过Azure CLI传入参数：

az functionapp function invoke --name <你的函数应用名> --function-name <你的Timer函数名> --resource-group <资源组名> --data '{"date": "2024-05-01"}'

二、长耗时任务的异步触发方案 #

针对HTTP调用超时（任务耗时1小时）的问题，推荐使用HTTP Trigger + Azure Queue Storage的异步架构，既规避超时问题，又保证扩展性：

方案流程 #

1. 轻量HTTP入口函数：创建一个HTTP Trigger函数，仅负责接收重跑请求，将目标日期（或日期范围）封装为消息发送到Azure Queue，立即返回202 Accepted，不处理实际业务逻辑，完全避免超时。
2. Queue Trigger处理函数：创建一个Queue Trigger函数，监听上述队列，读取消息中的日期参数，执行完整的数据处理逻辑。

关键配置 #

• 调整函数超时时间：在host.json中设置最长执行时间（仅高级/专用计划支持1小时超时，消费计划最长10分钟）：

{
  "version": "2.0",
  "functionTimeout": "01:00:00"
}

• 队列重试策略：在Queue Trigger的function.json中配置重试次数，失败消息自动进入死信队列，方便后续排查：

{
  "bindings": [
    {
      "name": "queueItem",
      "type": "queueTrigger",
      "direction": "in",
      "queueName": "data-processing-queue",
      "connection": "AzureWebJobsStorage",
      "maxDequeueCount": 3
    }
  ]
}

三、适配业务场景的完整流程 #

1. 日常自动处理：保留原有的Time Trigger函数，每日夜间自动触发，默认处理当日（或前一日）数据。
2. 历史数据重跑：
   • 单日期重跑：调用HTTP入口函数，传入指定日期，HTTP函数将该日期发送到队列，Queue函数异步处理。
   • 多日期批量重跑：编写简单脚本（如Python/Shell），遍历需要重跑的日期范围，批量发送消息到队列，实现并行处理。
3. 幂等性保障：数据处理函数需保证幂等，比如处理前先检查该日期的数据是否已存在，或使用唯一处理标记避免重复操作。

方案对比 #

• 替代Fire-and-Forget HTTP：HTTP+Queue方案避免了直接处理长耗时任务导致的超时，同时队列可缓冲大量任务，扩展性更强。
• 替代Durable Functions：Durable适用于复杂有状态工作流，本场景仅需简单异步任务，Queue方案更轻量、成本更低。

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