DataAnalysis-Tmp/config/csvReader.js

const csv = require('csv-parser')
const fs = require('fs')

class CsvReader {
  static readFile(filename, handler) {
    let res = [];
    return new Promise((resolve, reject) => {
      fs.createReadStream(filename)
        .pipe(csv())
        .on('data', (data) => res.push(handler(data)))
        .on('end', () => {
          resolve(res)
        }).on('error', (err)=> {
          reject(err);
        });
    });
  }
}
module.exports = CsvReader;