Форматирование данных DynamoDB в нормальный JSON в AWS Lambda

Question

Я использую AWS Lambda для сканирования данных из таблицы DynamoDB. Это то, что я получаю в ответ:

{ 
    "videos": [ 
    { 
     "file": { 
     "S": "file1.mp4" 
     }, 
     "id": { 
     "S": "1" 
     }, 
     "canvas": { 
     "S": "This is Canvas1" 
     } 
    }, 
    { 
     "file": { 
     "S": "main.mp4" 
     }, 
     "id": { 
     "S": "0" 
     }, 
     "canvas": { 
     "S": "this is a canvas" 
     } 
    } 
    ] 
} 

Мой передний конец приложение использует Ember данных Rest адаптер, который не принимает такой ответ. Есть ли способ получить нормальный формат JSON? Этот модуль NPM называется dynamodb-marshaler для преобразования данных DynamoDB в обычный JSON. Я ищу родное решение если возможно.

Answer 1

AWS JavaScript SDK был недавно обновлен с клиентом документа, который делает именно что вам нужно. Проверьте анонс и примеры использования здесь: http://blogs.aws.amazon.com/javascript/post/Tx1OVH5LUZAFC6T/Announcing-the-Amazon-DynamoDB-Document-Client-in-the-AWS-SDK-for-JavaScript

Answer 2

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

var response = {...} // your response from DynamoDB 
var formattedObjects = response.videos.map(function(video) { 
    return { 
     "file": video.file.S, 
     "id": video.id.S, 
     "canvas": video.canvas.S 
    }; 
}); 

Если вы хотите, чтобы построить общую систему для этого, вы должны обращаться с DynamoDB-х различных AttributeValue types. Функция как один ниже будет делать эту работу, но я ушел из тяжелой работы обработки большинства более сложных типов значений атрибутов DynamoDB в:

function dynamoItemToPlainObj(dynamoItem) { 
    var plainObj = {}; 
    for (var attributeName in dynamoItem) { 
     var attribute = dynamoItem[attributeName]; 
     var attributeValue; 
     for (var itemType in attribute) { 
      switch (itemType) { 
      case "S": 
       attributeValue = attribute.S.toString(); 
       break; 
      case "N": 
       attributeValue = Number(attribute.N); 
       break; 
       // more attribute types... 
      default: 
       attributeValue = attribute[itemType].toString(); 
       break; 
      } 
     } 
     plainObj[attributeName] = attributeValue; 
    } 
    return plainObj; 
}  
var formattedObjects = response.videos.map(dynamoItemToPlainObj); 

Answer 3

Здесь вы можете найти суть, которая делает это:

function mapper(data) { 

let S = "S"; 
let SS = "SS"; 
let NN = "NN"; 
let NS = "NS"; 
let BS = "BS"; 
let BB = "BB"; 
let N = "N"; 
let BOOL = "BOOL"; 
let NULL = "NULL"; 
let M = "M"; 
let L = "L"; 

if (isObject(data)) { 
    let keys = Object.keys(data); 
    while (keys.length) { 
     let key = keys.shift(); 
     let types = data[key]; 

     if (isObject(types) && types.hasOwnProperty(S)) { 
      data[key] = types[S]; 
     } else if (isObject(types) && types.hasOwnProperty(N)) { 
      data[key] = parseFloat(types[N]); 
     } else if (isObject(types) && types.hasOwnProperty(BOOL)) { 
      data[key] = types[BOOL]; 
     } else if (isObject(types) && types.hasOwnProperty(NULL)) { 
      data[key] = null; 
     } else if (isObject(types) && types.hasOwnProperty(M)) { 
      data[key] = mapper(types[M]); 
     } else if (isObject(types) && types.hasOwnProperty(L)) { 
      data[key] = mapper(types[L]); 
     } else if (isObject(types) && types.hasOwnProperty(SS)) { 
      data[key] = types[SS]; 
     } else if (isObject(types) && types.hasOwnProperty(NN)) { 
      data[key] = types[NN]; 
     } else if (isObject(types) && types.hasOwnProperty(BB)) { 
      data[key] = types[BB]; 
     } else if (isObject(types) && types.hasOwnProperty(NS)) { 
      data[key] = types[NS]; 
     } else if (isObject(types) && types.hasOwnProperty(BS)) { 
      data[key] = types[BS]; 
     } 
    } 
} 


return data; 

function isObject(value) { 
    return typeof value === "object" && value !== null; 
} 

}

https://gist.github.com/igorzg/c80c0de4ad5c4028cb26cfec415cc600

Answer 4

Я знаю, это немного старый, но у меня было то же самое обрабатывать данные потока обработки из dynamoDB в функции js лямбда узла js. Я использовал предложенный @churro

импорта и SDK выходного преобразователь

var AWS = require("aws-sdk"); 
var parse = AWS.DynamoDB.Converter.output; 

использовать функцию синтаксического анализа с небольшим хаком

exports.handler = function(event, context, callback) { 
    var docClient = new AWS.DynamoDB.DocumentClient(); 
    event.Records.forEach((record) => { 
     console.log(record.eventID); 
     console.log(record.eventName); 
     console.log('DynamoDB Record:', parse({ "M": record.dynamodb.NewImage })); 
    }); 
    callback(null, `Successfully processed ${event.Records.length} records.`); 
} 

Надеется, что это помогает

Answer 5

Если вам нужно редактора попробуйте это

https://2json.net/dynamo

Answer 6

На самом деле вы должны использовать функцию unmarshall из AWSJavaScriptSDK:

const AWS = require("aws-sdk"); 

exports.handler = function(event, context, callback) { 
    const newImages = event.Records.map(
     (record) => AWS.DynamoDB.Converter.unmarshall(record.dynamodb.NewImage) 
); 
    console.log('Converted records', newImages); 
    callback(null, `Success`); 
}