将 AWS 移动后端连接到 DynamoDB

Question

我正在尝试使用 AWS 移动后端（使用 lambda 函数）插入 dynamoDB（也在移动后端配置），但到目前为止没有成功。

相关代码：

'use strict';
console.log("Loading function");

const AWS = require('aws-sdk');
const docClient = new AWS.DynamoDB.DocumentClient({region:process.env.MOBILE_HUB_PROJECT_REGION});



exports.handler = function(event, context, callback) {
    var responseCode = 200;
    var requestBody, pathParams, queryStringParams, headerParams, stage,
    stageVariables, cognitoIdentityId, httpMethod, sourceIp, userAgent,
    requestId, resourcePath;
    console.log("request: " + JSON.stringify(event));

    // Request Body
    requestBody = event.body;

    if (requestBody !== undefined && requestBody !== null) {

        // Set 'test-status' field in the request to test sending a specific response status code (e.g., 503)
        responseCode = JSON.parse(requestBody)['test-status'];
    }

    // Path Parameters
    pathParams = event.path;

    // Query String Parameters
    queryStringParams = event.queryStringParameters;

    // Header Parameters
    headerParams = event.headers;

    if (event.requestContext !== null && event.requestContext !== undefined) {

        var requestContext = event.requestContext;

        // API Gateway Stage
        stage = requestContext.stage;

        // Unique Request ID
        requestId = requestContext.requestId;

        // Resource Path
        resourcePath = requestContext.resourcePath;

        var identity = requestContext.identity;

        // Amazon Cognito User Identity
        cognitoIdentityId = identity.cognitoIdentityId;

        // Source IP
        sourceIp = identity.sourceIp;

        // User-Agent
        userAgent = identity.userAgent;
    }

    // API Gateway Stage Variables
    stageVariables = event.stageVariables;

    // HTTP Method (e.g., POST, GET, HEAD)
    httpMethod = event.httpMethod;

    // TODO: Put your application logic here...

    let params = {
        Item:{
            "prop1":0,
            "prop2":"text"
        },
        TableName:"testTable"
    };

    docClient.put(params, function(data, err){
        if(err)
            responseCode = 500;
        else
            {
                responseCode = 200;
                context.succeed(data);
            }
    });

    // For demonstration purposes, we'll just echo these values back to the client
    var responseBody = {
        requestBody : requestBody,
        pathParams : pathParams,
        queryStringParams : queryStringParams,
        headerParams : headerParams,
        stage : stage,
        stageVariables : stageVariables,
        cognitoIdentityId : cognitoIdentityId,
        httpMethod : httpMethod,
        sourceIp : sourceIp,
        userAgent : userAgent,
        requestId : requestId,
        resourcePath : resourcePath
    };

    var response = {
        statusCode: responseCode,
        headers: {
            "x-custom-header" : "custom header value"
        },
        body: JSON.stringify(responseBody)
    };
    console.log("response: " + JSON.stringify(response))
    context.succeed(response);
};

由于某种原因，这不会将项目放在桌子上。 我使用角色部分授予了必要的权限，还有什么遗漏吗？

**responseCode 仅用于测试目的。

编辑： 试过AWS node.js lambda request dynamodb but no response (no err, no return data) 也没用。

编辑2： 添加了完整的处理程序代码。 （它是创建第一个 AWS lambda 时默认生成的代码）。

Answer 1

我已经重构了一些代码，使其看起来更简单，并使用async/await（确保选择 Node 8.10 作为函数的运行环境）而不是回调。我还去掉了上下文和回调参数，因为它们用于旧版本的 NodeJS。使用 Node 8+ 后，async/await 应该是默认选项。

此外，可以在 docClient.putItem 上链接一个 .promise()，因此您可以轻松地等待它，从而使您的代码更简单。我只留下了 DynamoDB 部分（这与您的问题相关）

'use strict';
console.log("Loading function");

const AWS = require('aws-sdk');
const docClient = new AWS.DynamoDB.DocumentClient({region:process.env.MOBILE_HUB_PROJECT_REGION});

exports.handler = async (event) => {

    let params = {
        Item:{
            "prop0":1,
            "prop2":"text"
        },
        TableName:"testTable"
    };

    try {
      await docClient.put(params).promise();
    } catch (e) {
      console.log(e)
      return {
        messsage: e.message
      }
    }

    return { message: 'Data inserted successfully' };

};

如果仍然无法正常工作，请记住以下事项：

1. 确保您的 Lambda 函数具有在 DynamoDB 上插入项目的正确权限（AmazonDynamoDBFullAccess 会这样做）

2. 在将项目插入 DynamoDB 时，您始终必须提供分区键。在您的示例中，JSON 只有两个属性：prop1 和 prop2。如果它们都不是分区键，那么你的代码肯定会失败。

3. 确保你的表也存在

如果您的代码失败，只需检查 CloudWatch 日志，因为现在任何异常都会被捕获并在控制台上打印出来。

Answer 2

表中没有写入数据的原因是因为对DynamoDBput的调用是异步的，会通过调用你的回调返回。但在此期间，其余代码会继续执行，您的函数最终会在对 DynamoDB 的调用有机会完成之前完成。

您可以使用await / async 关键字使您的代码同步：

async function writeToDynamoDB(params) {
 return new Promise((resolve,reject) => {
    docClient.put(params, function(data, err){
        if(err)
            reject(500);
        else
            resolve(data);
     });
 });
}

let params = ...
var data = await writeToDynamoDB(params)

您可以在https://github.com/sebsto/maxi80-alexa/blob/master/lambda/src/DDBController.ts 找到我编写的示例代码（在 Typescript 中）