function enrichPayload()

in cdk/lambda/add-approximate-arrival-time.js [18:25]


function enrichPayload(record) {
    const payload = JSON.parse(Buffer.from(record.data, 'base64').toString('utf8'));
    const timestamp = new Date(record.kinesisRecordMetadata.approximateArrivalTimestamp).toISOString();
    
    const enrichedPayload = Object.assign({approximate_arrival_timestamp: timestamp}, payload);

    return Buffer.from(JSON.stringify(enrichedPayload)+"\n").toString('base64');
}