33 lines
1.1 KiB
JavaScript
33 lines
1.1 KiB
JavaScript
console.log('Loading function');
|
|
|
|
const validateRecord = (recordElement)=>{
|
|
// record is considered valid if contains status field
|
|
return recordElement.includes("status")
|
|
}
|
|
|
|
exports.handler = async (event, context) => {
|
|
/* Process the list of records and transform them */
|
|
const output = event.records.map((record)=>{
|
|
const decodedData = Buffer.from(record.data, "base64").toString("utf-8")
|
|
let isValidRecord = validateRecord(decodedData)
|
|
|
|
if(isValidRecord){
|
|
let parsedRecord = JSON.parse(decodedData)
|
|
// read fields from parsed JSON for some more processing
|
|
const outputRecord = `status::${parsedRecord.status}`
|
|
return {
|
|
recordId: record.recordId,
|
|
result: 'Ok',
|
|
// payload is encoded back to base64 before returning the result
|
|
data: Buffer.from(outputRecord, "utf-8").toString("base64")
|
|
}
|
|
|
|
}else{
|
|
return {
|
|
recordId: record.recordId,
|
|
result: 'dropped',
|
|
data: record.data // payload is kept intact,
|
|
}
|
|
}
|
|
})
|
|
}; |