javascript - 在使用 node.js 的 lambda 中，我如何解析运动流中的数据

Question

我将以下 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)
    });
};

Answer 1

我认为你想要做的是:

var data = JSON.parse(new Buffer(record.kinesis.data, 'base64'));