我设置了以下 lambda 函数,并使用 kinesis 作为其事件源。数据以流的形式通过,这里我将其解析为字符串,例如{id=2, sourceIp=220.220.1.220 }
。我想将其转换为node.js 中的对象。我怎样才能做到这一点?
exports.handler = (event, context) => {
event.Records.forEach(function(record) {
var data = new Buffer(record.kinesis.data, 'base64').toString('ascii');
console.log('data: ', data)
});
};
最佳答案
我想你想做的是这样的:
var data = JSON.parse(new Buffer(record.kinesis.data, 'base64'));
关于javascript - 在 lambda 中使用 node.js 如何解析来自 kinesis 流的数据,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/37825431/