Как использовать nodejs для обработки резюме

У меня есть для этого идеальное решение. Я пишу для вас примерный алгоритм.

Steps

1. Разделите данные csv с помощью '\ n' -> Преобразовать в массив
2. Каждый элемент в массиве назначается csvLineObj.
3. Теперь вы можете получить доступ к каждой строке по-разному.

var aTempArray=[];

for(will run from 0 to length of CSV){  

  var trArr= csvLineObj.split(","); 
  // Will return an array
  
  if (trArr[1]===trArr[2]){ aTempArray.psuh(csvLineObj); 
  // You have the array of results in aTempArray
  
}

aTempArray.concat("\n"); ---> You have the desired result

Я бы предложил использовать отличную библиотеку csv-parse, я бы никогда не рекомендовал использовать собственное решение для синтаксического анализа csv.

В этом примере мы анализируем и суммируем по мере продвижения.

Последняя запись требует особой обработки, как показано!

testfile.csv

amount,open,close
100,2017-08-28 13:18:46,2017-08-30 11:18:01
200,2017-08-28 13:18:46,2017-08-30 11:18:01
300,2017-08-28 13:18:46,2017-08-30 11:18:01
100,2017-08-30 03:32:24,2017-08-30 11:18:01
200,2017-08-30 03:32:24,2017-08-30 11:18:01
100,2017-08-28 13:19:24,2017-08-30 11:18:01
100,2017-08-30 03:32:24,2017-08-30 11:18:01

example.js

const parse = require('csv-parse');
const transform = require('stream-transform');
const fs = require('fs');

let input = fs.createReadStream('testfile.csv');
let outputStream = fs.createWriteStream('outfile.csv');

function sumRecords(cache) {
    let first = cache[0];
    return cache.reduce((acc,rec) => {
       acc[0] += Number(rec[0]);
       return acc;
    }, [0, first[1], first[2]]);
}

// Cache of same records.
records = [];
var parser = parse({delimiter: ','})
var transformer = transform((record, callback) => {

    // Skip header.. 
    if (record[0] == 'amount') {
        callback(null, record.join(',') + '\n');
        return;
    }

    if (records.length != 0) {
        let firstRecord = records[0];
        if (firstRecord[1] != record[1] || firstRecord[2] != record[2]) {
            // Sum up records.
            let outputRecord = sumRecords(records);
            callback(null, outputRecord.join(',') + '\n');
            records = []; // Clear our cache.
        }
    }
    records.push(record);
});

input.pipe(parser).pipe(transformer).pipe(outputStream);

// Write any remaining records to file.
setTimeout(() => {
    fs.appendFile('outfile.csv', sumRecords(records).join(','), () => {});
}, 1000);

Мы получаем результат, который выглядит так:

Outfile.csv

amount,open,close
600,2017-08-28 13:18:46,2017-08-30 11:18:01
300,2017-08-30 03:32:24,2017-08-30 11:18:01
100,2017-08-28 13:19:24,2017-08-30 11:18:01
100,2017-08-30 03:32:24,2017-08-30 11:18:01