DynamoDB updateItem в Lambda не работает тихо - PullRequest
Новая
       6

DynamoDB updateItem в Lambda не работает тихо

0 голосов
/ 07 мая 2019

Я пытаюсь реализовать простой счетчик с помощью функции Lambda, но всякий раз, когда я проверяю его, приведенный ниже элемент updateItem просто не работает: ни один из операторов журнала в обратном вызове не выполняется вообще, и, конечно, соответствующий счетчик в таблице никогда не обновляется. Вот моя лямбда-функция: 

'use strict';
const AWS = require('aws-sdk');
const dynamodb = new AWS.DynamoDB({ apiVersion: '2012-08-10' });

let params = {
    TableName: 'Counters',
    Key: {
        'name': { S: 'global' }
    },
    UpdateExpression: 'SET val = val + :inc',
    ExpressionAttributeValues: {
        ':inc': { N: '1' }
    },
    ReturnValues: 'ALL_NEW'
};

exports.handler = async(event) => {
    console.log("Invoked counter-test");

    dynamodb.updateItem(params, function(err, data) {
        console.log("In updateItem callback");
        if (err)
            console.log(err, err.stack);
        else
            console.log(data);
    });

    console.log("Updated counter");

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

А вот и результат теста: 

Response:
{
  "statusCode": 200,
  "body": "\"Counter updated\""
}

Request ID:
"80e92299-2eea-45e4-9c68-54ccf87199c5"

Function Logs:
START RequestId: 80e92299-2eea-45e4-9c68-54ccf87199c5 Version: $LATEST
2019-05-07T11:34:21.931Z    80e92299-2eea-45e4-9c68-54ccf87199c5    Invoked counter-test
2019-05-07T11:34:21.934Z    80e92299-2eea-45e4-9c68-54ccf87199c5    Updated counter
END RequestId: 80e92299-2eea-45e4-9c68-54ccf87199c5
REPORT RequestId: 80e92299-2eea-45e4-9c68-54ccf87199c5  Duration: 275.91 ms Billed Duration: 300 ms     Memory Size: 128 MB Max Memory Used: 67 MB

Как видите, не выполнялись никакие операторы журнала из обратного вызова updateItems.

Если я пытаюсь обновить счетчик из командной строки, используя aws dynamodb, он работает, однако: 

$ aws dynamodb update-item \
  --table-name Counters \
  --key '{"name": { "S": "global" }}' \
  --update-expression 'SET val = val + :inc' \
  --expression-attribute-values '{":inc": {"N": "1"}}' \
  --return-values ALL_NEW \
  --output json
{
    "Attributes": {
        "name": {
            "S": "global"
        },
        "val": {
            "N": "129"
        }
    }
}

1 Ответ

4 голосов
/ 07 мая 2019

Это связано с асинхронной природой Javascript.

Метод updateItem является асинхронным, и вы не ждете, пока обратный вызов будет запущен, прежде чем вернуться (вы запускаете операцию updateItem, а затемнемедленно вернуть ответ).

Если вы хотите сохранить шаблон обратного вызова, вы должны сделать: 

exports.handler = (event, context, callback) => {
    console.log("Invoked counter-test");

    dynamodb.updateItem(params, function(err, data) {
        console.log("In updateItem callback");
        if (err) {
            console.log(err, err.stack);
            callback(err);
        } else {
            console.log(data);
            console.log("Updated counter");
            const response = {
                statusCode: 200,
                body: JSON.stringify('Counter updated'),
            };
            callback(null, response);
        }
    });
};

Используя обещания: 

exports.handler = (event, context, callback) => {
    console.log("Invoked counter-test");

    dynamodb.updateItem(params).promise()
        .then((data) => {
            console.log(data);
            console.log("Updated counter");

            const response = {
                statusCode: 200,
                body: JSON.stringify('Counter updated'),
            };
            callback(null, response);          
        });
        .catch((err) => {
          console.log(err, err.stack);
          callback(err);
        })
};

Используя await(рекомендуется): 

exports.handler = async (event) => {
    try {
        console.log("Invoked counter-test");

        const data = await dynamodb.updateItem(params).promise();
        console.log(data);

        console.log("Updated counter");

        const response = {
            statusCode: 200,
            body: JSON.stringify('Counter updated'),
        };
        return response;      
    } catch (err) {
      console.log(err, err.stack);
      throw err;
    }
};

См. также Понимание асинхронного JavaScript , Глубокое понимание асинхронности и ожидания JavaScript с примерами и AWS SDK для Javascript - Использование JavaScriptОбещания .

...