使用AWS DynamoDB scan回调结果赋值外部变量为空的解决方法

你遇到的这个问题其实是JavaScript异步操作的典型坑——docClient.scan是异步执行的，它的回调函数会在DynamoDB返回数据之后才触发，但你在回调外部访问tmp的时候，回调还没来得及执行，所以tmp还是初始的空数组。

举个直观的执行顺序例子：

var tmp = [];
console.log("1. 声明tmp并初始化为空数组");

docClient.scan(params, (err, data) => {
  console.log("3. 扫描完成，进入回调函数");
  tmp = data.Items;
});

console.log("2. 回调外访问tmp，此时tmp还是:", tmp);

这段代码的打印顺序是1→2→3，你在第二步访问tmp的时候，第三步的回调还没跑，自然拿不到数据。

解决方案1：把后续逻辑放到回调内部 #

既然回调是拿到扫描结果的地方，那就把查询另一张表的逻辑直接放在这个回调里，确保能拿到tmp的有效值：

var tmp = [];
docClient.scan(params, (err, data) => {
  if (err) {
    console.error("扫描第一张表失败:", err);
    return;
  }
  // 此时扫描完成，data.Items有数据了
  tmp = data.Items;
  console.log("扫描到的数据:", tmp);

  // 构造第二张表的查询参数，比如用batchGet批量查询
  const secondTableParams = {
    RequestItems: {
      "你的第二张表名称": {
        Keys: tmp.map(item => ({
          // 替换成两张表关联的字段，比如id
          id: item.id
        }))
      }
    }
  };

  // 用拿到的tmp数据查询第二张表
  docClient.batchGet(secondTableParams, (batchErr, batchData) => {
    if (batchErr) {
      console.error("查询第二张表失败:", batchErr);
      return;
    }
    // 处理两张表的合并数据
    const secondTableItems = batchData.Responses["你的第二张表名称"];
    console.log("第二张表查询结果:", secondTableItems);
  });
});

这样所有依赖扫描结果的操作都在回调内部执行，就能保证tmp是有值的。

解决方案2：过渡到Promise/Async-Await（进阶） #

如果后续逻辑复杂，回调嵌套太多会形成“回调地狱”，你可以把docClient的异步方法包装成Promise，用async-await让代码更线性：

// 把scan包装成Promise函数
function scanDynamoTable(params) {
  return new Promise((resolve, reject) => {
    docClient.scan(params, (err, data) => {
      if (err) reject(err);
      else resolve(data.Items);
    });
  });
}

// 把batchGet也包装成Promise
function batchGetFromTable(params) {
  return new Promise((resolve, reject) => {
    docClient.batchGet(params, (err, data) => {
      if (err) reject(err);
      else resolve(data);
    });
  });
}

// 用async函数执行整个流程
async function fetchAndCombineData() {
  try {
    // 等待扫描完成，拿到tmp数据
    const tmp = await scanDynamoTable(params);
    console.log("扫描到的数据:", tmp);

    // 构造第二张表的查询参数
    const secondTableParams = {
      RequestItems: {
        "你的第二张表名称": {
          Keys: tmp.map(item => ({ id: item.id }))
        }
      }
    };

    // 等待第二张表查询完成
    const batchData = await batchGetFromTable(secondTableParams);
    const secondTableItems = batchData.Responses["你的第二张表名称"];
    console.log("第二张表查询结果:", secondTableItems);
  } catch (err) {
    console.error("流程出错:", err);
  }
}

// 启动整个流程
fetchAndCombineData();

这种写法和同步代码的逻辑顺序一致，可读性更高，也更易维护。

核心思路就是：异步操作的结果只能在它的回调（或者Promise的resolve后）里可靠访问，不要试图在异步操作外部直接拿结果，因为那时候异步任务还没完成。

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