AWS Kinesis Firehose 通过使用默认编号编码器将记录的数据编码为二进制格式,如果需要阅读这些数据,则需要解码它们。一种解决方法是在 Firehose 中启用转换功能,使记录经过转换器(如 Lambda 函数)进行转换和格式化,以便可以读取。另一种方法是在消费者端(如 Amazon S3)上使用相应的解码程序来解密数据。以下是示例代码,演示如何使用 AWS Lambda 将记录转换为可读格式:
exports.handler = function(event, context) {
var i;
var payload = "";
for (i = 0; i < event.records.length; i++) {
var record = new Buffer(event.records[i].data, 'base64').toString();
// Do some data conversion or formatting here
payload += record;
payload += '\n';
}
context.succeed({records: [{data: new Buffer(payload).toString('base64')}]});
};