如何强制AWS Lambda执行完全部代码：Airtable插入记录失败排查

核心问题 #

你的Lambda部署后无法写入Airtable的最主要原因是异步操作没有等待执行完成，同时存在未定义变量的语法问题：

• 你封装的insertRecord方法返回Promise对象，但在handler中直接调用没有加await关键字，Lambda执行到handler代码末尾就会立即冻结运行环境，不会等待Airtable的网络请求和回调执行。本地运行时Node.js进程不会主动退出，所以异步操作能正常完成，部署到Lambda后就会出现请求未发出就被中断的情况。
• 代码中console.log("iteration: " + iteration);的iteration变量没有定义，执行时会抛出异常，直接终止后续逻辑。

修复后的代码 #

console.log('Loading function');
const Airtable = require('airtable');
const apiKey = process.env.AIRTABLE_API_KEY;
const BaseTable = process.env.AIRTABLE_BASE_TABLE;
var base = new Airtable({
  apiKey: apiKey
}).base(BaseTable);
const table = base('Contacts');

exports.handler = async (event) => {
  // 用循环下标替代未定义的iteration变量
  for (let index = 0; index < event.Records.length; index++) {
    const { messageId, body } = event.Records[index];
    console.log("iteration: " + index);
    try {
      const data = JSON.parse(body);
      var fields = {
        "Full Name (First Middle Last)": data.firstname + ' ' + data.lastname,
        "Email": data.email,
        "Phone": data.phonenumber,
        "Address": data.address_one + ' ' + data.address_two,
        "City": data.city,
        "State/Province": data.state,
        "Postal Code": data.zip,
        "Country": data.country,
        "Birthday": data.dob,
      };
      // 加await等待写入操作完成
      await insertRecord(fields);
    } catch (err) {
      // 捕获单条记录处理错误，避免影响其他消息处理
      console.error('处理消息失败，messageId:', messageId, '错误信息:', err);
      // 可选：抛出错误让SQS重试这条消息
      // throw err;
    }
  }

  console.log('before the end');
  return { statusCode: 200 };
};

function insertRecord(fields) {
  console.log('insert Record');
  return new Promise((resolve, reject) => {
    table.create([{
      fields: fields
    }], function(err, records) {
      if (err) {
        console.log('ERROR');
        console.log(err);
        reject(err);
      } else {
        console.log('SUCCESS');
        resolve(records);
      }
    });
  });
}

额外检查项 #

如果修复代码后仍然无法写入，逐一检查以下配置：

• 确认Lambda控制台已经正确配置AIRTABLE_API_KEY、AIRTABLE_BASE_TABLE两个环境变量，取值和你本地测试用的完全一致
• 如果Lambda绑定了VPC，需要确认VPC配置了NAT网关，否则Lambda没有公网访问权限，无法调用Airtable的公网API
• 确认Lambda的执行超时时间设置不低于10秒，避免网络请求还未返回就被强制终止
• 确认你使用的Airtable API密钥有对应Base下Contacts表的写入权限，Base ID、表名拼写完全正确

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