Azure函数失败时如何实现无延迟的自动邮件通知？

针对Azure Function App执行失败通知延迟15分钟的问题，以下是几种即时触发通知的可行方案：

方案1：在函数代码内直接捕获异常并发送通知 #

这是最直接的即时方案，无需依赖警报规则的延迟评估，在函数执行失败的瞬间触发邮件发送：

1. 集成邮件服务SDK（比如Azure SendGrid，官方推荐的邮件服务），在项目中添加依赖：

<!-- Maven依赖示例 -->
<dependency>
    <groupId>com.sendgrid</groupId>
    <artifactId>sendgrid-java</artifactId>
    <version>4.9.3</version>
</dependency>

2. 在HTTP函数的代码中捕获异常，在catch块内调用SendGrid API发送邮件：

import com.sendgrid.SendGrid;
import com.sendgrid.helpers.mail.Mail;
import com.sendgrid.helpers.mail.objects.Content;
import com.sendgrid.helpers.mail.objects.Email;

import java.io.IOException;
import com.microsoft.azure.functions.*;
import com.microsoft.azure.functions.annotation.*;

public class HttpTriggerFunction {
    @FunctionName("HttpTrigger")
    public HttpResponseMessage run(
            @HttpTrigger(name = "req", methods = {HttpMethod.GET, HttpMethod.POST}, authLevel = AuthorizationLevel.ANONYMOUS) HttpRequestMessage<Optional<String>> request,
            final ExecutionContext context) {
        try {
            // 函数业务逻辑
            String result = executeBusinessLogic();
            return request.createResponseBuilder(HttpStatus.OK).body(result).build();
        } catch (Exception e) {
            context.getLogger().severe("函数执行失败: " + e.getMessage());
            // 发送失败通知邮件
            sendFailureNotification(e.getMessage());
            return request.createResponseBuilder(HttpStatus.INTERNAL_SERVER_ERROR).body("执行失败").build();
        }
    }

    private void sendFailureNotification(String errorMsg) {
        Email from = new Email("your-alert@example.com");
        String subject = "Azure Function执行失败通知";
        Email to = new Email("user@example.com");
        Content content = new Content("text/plain", "函数执行出错，错误信息：" + errorMsg);
        Mail mail = new Mail(from, subject, to, content);

        SendGrid sg = new SendGrid(System.getenv("SENDGRID_API_KEY"));
        try {
            sg.api(mail);
        } catch (IOException ex) {
            ex.printStackTrace();
        }
    }

    private String executeBusinessLogic() throws Exception {
        // 模拟业务逻辑抛出异常
        throw new Exception("数据库连接失败");
    }
}

3. 在Function App的配置中添加SENDGRID_API_KEY应用设置，值为你的SendGrid API密钥。

方案2：调整警报规则的评估频率 #

默认的日志查询警报可能使用了15分钟的聚合窗口，导致延迟。可以通过缩小评估窗口和频率来降低延迟：

• 进入Azure Portal的警报规则详情页，编辑“条件”配置：
  • 将聚合时间范围设置为1分钟（最小支持值）
  • 将评估频率设置为1分钟（最小支持值）
• 确保查询语句能精准匹配失败的函数执行日志（比如用traces | where severityLevel == 3 and message contains "Function execution failed"）
• 保存配置后，警报会每分钟评估一次日志，延迟可降低至1-2分钟内。

方案3：使用Azure Event Grid捕获函数失败事件 #

Azure Function App会向Event Grid发送函数执行状态事件，包括失败事件，可以通过Event Grid触发器来即时触发通知：

1. 在Function App的“事件”页面，启用Event Grid事件订阅，选择“函数执行失败”作为事件类型，目标选择另一个用于发送通知的Azure Function。

2. 创建一个Event Grid触发的函数，代码示例：

import com.microsoft.azure.functions.*;
import com.microsoft.azure.functions.annotation.*;

public class EventGridAlertFunction {
    @FunctionName("EventGridAlert")
    public void run(
            @EventGridTrigger(name = "event") String eventJson,
            final ExecutionContext context) {
        context.getLogger().info("收到函数失败事件: " + eventJson);
        // 调用邮件发送逻辑（可复用方案1中的sendFailureNotification方法）
        sendFailureNotification("函数执行失败，事件详情：" + eventJson);
    }

    // 复用sendFailureNotification方法，同方案1
    private void sendFailureNotification(String errorMsg) {
        // 实现邮件发送逻辑
    }
}

这种方式事件推送几乎实时，能在函数失败后几秒内触发通知。

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