createReadStream 的同步

Question

我对 Javascript 非常陌生。我要做的就是从本地读取一个 CSV 文件并使用数据进行处理，例如将行转换为数组的数组。我遇到了fs.createReadStream，它有助于读取 csv 数据，但我以后无法使用处理过的 csv 数据。我读了一些帖子，我猜是同步的问题。 我的代码看起来像这样-

ar abc = [] 
const csv = require('csv-parser');
const fs = require('fs');

fs.createReadStream('data.csv')
  .pipe(csv())
  .on('data', (row) => {
    var nums =[];

   // console.log(row);
    nums.push(row['time'])
    nums.push(row['return'])
    
    abc.push(nums)
    
  })
  .on('end', function () {
    console.log(abc)
      })
  

  var final_sort= []
  console.log()
  for (let i = 0; i < abc.length; i=i+5){

    final_sort.push(abc[i])


  } 
  console.log(final_sort)

这首先在 fs 之外输出日志，然后输出 fs.createReadStream。我想要fs。先处理 createReadStream ，然后我可以进一步利用数据。

Answer 1

如果你想处理你的序列，那么你必须尝试承诺

如果您的任务是读取所有数据然后排序，那么您的代码将是这样的

var abc = []
const csv = require('csv-parser');
const fs = require('fs');
// -----------1 process start
await new Promise((resolve, reject) => {
  fs.createReadStream('data.csv')
    .pipe(csv())
    .on('data', (row) => {
      var nums = [];

      // console.log(row);
      nums.push(row['time'])
      nums.push(row['return'])

      abc.push(nums)

    })
    .on('end', function () {
      console.log(abc)
      //---------- 2 return after all data read
      resolve()
    })
});
//---------- 3 here you get all data
var final_sort = []
console.log()
for (let i = 0; i < abc.length; i = i + 5) {

  final_sort.push(abc[i])


}
console.log(final_sort)

供参考 understanding-javascript-promises