DynamoDB 记录未通过地图循环添加

Question

我正在使用 Axios 从 API 获取价格（通常为数千），然后想将其存储在 DynamoDB 中。如果我在本地调用 lambda 函数，一切都会按预期工作，但如果我部署该函数并使用 AWS CLI 调用它，则它不再在 DynamoDB 中存储任何值。我在请求中收到的数据以及来自 Axios 调用的响应是相同的。

我以某种方式认为这是调用 DynamoDB 的异步函数的范围问题，但我无法解决它。期待您的建议。如果您需要更多代码，请告诉我。

更新价格.js

import { updatePrice } from "./libs/pricing-lib";
import {
    success,
    failure
} from "./libs/response-lib";

export async function main(event, context) {
    try {
        let result = await updatePrice(event.pathParameters.id, event.pathParameters.date);
        return success(result);
    } catch(e) {
        return failure(e);
    }
}

dynamodb-lib-js

import AWS from "aws-sdk";
export function call(action, params) {
    const dynamoDb = new AWS.DynamoDB.DocumentClient();
    return dynamoDb[action](params).promise();
}

定价-lib.js

export async function updatePrice(stockid, from) {
  try {
    let url = getUrl(stockid, from);
    const resultEodApi = (await axios.get(url)).data;

    resultEodApi.map((price) => {
      try {
        let priceParams = {
          TableName: process.env.pricesTableName,
          Item: {
            stockid: stockid,
            date: price.date,
            close: price.close
          }
        };
        dynamoDbLib.call("put", priceParams);
      } catch (e) {
        return e;
      }
    });

    return true;
  } catch (e) {
    return e;
  }
}

Answer 1

稍微扩展一下 Ashish 的回答。

问题：

正如 Ashish 所说，该put操作在 Lambda 部署中不起作用的原因是调用是异步执行的。

调用dynamoDb[action](params).promise()启动异步put操作，并返回一个 Promise 对象。当put操作返回时，promise 将被解析。

但是，在您的代码中，您既await不会解析承诺，也不会将承诺作为处理程序的输出返回。调用updatePrice终止并返回undefined，此时AWS Lambda 挂起函数的执行。结果，put电话永远不会接通。

为什么本地和远程执行之间存在差异？

您看到远程执行和本地执行之间存在差异的原因是本地 node.js 进程和 Lambda 函数具有不同的语义。

当您在本地运行 node.js 进程时，node.js 进程仅在所有承诺都得到解决后终止¹。

Lambda 执行的行为不同。Lambda 在终止执行之前不会等待 promise 得到解决²。相反，Lambda 在解析处理程序返回的承诺后立即终止执行。在您的情况下，处理程序函数返回true³，因此它会立即解决，并且执行终止。那时，您的put呼叫尚未解决。

为了说明差异，请考虑以下代码：

function sleep(ms) {
  return new Promise(resolve => setTimeout(resolve, ms));
}       

module.exports.hello = async (event) => {
  sleep(300).then(() => console.log("Finished doing my asynchronous thing, can exit now!"))    
  console.log("Function execution done!")
  return true;
};

// call the handler when running locally:
if (require.main === module) { module.exports.hello(); }

当您在本地运行它时，函数执行完成，但节点进程仍在运行，直到 promise 得到解决。在本地运行，您将获得以下输出（注意顺序）：

> Function execution done!
> Finished doing my asynchronous thing, can exit now!

在 lambda 上运行，当函数执行结束时，其余的运行也会结束。承诺永远不会解决。我们将得到以下输出：

START RequestId: <id> Version: $LATEST
2019-12-26T09:04:28.843Z    <id>    INFO    Function execution done!
END RequestId: <id>
REPORT RequestId: <id>  Duration: 3.37 ms   Billed Duration: 100 ms Memory Size: 1024 MB    Max Memory Used: 71 MB  Init Duration: 114.44 ms    

我们只得到Function execution done!印刷品。另请注意，执行持续时间仅为 3.37 毫秒。在 AWS 停止进程之前，我们异步运行的 300 毫秒睡眠没有时间解决。

解决问题

来自AWS Lambda 开发人员指南：

如果您的代码执行异步任务，请返回承诺以确保它完成运行。当您解决或拒绝承诺时，Lambda 会向调用者发送响应或错误。

您可以使用 Ashish 的解决方案——返回您创建的承诺。或者，您可以明确地await将Promise.all. 在任何一种情况下，重要的是要确保在从函数返回之前不会丢失您创建的任何承诺。

¹更具体地说，它等待事件循环为空。

²它实际上暂停了执行。下次调用处理程序时，将从同一位置继续执行。如果您连续多次调用处理程序，您put的某些s 可能会通过，具体取决于时间以及 aws-sdk 库在执行流程中处理此类中断的情况，但很难预测。

³实际上，async函数的返回值总是一个包装返回值的promise。因此，在您的情况下，您所拥有的是return true;-true包装在一个Promise对象中，该对象立即解析并终止执行。