如何在Lambda中提前返回？S3触发Lambda过滤指定文件问题

我来帮你搞定这个问题！你遇到的核心问题是：虽然在判断非text.txt文件时调用了resolve，但Lambda函数里的后续代码（比如发送HTTP请求的逻辑）依然会执行。这是因为Promise的resolve只是标记Promise状态为完成，不会直接中断函数的执行流程，所以后面的代码还是会继续跑起来。

问题分析 #

看你的代码，当!srcKey.includes('text.txt')成立时，你调用了resolve('Not original file')，但函数并没有停止，后续的data定义、HTTP请求初始化等代码依然会执行。这不仅会做无用功，甚至可能导致错误的请求发送出去。

另外还有个小问题：你在req.end()之后直接调用了resolve('Success')，这会导致HTTP请求还没完成，Lambda就提前标记Promise成功，可能请求还没处理完就被Lambda的运行环境终止了。

解决方案 #

这里给你两种可行的修改方式，同时修复请求完成时机的问题：

方式1：在resolve后添加return终止执行 #

在判断块的resolve之后添加return，直接退出当前的Promise回调函数，这样后续代码就不会执行了：

if (!srcKey.includes('text.txt')) {
  console.log('Ignoring non-target file:', srcKey);
  resolve('Not original file');
  return; // 关键：终止后续代码执行
}

方式2：将核心逻辑放入else块 #

把需要处理目标文件的代码（比如构造请求、发送API调用）全部放到else块里，这样只有符合条件的文件才会执行这些逻辑：

if (!srcKey.includes('text.txt')) {
  resolve('Not original file');
} else {
  // 这里放构造data、options、发送HTTP请求的所有代码
}

修复请求完成时机 #

另外，要把resolve('Success')放到HTTP响应的end事件里，确保请求完全处理完成后再标记Promise成功，同时错误处理应该用reject而不是resolve，这样能正确捕获失败情况。

修改后的完整代码 #

const http = require('http');
exports.handler = async (event, context) => {
  return new Promise((resolve, reject) => {
    const srcRegion = event.Records[0].awsRegion;
    const srcEventTime = event.Records[0].eventTime;
    const srcEventName = event.Records[0].eventName;
    const srcIP = event.Records[0].requestParameters.sourceIPAddress;
    const srcBucket = event.Records[0].s3.bucket.name;
    const srcKey = decodeURIComponent(event.Records[0].s3.object.key.replace(/\+/g, " "));
    const srcETag = event.Records[0].s3.object.eTag;

    // 忽略非text.txt的文件
    if (!srcKey.includes('text.txt')) {
      console.log('Skipping file:', srcKey);
      resolve('Not original file');
      return; // 终止后续代码执行
    }

    const data = JSON.stringify({
      lambda: {
        src_bucket: srcBucket,
        src_key: srcKey,
        src_region: srcRegion,
        src_event_time: srcEventTime,
        src_event_name: srcEventName,
        src_ip: srcIP,
        src_etag: srcETag
      }
    });
    
    const options = {
      host: '*****************',
      path: '*****************',
      port: '*****************',
      method: '*****************',
      headers: '*****************'
    };

    const req = http.request(options, (res) => {
      let responseData = '';
      res.on('data', function(d) {
        responseData += d;
      });
      // 请求完成后再标记成功
      res.on('end', function() {
        console.log('API response received:', responseData);
        resolve('Success');
      });
    });

    req.on('error', (e) => {
      console.error('Request failed:', e.message);
      reject(e.message); // 用reject标记失败，符合Promise规范
    });

    req.write(data);
    req.end();
  });
};

关键修改点总结 #

• 添加return在resolve之后，确保非目标文件不会触发后续逻辑
• 将resolve('Success')移到响应的end事件中，保证请求处理完成再返回
• 错误处理改用reject，让Promise能正确捕获失败状态
• 增加日志输出，方便调试排查问题

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