如何在Node.js Lambda函数中实现同步DDB查询？

嗨，我来帮你搞定这个问题！其实你完全不需要找同步查询API——AWS SDK for JavaScript的DynamoDB DocumentClient本身就支持Promise，用async/await就能轻松实现“等待查询完成再继续”的需求，完美适配Lambda的执行逻辑。

核心思路：把回调式调用改成Promise+async/await #

原来的代码用了回调函数，Lambda可能会在回调执行前就结束函数进程。只要你不给docClient.query()传回调参数，它就会返回一个Promise对象，然后用await就能等待查询完成，再处理结果。

改造后的完整Lambda示例代码 #

const AWS = require('aws-sdk');
const docClient = new AWS.DynamoDB.DocumentClient();

// Lambda handler必须声明为async函数，这样Lambda会等待内部的Promise完成
exports.handler = async (event) => {
  // 先定义你的查询参数（根据实际需求填写）
  const params = {
    TableName: "YourTableName",
    KeyConditionExpression: "#yr = :yyyy",
    ExpressionAttributeNames: {
      "#yr": "year"
    },
    ExpressionAttributeValues: {
      ":yyyy": 2015
    }
  };

  try {
    // 等待查询完成，拿到结果
    const data = await docClient.query(params).promise();
    
    console.log("Query succeeded.");
    data.Items.forEach(item => {
      console.log(" -", `${item.year}: ${item.title} ... ${item.info.genres} ... ${item.info.actors[0]}`);
    });

    // 这里可以用查询结果做后续处理，比如返回给调用方
    return {
      statusCode: 200,
      body: JSON.stringify({ items: data.Items })
    };
  } catch (err) {
    console.error("Unable to query. Error:", JSON.stringify(err, null, 2));
    // 错误处理逻辑
    return {
      statusCode: 500,
      body: JSON.stringify({ error: err.message })
    };
  }
};

关键说明 #

1. Lambda Handler必须是async函数：Lambda会自动等待async函数内部的所有Promise执行完成，不会提前终止进程，这样你就能确保查询结果被处理完。
2. .promise()方法：在SDK v2中，所有回调式的方法都可以通过调用.promise()来转换成Promise形式，这是官方推荐的异步处理方式。
3. 错误处理用try/catch：替代原来回调里的err判断，更符合现代JavaScript的写法，也更容易维护。

如果你用的是AWS SDK v3（最新版本），写法会更简洁——v3的客户端方法本身就返回Promise，直接await docClient.send(new QueryCommand(params))就行，原理是一样的。

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