in app/nodejs/process.js [135:157]
function writeProcessedData(aggregate) {
logger.info('writeProcessedData: start writing');
let counter = 0;
const processedBucket = storage.bucket(process.env.PROCESSED_DATA_BUCKET);
const writeData = new Promise((resolve) => {
Object.keys(aggregate).forEach(async function(rowKey) {
const facetData = aggregate[rowKey];
processedBucket
.file(`${rowKey}/data.json`)
.save(JSON.stringify(facetData));
counter += 1;
});
resolve(counter);
});
writeData.then(function(counter) {
logger.info(`writeProcessedData: wrote ${counter} files`);
});
}