DynamoDB 写入不一致

Question

在无服务器框架中，我们将以下代码用作LAMBDA功能，每2分钟用Cron触发。我们面临的问题是，DynamoDB中的写作是不一致的，我们想拥有3篇文章，但是我们每2分钟收到1或2篇著作。 DynamoDB具有HASH键的时间，然后对键进行分类日期和计费模式：配置。是否有人面对DynamoDB的行为或同样的问题来分享他如何so索。谢谢

"use strict";

const AWS = require("aws-sdk");
const axios = require("axios");

const dynamoDb = new AWS.DynamoDB.DocumentClient();

const lambda = new AWS.Lambda({
  region: "us-east-1",
});

module.exports.getWeather = async (event, context, callback) => {
  const openWeatherMapAPIURL = `http://api.openweathermap.org/data/2.5/weather?id=${event}&appid=XXXXXXXXXXXXXXXXXXXXXXX&units=metric`;
  const currentWeather = await axios
    .get(openWeatherMapAPIURL)
    .then((records) => {
      console.log(records);

      const d = new Date(records.headers.date);
      let hour = d.getHours();

      const params = {
        TableName: process.env.DYNAMODB_TABLE_NAME,
        Item: {
          hour: hour,
          date: records.headers.date,
          city: records.data.name,
          temp: records.data.main.temp,
          feelsLike: records.data.main.feels_like,
          description: records.data.weather[0].description,
        },
      };
      setTimeout(function () {
        dynamoDb.put(params, (error) => {
          // handle potential errors
          console.log(`zapis na: ${records.data.name} ${records.headers.date}`);
          if (error) {
            console.log(error);
            console.error(error);
            return;
          }
        });
      }, 3000);
      
    })
    .catch((error) => {
      console.log(error);
      return;
    });
 

  const response = {
    statusCode: 200,
    body: JSON.stringify({
      message: `Weather from ${event} was requested!`,
    }),
  };
  callback(null, response);
};

module.exports.cron_launcher = (event, context, callback) => {
  const requestedID = ["786735", "792578", "785842"];

  requestedID.forEach((requestedID) => {
    const params = {
      FunctionName: process.env.HANDLER_LOCATION + "-getWeather",
      InvocationType: "RequestResponse",
      Payload: JSON.stringify(requestedID),
    };

    return lambda.invoke(params, function (error, data) {
      if (error) {
        console.error(JSON.stringify(error));
        return new Error(`Error printing messages: ${JSON.stringify(error)}`);
      } else if (data) {
        console.log(data);
      }
    });
  });
};

Answer 1

您不在等待DynamoDB.put操作完成。此外，您正在将呼叫包装在settimeout中。在进行网络操作之前​​，您的lambda功能正在返回。在返回Lambda的结果之前，请确保PUT操作成功。

1. 我认为您没有理由在此处使用Settimeout。
2. 您可以调用dynamoDB.put（...）。promise（）以从DynamoDB SDK中获得承诺并等待该承诺。
   2.a，或者您可以继续使用回调，但将整个代码的整个部分包裹在新的Promise对象中，在DynamoDB之后调用Resolve方法。输入调用完成。