使用 Lambda 在 DynamoDB 中存储 JSON 请求

Question

我的 Lambda 函数中有一个返回 json 的 http 请求。我正在使用 node.js。我想将该 json 作为对象保存在我的 DynamoDB 表中。

const http = require('https')
const AWS = require('aws-sdk');

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

exports.handler = async (event) => {
    return httprequest().then((data) => {
        //Parse JSON to objects

        // in this case not neccessary because it's already parsed.
        // data is already object

        // var arr_from_json = JSON.parse(data);

        //add Item to DynamoDB
        var params = {
            TableName: 'json',
            Item: {
                date: Date.now(),
                answer: data.answer,
                forced: data.forced,
                image: data.image
            }
        };

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

        docClient.put(params, function(err, data) {
            if (err) console.log(err);
            else console.log(data);
        });

        // Respond with JSON
        const response = {

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

function httprequest() {
    return new Promise((resolve, reject) => {
        const options = {
            host: 'yesno.wtf',
            path: '/api',
            port: 443,
            method: 'GET'
        };
        const req = http.request(options, (res) => {
            if (res.statusCode < 200 || res.statusCode >= 300) {
                return reject(new Error('statusCode=' + res.statusCode));
            }
            var body = [];
            res.on('data', function (chunk) {
                body.push(chunk);
            });
            res.on('end', function () {
                try {
                    body = JSON.parse(Buffer.concat(body).toString());
                } catch (e) {
                    reject(e);
                }
                resolve(body);
            });
        });
        req.on('error', (e) => {
            reject(e.message);
        });
        // send the request
        req.end();
    });
}

JSON

{"answer":"no","forced":false,"image":"https://yesno.wtf/assets/no/8-5e08abbe5aacd2cf531948145b787e9a.gif"}

但是，它不会将对象存储在 DynamoDB 中。我能做些什么不同的事情？首先存储在 DynamoDB 中的部分是否正确？

Answer 1

首先，我假设表存在并且 lambda 具有正确的权限。否则，您将分别收到 Requested resource not found 或 not authorized to perform: dynamodb:PutItem 错误。

您正在调用docClient.put(...)，但随后只需从 lambda 返回响应，而无需等待 DynamoDB 的响应。如果您在发回响应之前等待 DynamoDB 的响应，它会按预期工作，您可以在下面使用 await 的示例中看到：

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

// There's no need to re-instantiate this on each request:
const docClient = new AWS.DynamoDB.DocumentClient({ region: 'eu-west-1', apiVersion: 'latest' });    

function httprequest() {
    return new Promise((resolve) => {
        setTimeout(() => {
            resolve({
                answer: 'no',
                forced: false,
                image: 'https://yesno.wtf/assets/no/8-5e08abbe5aacd2cf531948145b787e9a.gif',
            });
        }, 2000);
    })
}

exports.handler = async (event) => {
    try {
        const data = await httprequest();

        const params = {
            Item: {
                date: Date.now(),
                answer: data.answer,
                forced: data.forced,
                image: data.image
            },

            TableName: 'json'
        };

        await docClient.put(params).promise();

        console.log('Document inserted.');

        return JSON.stringify(data);
    } catch(err) {
        console.log(err);

        return err;
    }
};

话虽如此，直觉上我会说如果达到docClient.put(...)，那么无论如何都应该将文档插入到DynamoDB中，但看起来情况并非如此，至少在使用回调时不是这样。但是，如果您将其替换为 docClient.put(params).promise()，则会插入该文档，即使您不等待 DynamoDB 的响应也是如此。 docClient.put(params) 单独也行不通。

我认为这有点令人困惑/违反直觉，所以我创建了另一个问题，以了解更多关于为什么它的工作方式：

Why values are not inserted into DynamoDB unless calling `.promise()`?