当AWS Lambda执行失败时，如何调用HTTPS端点并传递事件对象？

首先明确：你考虑的CloudWatch告警+SNS方案无法满足需求——CloudWatch告警仅基于聚合指标触发，只能发送指标类通知，无法获取每次Lambda失败对应的原始event对象，因此没法把当初传递的数据传给你的端点。

下面分两种场景给出可行方案：

场景1：Node.js应用同步调用Lambda #

如果你的应用是用RequestResponse模式同步调用Lambda（调用后等待返回结果），那么Lambda失败时会直接抛出错误到调用方，此时可以直接在应用的错误捕获逻辑里调用你的HTTPS端点：

const AWS = require('aws-sdk');
const lambda = new AWS.Lambda({ region: 'your-region' });
const axios = require('axios');

async function invokeTargetLambda(eventData) {
  const invokeParams = {
    FunctionName: 'Your-Target-Lambda-Name',
    InvocationType: 'RequestResponse',
    Payload: JSON.stringify(eventData)
  };

  try {
    const response = await lambda.invoke(invokeParams).promise();
    // 处理Lambda成功返回的结果
    return JSON.parse(response.Payload);
  } catch (lambdaError) {
    // Lambda执行失败，调用公司的HTTPS端点
    await axios.post('https://your-company-endpoint.com/lambda-failure', {
      originalEvent: eventData,
      errorDetails: {
        message: lambdaError.message,
        code: lambdaError.code
      }
    });
    // 可选：将错误继续抛出给上层处理
    throw lambdaError;
  }
}

这种方案简单直接，不需要额外的AWS服务，所有逻辑都在你的应用内处理。

场景2：Node.js应用异步调用Lambda #

如果你的应用是用Event模式异步调用Lambda（调用后立即返回，不等待执行结果），此时调用方无法直接感知Lambda的失败状态，需要借助Lambda死信队列（DLQ）+处理Lambda的组合来实现：

步骤1：配置目标Lambda的死信队列 #

1. 创建一个SQS标准队列（作为死信队列，用于存储Lambda失败的事件）
2. 进入目标Lambda的配置页面，找到「异步调用」设置：
   • 开启「死信队列」，选择刚才创建的SQS队列
   • 设置重试次数（比如2次，Lambda默认会重试2次失败的异步调用，之后才会把事件发送到DLQ）

步骤2：创建处理死信队列的Lambda #

这个Lambda会被SQS队列触发，读取队列中存储的失败事件，提取原始event后调用你的HTTPS端点：

const axios = require('axios');

exports.handler = async (sqsEvent) => {
  for (const record of sqsEvent.Records) {
    try {
      // 解析DLQ中的消息，原始event存储在requestPayload字段中
      const lambdaFailureDetails = JSON.parse(record.body);
      const originalEvent = lambdaFailureDetails.requestPayload;

      // 调用公司的HTTPS端点
      await axios.post('https://your-company-endpoint.com/lambda-failure', {
        originalEvent: originalEvent,
        failureReason: lambdaFailureDetails.errorMessage,
        failureType: lambdaFailureDetails.errorType,
        lambdaRequestId: lambdaFailureDetails.requestId
      });

      // 处理成功后，SQS会自动删除当前消息（前提是Lambda执行无报错）
    } catch (notifyError) {
      console.error('Failed to notify company endpoint:', notifyError);
      // 抛出错误让SQS重试该消息（最多重试次数由SQS配置决定）
      throw notifyError;
    }
  }
  return { statusCode: 200, body: 'Failure events processed' };
};

步骤3：配置SQS触发器 #

给处理Lambda添加SQS触发器，选择刚才创建的死信队列，设置批量大小（比如10）和批处理窗口。

关键注意事项 #

• 权限配置：确保目标Lambda有权限向死信队列发送消息，处理Lambda有权限从死信队列读取消息
• 幂等性：你的HTTPS端点要支持幂等，避免因SQS重试导致重复通知
• 超时设置：处理Lambda的超时时间要足够覆盖HTTPS调用的耗时（比如设置为10秒）
• 重试策略：根据业务需求调整Lambda异步调用的重试次数和SQS的重试间隔

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