基于Timer Trigger的Azure Function触发Logic Apps的实现方法咨询

因为Timer Trigger的Azure Function确实没法用HTTP输出绑定，但完全可以通过以下几种方式触发Logic Apps：

方案一：直接在代码中调用Logic Apps的HTTP触发器URL #

这是最直接的方式，Logic Apps本身支持HTTP触发器，你可以直接在Function代码里发送HTTP请求触发它：

1. 在Logic Apps里创建「当收到HTTP请求时」的触发器，配置好请求方法（比如POST）和预期的请求体结构（比如包含需要标记的Cosmos DB文档ID）
2. 保存Logic Apps后，复制自动生成的HTTP触发URL（这个URL自带SAS令牌，不需要额外做身份验证）
3. 在Timer Trigger的Function代码里，用对应语言的HTTP客户端（比如C#的HttpClient）发送请求到这个URL，带上处理好的文档数据

示例C#代码：

using System;
using System.Net.Http;
using System.Threading.Tasks;
using Microsoft.Azure.WebJobs;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;

public static class TimerTriggerFunction
{
    private static readonly HttpClient _httpClient = new HttpClient();

    [FunctionName("TimerTriggerFunction")]
    public static async Task Run([TimerTrigger("0 */5 * * * *")]TimerInfo myTimer, ILogger log)
    {
        log.LogInformation($"Timer trigger executed at: {DateTime.Now}");

        // 1. 从Cosmos DB获取已处理数据的ID（这里模拟数据）
        var processedDocIds = new[] { "doc-001", "doc-002" };

        // 2. 构造发给Logic Apps的请求体
        var requestData = new
        {
            DocumentIds = processedDocIds,
            Status = "Completed"
        };

        // 3. 替换成你的Logic Apps HTTP触发URL
        var logicAppsEndpoint = "https://prod-xx.westus.logic.azure.com:443/workflows/xxxx/triggers/manual/paths/invoke?api-version=2016-06-01&sp=%2Ftriggers%2Fmanual%2Frun&sv=1.0&sig=xxxx";
        
        var response = await _httpClient.PostAsJsonAsync(logicAppsEndpoint, requestData);
        
        if (response.IsSuccessStatusCode)
        {
            log.LogInformation("Logic Apps触发成功");
        }
        else
        {
            log.LogError($"触发Logic Apps失败，状态码：{response.StatusCode}");
        }
    }
}

方案二：用Service Bus做中间件解耦 #

如果想让Function和Logic Apps解耦（比如避免Logic Apps临时不可用导致请求丢失），可以用Service Bus做中间层：

1. 创建一个Service Bus队列/主题
2. 在Timer Function中添加Service Bus输出绑定（配置好连接字符串和队列名称），或者用SDK直接发送消息到队列
3. 在Logic Apps里添加「当收到Service Bus消息时」的触发器，监听这个队列，收到消息后执行标记Cosmos DB的逻辑

示例C#输出绑定代码：

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

public static class TimerTriggerFunction
{
    [FunctionName("TimerTriggerFunction")]
    public static void Run(
        [TimerTrigger("0 */5 * * * *")]TimerInfo myTimer,
        [ServiceBus("processed-docs-queue", Connection = "ServiceBusConnectionString")] out string outputMessage,
        ILogger log)
    {
        log.LogInformation($"Timer trigger executed at: {DateTime.Now}");

        // 模拟从Cosmos DB获取的已处理数据ID
        var processedDocIds = new[] { "doc-001", "doc-002" };
        outputMessage = JsonConvert.SerializeObject(new { DocumentIds = processedDocIds });
    }
}

方案三：用Event Grid发布事件触发 #

如果后续可能需要多个服务监听这个事件，可以用Event Grid：

1. 创建Event Grid主题
2. 在Timer Function中发布事件到这个主题
3. 在Logic Apps里订阅该Event Grid主题，收到事件后执行标记操作

这种方式适合需要扩展多订阅者的场景，单场景用前两种更轻便。

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