next csv params

This commit is contained in:
Jan Prochazka
2020-11-19 11:36:34 +01:00
parent 0cd3e393e8
commit 7ccb1d9c90
5 changed files with 21 additions and 6 deletions

View File

@@ -37,12 +37,11 @@ class CsvPrepareStream extends stream.Transform {
}
}
async function csvReader({ fileName, encoding = 'utf-8', header = true, delimiter, quoted, limitRows = undefined }) {
async function csvReader({ fileName, encoding = 'utf-8', header = true, delimiter, limitRows = undefined }) {
console.log(`Reading file ${fileName}`);
const csvStream = csv.parse({
// @ts-ignore
delimiter,
quoted,
skip_lines_with_error: true,
to_line: limitRows ? limitRows + 1 : -1,
});