Azure Logic App：Gmail触发器结合C#/JS实现邮件读取与API调用

核心流程梳理 #

先搭好基础触发与执行链路：

• 配置Gmail触发器为当有新邮件到达，建议添加筛选条件（比如指定发件人、邮件标签），避免无关邮件触发流程。
• 从邮件主题/正文提取参数，再传递给API调用环节。

参数提取的高效方案 #

优先用Logic App内置函数处理，比写代码更轻量：

• 主题提取：如果参数用固定格式（比如API_REQUEST:param1=value1&param2=value2），用split和uriQuery解析：

  @uriQuery(split(triggerBody()?['subject'], ':')[1])
  

  解析后可直接通过parameters('param1')获取对应值。
• 正文提取：
  • 若正文是JSON格式，直接转成对象：@json(triggerBody()?['body'])，之后通过body('Parse_JSON')?['param1']取值。
  • 若正文是非结构化文本，用正则匹配：@matches(triggerBody()?['body'], 'param1=(.*?)\\r?\\n')[0][1]提取目标参数。

API调用的两种选择（优先内置动作） #

1. 内置HTTP动作（推荐）

如果API是标准REST接口，直接用Logic App的HTTP动作：

• 配置请求方法（GET/POST等）、API地址。
• 将提取的参数填入查询参数（GET请求）或请求体（POST请求），无需编写代码，维护成本低，且自带重试、监控能力。

2. 脚本调用（仅用于复杂逻辑）

只有当需要参数加密、复杂签名等特殊处理时，才用C#/JS脚本：

• JavaScript脚本示例：

  async function main(inputs) {
      const apiUrl = 'https://your-api-domain.com/endpoint';
      const requestData = {
          param1: inputs.param1,
          param2: inputs.param2
      };
  
      try {
          const response = await fetch(apiUrl, {
              method: 'POST',
              headers: {
                  'Content-Type': 'application/json',
                  'Authorization': `Bearer ${inputs.apiToken}`
              },
              body: JSON.stringify(requestData)
          });
          return await response.json();
      } catch (err) {
          return { error: err.message };
      }
  }
  

• C#脚本示例：

  using System;
  using System.Net.Http;
  using System.Net.Http.Headers;
  using System.Threading.Tasks;
  
  public static async Task<object> Run(dynamic inputs)
  {
      var apiUrl = "https://your-api-domain.com/endpoint";
      var client = new HttpClient();
      client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", inputs.apiToken);
  
      var requestBody = new {
          param1 = inputs.param1,
          param2 = inputs.param2
      };
  
      var response = await client.PostAsJsonAsync(apiUrl, requestBody);
      return response.IsSuccessStatusCode ? await response.Content.ReadAsAsync<object>() : new { error = response.ReasonPhrase };
  }
  

  注意：脚本动作有超时限制（默认1分钟），且资源有限，尽量避免在脚本里做复杂计算。

错误处理与可靠性优化 #

• 给API调用环节添加Run After配置，处理失败/超时情况，比如触发告警邮件、记录日志到Azure Monitor。
• 对HTTP动作配置重试策略（比如指数退避），应对API临时不可用的场景。

安全注意事项 #

• API密钥、凭证不要硬编码，存储到Azure Key Vault，用Get Secret动作动态获取。
• 限制Gmail触发器的触发条件，比如仅允许指定发件人、带特定关键词的邮件触发，防止恶意调用。
• 若参数包含敏感信息，建议在邮件里用Base64编码，脚本中解码后再传递给API。

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