Node.js:按定义的顺序返回承诺

Question

我需要按定义的顺序处理数百个 JSON 文件，并以与 JSON 文件中相同的顺序将内容写回 CSV：

1. 编写带有标头的 CSV 文件
2. 收集要处理的 JSON 文件数组
3. 读取文件并返回包含所需信息的数组
4. 在 #1 下创建的 CSV 文件附加信息
5. 继续执行步骤 #3 中的下一个 JSON 文件

'use strict';
const glob = require('glob');
const fs = require('fs');
const fastcsv = require('fast-csv');
const readFile = require('util').promisify(fs.readFile);
function writeHeader(fileName) {
return new Promise((resolve, reject) => {
fastcsv
.writeToStream(fs.createWriteStream(fileName), [['id', 'aa', 'bb']], {headers: true})
.on('error', (err) => reject(err))
.on('finish', () => resolve(true));
});
}
function buildFileList(globPattern) {
return new Promise((resolve, reject) => {
glob(globPattern, (err, files) => {
if (err) {
reject(err);
} else {
resolve(files);
}
});
});
}
function readFromFile(file) {
return new Promise((resolve, reject) => {
readFile(file, 'utf8', (err, data) => {
if (err) {
reject(err);
} else {
const obj = JSON.parse(data);
const key = Object.keys(obj['776'])[0];
const solarValues = [];
obj['776'][key].map((item, i) => solarValues.push([i, item[0], item[1][0][0]]));
resolve(solarValues);
}
});
});
}
function csvAppend(fileName, rows = []) {
return new Promise((resolve, reject) => {
const csvFile = fs.createWriteStream(fileName, {flags: 'a'});
csvFile.write('n');
fastcsv
.writeToStream(csvFile, rows, {headers: false})
.on('error', (err) => reject(err))
.on('finish', () => resolve(true));
});
}
writeHeader('test.csv')
.then(() => buildFileList('data/*.json'))
.then(fileList => Promise.all(fileList.map(item => readFromFile(item))))
.then(result => Promise.all(result.map(item => csvAppend('test.csv', item))))
.catch(err => console.log(err.message));

JSON示例：

https://gist.github.com/Sineos/a40718c13ad0834b4a0056091e3ac4ca

https://gist.github.com/Sineos/d626c3087074c23a073379ecef84a55c

问题

虽然代码基本上有效，但我的问题是 CSV 不是按照定义的顺序写回来的，而是像异步过程一样混合在一起。

我尝试了各种组合，有和没有Promise.all导致挂起的承诺或混淆的CSV文件。

这是我对 Node.js Promise 的第一次尝试，因此非常感谢有关如何正确执行此操作的每个输入。提前非常感谢。

Answer 1

这段代码应该按顺序处理你的文件，我们将使用 async/await 和 for .. 的顺序循环：

async function processJsonFiles() {
try {
await writeHeader('test.csv');
let fileList = await buildFileList('data/*.json');
for(let file of fileList) {
let rows = await readFromFile(file);
await csvAppend('test.csv', rows);
}
} catch (err) {
console.error(err.message);
}
}
processJsonFiles();