nodejs求问
下面代码段中调用了一个promise类型的接口。我现在要对一个数组里的所有数据执行这个接口,异步执行内存就爆了,有什么解决办法吗?或者说如何让这个接口同步执行?
var store = require('app-store-scraper');
const fs = require('fs')
const fast_csv = require('fast-csv')
let input = fs.readFileSync("1.txt").toString().split('\n')
var ws = fs.createWriteStream('./test.csv')
const csvStream = fast_csv.format({ headers: ['appid', 'privacy']});
csvStream.pipe(ws).on('end', () => process.exit());
console.log('pipe ready')
input.forEach((id)=>{
store.privacy({
id:Number(id),
})
.then((res)=>{
var out = JSON.stringify(res,null,"\t");
csvStream.write([id,out]);
})
.catch((id)=>console.log(id+' failed'));
})
// csvStream.end();
var store = require('app-store-scraper');
const fs = require('fs')
const fast_csv = require('fast-csv')
let input = fs.readFileSync("1.txt").toString().split('\n')
var ws = fs.createWriteStream('./test.csv')
const csvStream = fast_csv.format({headers: ['appid', 'privacy']});
csvStream.pipe(ws).on('end', () => process.exit());
console.log('pipe ready')
async function execAllPrivacy() {
for (let i = 0; i < input.length; i++) {
const id = input[i];
await store.privacy({
id: Number(id),
}).then((res) => {
var out = JSON.stringify(res, null, "\t");
csvStream.write([id, out]);
}).catch((id) => console.log(id + ' failed'));
}
}
execAllPrivacy();
// csvStream.end();
用for循环才行
这是同步
input.forEach(async (id)=>{
const res = await store.privacy({id:Number(id)})
const out = JSON.stringify(res,null,"\t");
csvStream.write([id,out]);
})