AWS Лямбда с использованием функции s3 getObject и putItem для вставки в DynamoDB, но ничего не происходит

Question

это код node.js:

'use strict';

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

AWS.config.update({
    region: 'eu-west-1'});

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

const tableName = 'Fair';

const s3 = new AWS.S3();

exports.handler = async (event) => {
    var getParams = {
        Bucket: 'dataforfair', //s3 bucket name
        Key: 'fairData.json' //s3 file location
    }
    
    const data = await s3.getObject(getParams).promise()
    .then( (data) => {
        //parse JSON 
        let fairInformations = JSON.parse(data.Body.toString());

        fairInformations.forEach(function(fairInformationEntry) {
            console.log(fairInformationEntry);
            var params = {
                TableName: tableName,
                Item: {
                    "year": fairInformationEntry.year,
                    "fairName":  fairInformationEntry.fairName,
                    "info": fairInformationEntry.info
                }
            };
        
            docClient.put(params, function(err, data) {
                console.log('*****test');
            if (err) {
                console.error("Unable to add fairInformation", fairInformationEntry.fairName, ". Error JSON:", JSON.stringify(err, null, 2));
            } else {
                console.log("PutItem succeeded:", fairInformationEntry.fairName);
            }
            });
        });
       })
       .catch((err) => {
           console.log(err);
       });
      

    const response = {
        statusCode: 200,
        body: JSON.stringify(data),
    };
    return response;
};

Привет всем,

Я хочу поместить данные в базу данных Dynamo после получения файла JSON из корзины s3. Получение JSON работает и console.log (fairInformationEntry); также все еще запущен, но docClient.put () никогда не вызывается. Я не получаю ошибок, ничего. Я не знаю, что не так и почему это не работает. У меня есть правильная роль IAM и доступ ко всему, что мне нужно.

Надеюсь, вы мне поможете!

Answer 1

Проблема заключается в смешении обещания, обратного вызова и асинхронного ожидания. Вы также пытаетесь выполнить асинхронную операцию внутри foreach. Код должен выглядеть примерно так:

"use strict";

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

AWS.config.update({
  region: "eu-west-1"
});

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

const tableName = "Fair";

const s3 = new AWS.S3();

exports.handler = async event => {
  var getParams = {
    Bucket: "dataforfair", //s3 bucket name
    Key: "fairData.json" //s3 file location
  };

  const data = await s3.getObject(getParams).promise();
  //parse JSON
  let fairInformations = JSON.parse(data.Body.toString());

  await Promise.all(
    fairInformations.map(fairInformationEntry => {
      console.log(fairInformationEntry);
      var params = {
        TableName: tableName,
        Item: {
          year: fairInformationEntry.year,
          fairName: fairInformationEntry.fairName,
          info: fairInformationEntry.info
        }
      };
      return docClient.put(params).promise();
    })
  );

  const response = {
    statusCode: 200,
    body: JSON.stringify(data)
  };
  return response;
};

Надеюсь, это поможет