Я пытаюсь прочитать данные из kinesis analytics с помощью функции Lambda в узле JS, я получаю данные в закодированном формате, когда пытаюсь их декодировать, я не получаю никакого вывода.
console.log('Loading function');
const zlib = require('zlib');
exports.handler = async (event, context) => {
let success = 0;
let failure = 0;
const output = event.records.map((record) => {
// let compressedData = zlib.deflate(record['data'])
try {
// console.log(compressedData.toString('ascii'))
console.log('saran100000')
var compressedData = zlib.deflate(record['data'])
console.log('saran')
console.log(record.data)
console.log(compressedData)
var compAndToString =zlib.deflate(record['data']).toString('utf8')
console.log('saran1')
console.log(compAndToString)
var compAndUncomp = zlib.inflate(zlib.deflate(record['data']))
console.log('saran2')
console.log(compAndUncomp)
var convertBackToString = zlib.inflate(zlib.deflate(record['data'])).toString('utf8')
console.log('saran3')
console.log(convertBackToString)
success++;
return {
recordId: record.recordId,
// data:result,
result: 'Ok'
};
} catch (err) {
console.log(err)
failure++;
return {
recordId: record.recordId,
result: 'DeliveryFailed',
};
}
});
console.log(`Successful delivered records ${success}, Failed delivered records ${failure}.`);
return { records: output };
};
Я также попробовал код в следующей ссылке нажмите здесь