Как читать данные из Kinesis Analytics с помощью функции лямбда в узле JS? - PullRequest
Новая
       44

Как читать данные из Kinesis Analytics с помощью функции лямбда в узле JS?

0 голосов
/ 24 октября 2019

Я пытаюсь прочитать данные из 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 };
};

Я также попробовал код в следующей ссылке нажмите здесь

...