AWS Lambda Dynamodb 更新不更新项目

Question

有一个名为 Portal 的 DynamoDB 表。 从节点中编写的 Lambda 函数中，我想更新项目的 status 和 ts 字段（通过调用 signalJobStart 函数）并等待异步更新函数完成之前的承诺继续。 由于某种原因，没有发生更新，但是在操作过程中没有引发错误。 日志中没有错误，我可以在日志中看到“已完成”的日志消息。

为什么表格中的项目没有变化？ 为什么我在日志中既看不到错误也看不到成功消息？

（我也尝试过没有承诺，但结果相同。表格项没有更新 - 甚至是异步的。）

这是来自 Lambda 的代码：

const AWS = require('aws-sdk');
const docClient = new AWS.DynamoDB.DocumentClient({region: 'eu-west-1'});

module.exports = {
signalJobStart: function(accountId, jobId) {
    console.log("Signaling job start for account %s and job %s", accountId, jobId);

    let table = "Portal";

    let params = {
        TableName: table,
        Key:{
            "accountid": accountId,
            "entity": jobId
        },
        UpdateExpression: "SET status = :s, ts = :t",
        ExpressionAttributeValues:{
            ":s": "running",
            ":t": Date.now()
        },
        ReturnValues:"UPDATED_NEW"
    };

    let updatePromise = docClient.update(params, function(err, data) {
        if (err) {
            console.error("Unable to update item. Error JSON:", JSON.stringify(err, null, 2));
        } else {
            console.log("UpdateItem succeeded:", JSON.stringify(data, null, 2));
        }
    }).promise();

    updatePromise.then(function(data) {
      console.log('Success');
    }).catch(function(err) {
      console.log(err);
    });

    console.log("FINISHED");
}};

Answer 1

对我有什么帮助：

1. 以异步/等待方式执行：

   exports.handler = async (event) => {
   ...
   let _result = "";
   try {
      _result = await docClient.update(_updateParams).promise();
   } catch(ex){
      _result = ex;
   }
   ..
   

2. 确保我正在写入的字段不是保留字，如下例所示（“数据”是保留字）：

   {
   ..
   UpdateExpression: "set data = :newdata",
   ExpressionAttributeValues: {
   ":newdata": "blah"
   },
   ..
   

   要检查这一点：将列重命名为“data2” - 没有问题。

3. 确保您在 IAM 控制台的“执行角色”中具有权限。

Answer 2

我觉得可以

docClient.update(params).promise()

然后继续使用.then(...) 语句流使其工作。 就个人而言，我认为错误处理程序语法（用于update）可能不会给您一个承诺。

如果这不起作用，请告诉我。

Answer 3

在您的查询中status 是保留关键字，并且在dynamodb 中被禁止。所以在你的查询中使用ExpressionAttributeNames。

同样使用新的 Promise 来处理 promise

请查看下方对您的帮助：

module.exports = {
  signalJobStart: function (accountId, jobId) {
    return new Promise(function (resolve, reject) {
      console.log("Signaling job start for account %s and job %s", accountId, jobId);

      let table = "Portal";

      let params = {
        TableName: table,
        Key: {
          "accountid": accountId,
          "entity": jobId
        },
        UpdateExpression: "SET #status = :s, ts = :t",
        ExpressionAttributeNames: {
          '#status': 'status'
        },
        ExpressionAttributeValues: {
          ":s": "running",
          ":t": Date.now()
        },
        ReturnValues: "UPDATED_NEW"
      };

      docClient.update(params, function (err, data) {
        if (err) {
          console.error("Unable to update item. Error JSON:", JSON.stringify(err, null, 2));
          reject(err)
        } else {
          console.log("UpdateItem succeeded:", JSON.stringify(data, null, 2));
          resolve({ message: 'sucsss', data: data })
        }
      })
    });
  }
};

注意：还请确认accountid 和entity 在您的数据库中都是Key。