node.js - AWS DynamoDB node.js put请求不会将数据放入Dynamo表中

Question

我正在使用以下代码将数据提取到 DynamoDB。

从 Kinesis 读取的代码

var AWS = require("aws-sdk"),
DOC = require("dynamodb-doc");
docClient = new DOC.DynamoDB();

function upsert(result) {
   var info = new Info(result);
   console.log('Within upsert :', info.AcctNo);
   docClient.putItem({
      TableName: "test_lamda_dynamo_table",
      Item: info
   }, function(err, data) {
      if (err) {
        console.error('error', err);
        context.done('error', err);
      } else {
        console.log('success', data);
        context.done('success', event.Records);
      }
   });
}

我无法在 cloudwatch 日志中看到错误处理程序系统输出，也无法在 DynamoDB 中看到数据。

以下是来自 cloudwatch 的示例日志

"Within upsert Info: 1234456"

我无法在 cloudwatch lambda 函数日志中看到与 PutItem 函数相关的任何错误日志。

请建议我在这里做错了什么。

Answer 1

我在下面的链接中找到了此问题的解决方案。

Querying DynamoDB with Lambda does nothing

这是因为 lambda 处理程序中也使用了 context.succeed 调用。

    exports.handler = function(event, context) {

  event.Records.forEach(function(record) {
    try {
      var payload = new Buffer(record.kinesis.data, 'base64').toString('ascii');

      console.log('Decoded payload:', payload);

      upsert(payload, context);

      // bug
      context.succeed("Success")

    } catch (e) {
      // log error and continue
      console.error('Error occured while inserting messages to Dynamo' + e);
    }
  });
};