Если вы используете Event-Stream для чтения, вы можете использовать split()
метод process csv построчно.Затем измените и запишите строку в новый поток записи.
var fs = require('fs');
var es = require('event-stream');
const newCsv = fs.createWriteStream('new.csv');
fs.createReadStream('old.csv')
.pipe(es.split())
.pipe(
es.mapSync(function(line) {
// modify line way you want
newCsv.write(line);
}))
newCsv.end();