sink.v1.js

/*
 * Just consume events from Kinesis in a sink 
 */

const pause = parseInt(process.env.PAUSE_TIME || '0');
//const pause = 0;

const sleep = (ms) => {
    return new Promise(resolve => setTimeout(resolve, ms));
};

export const handler = async (event, context, callback) => {
    let now = Date.now();
    console.log(`sinking ${event.Records.length} records`);
    // do some busy processing with your records and then...
    if (pause > 0) {
        // make sure that we are not returning before pause time
        let elapsed = Date.now() - now;
        console.log(`sleeping ${pause * 1000 - elapsed} ms`);
        await sleep(pause * 1000 - elapsed);
    } 
    
    callback(null, 'Done');
};