Serverless Framework и DynamoDB: неожиданный токен в JSON на JSON.parse

Question

Привет! Я следовал этому Обучающему API без AWS + AWS REST , и все прошло отлично, я получил его на работу.

Теперь я пытаюсь изменить его, но ударил стенупри попытке отправить данные в таблицу DynamoDB.

Использование Postman для отправки допустимого объекта JSON Я получаю ответ 502.Если я тестирую функцию в Lambda, я получаю следующую ошибку:

{
  "errorType": "SyntaxError",
  "errorMessage": "Unexpected token o in JSON at position 1",
  "trace": [
    "SyntaxError: Unexpected token o in JSON at position 1",
    "    at JSON.parse (<anonymous>)",
    "    at Runtime.module.exports.submit [as handler] (/var/task/api/interview.js:11:28)",
    "    at Runtime.handleOnce (/var/runtime/Runtime.js:66:25)",
    "    at process._tickCallback (internal/process/next_tick.js:68:7)"
  ]
}

После поиска решений я обнаружил, что похоже, что event, который передается как JSON.parse(event), являетсяundefined.

Вот serverless.yml:

service: interview

frameworkVersion: ">=1.1.0 <2.0.0"

provider:
  name: aws
  runtime: nodejs10.x
  stage: dev
  region: us-east-1
  environment:
    INTERVIEW_TABLE: ${self:service}-${opt:stage, self:provider.stage}
    INTERVIEW_EMAIL_TABLE: "interview-email-${opt:stage, self:provider.stage}"
  iamRoleStatements:
    - Effect: Allow
      Action:
        - dynamodb:Query
        - dynamodb:Scan
        - dynamodb:GetItem
        - dynamodb:PutItem
      Resource: "*"

resources:
  Resources:
    CandidatesDynamoDbTable:
      Type: 'AWS::DynamoDB::Table'
      DeletionPolicy: Retain
      Properties:
        AttributeDefinitions:
          -
            AttributeName: "id"
            AttributeType: "S"   
        KeySchema:
          -
            AttributeName: "id"
            KeyType: "HASH"
        ProvisionedThroughput:
          ReadCapacityUnits: 1
          WriteCapacityUnits: 1
        StreamSpecification:
          StreamViewType: "NEW_AND_OLD_IMAGES"
        TableName: ${self:provider.environment.INTERVIEW_TABLE}

functions:
  interviewSubmission:
    handler: api/interview.submit
    memorySize: 128
    description: Submit interview information and starts interview process.
    events:
      - http: 
          path: interviews
          method: post

и интервью.js

'use strict';

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

AWS.config.setPromisesDependency(require('bluebird'));

const dynamoDb = new AWS.DynamoDB.DocumentClient();

module.exports.submit = (event, context, callback) => {
  const requestBody = JSON.parse(event);
  const fullname = requestBody.fullname;
  const email = requestBody.email;
  const test = requestBody.test;
  const experience = requestBody.experience;

  if (typeof fullname !== 'string' || typeof email !== 'string' || typeof experience !== 'number') {
    console.error('Validation Failed');
    callback(new Error('Couldn\'t submit interview because of validation errors.'));
    return;
  }

  submitInterviewP(interviewInfo(fullname, email, experience, test))
    .then(res => {
      callback(null, {
        statusCode: 200,
        body: JSON.stringify({
          message: `Sucessfully submitted interview with email ${email}`,
          interviewId: res.id
        })
      });
    })
    .catch(err => {
      console.log(err);
      callback(null, {
        statusCode: 500,
        body: JSON.stringify({
          message: `Unable to submit interview with email ${email}`
        })
      })
    });
};


const submitInterviewP = interview => {
  console.log('Submitting interview');
  const interviewInfo = {
    TableName: process.env.INTERVIEW_TABLE,
    Item: interview,
  };
  return dynamoDb.put(interviewInfo).promise()
    .then(res => interview);
};

const interviewInfo = (fullname, email, experience,test) => {
  const timestamp = new Date().getTime();
  return {
    id: uuid.v1(),
    fullname: fullname,
    email: email,
    experience: experience,
    test: test,
    submittedAt: timestamp,
    updatedAt: timestamp,
  };
};

Если я заменим параметр event для допустимого объекта JSONи затем разверните снова.Я могу успешно вставить объект в DynamoDB.

Есть какие-нибудь подсказки?Пожалуйста, дайте мне знать, если я что-то пропустил, что могло бы помочь.

Спасибо!

Answer 1

API-шлюз структурирует тело запроса в свойстве body события.

В настоящее время вы пытаетесь проанализировать объект события const requestBody = JSON.parse(event);, что неверно.Вам необходимо проанализировать свойство event.body:

const requestBody = JSON.parse(event.body);