Using streams to parse and transform CSV - NodeJS

csv-parser.js

const csv = require('csv');

const express = require('express');

const bodyParser = require('body-parser');

const app = express();

app.use(bodyParser.json());

app.get('/parse', (req, res) => {

  res.set('Content-Type', 'application/json'); // Set it if you are sending json

  csv
    .generate({seed: 1, columns: 2, length: 20}) // generates a random csv for testing, instead use your read stream for your purpose
    .pipe(csv.parse()) // parses data from the stream
    .pipe(csv.transform(function(record){
      return JSON.stringify({ // stringify is required to pass to the next pipe since it doesn't understand json
        col1: record[0],
        col2: record[1]
      });
    }))
    .pipe(res);

})

app.listen(8080)