John-Paul Jorissen
06/05/2019, 1:52 PMreduce
in this stage?
function summarize(context){
const vendors = {}
let totalItemsProcessed = 0
context.output.iterator().each(function(key, row) {
// only manages to log the very last item written to the context
log.debug({
title: 'vendor summary',
details: key
})
// map-reduce scripts always serialize objects to JSON in the context
vendors[key] = JSON.parse(row)
totalItemsProcessed++
})
const searchDate = new Date();
const body = JSON.stringify({
entity: "vendor",
recently_created: vendors,
search_date: searchDate
})
middlewareRequest(body, "scheduled/Vendor")
const summaryMessage = "Usage: " + context.usage + " Concurrency: " + context.concurrency +
" Number of yields: " + context.yields + " Total Items Processed: " + totalItemsProcessed;
log.audit({
title: 'Summary of usage',
details: summaryMessage
});
}