我本以为我得到了数组中的所有CSV数据，但由于某种原因，我什么都没有得到.
有人能解释为什么a最后是空的吗？
const fs = require('fs');
const { parse } = require('csv-parse');
let a = [];
fs.createReadStream('./example.csv')
.pipe(parse({ delimiter: ';', from_line: 2 }))
.on('data', function (row) {
a.push(row);
})
.on('end', function () {
console.log('finished');
})
.on('error', function (error) {
console.log(error.message);
});
console.log(a);
您的a是undefined，因为代码是异步执行的.执行console.log(a)后调用on()函数.
您可以在data事件或end事件中读取a的值:
fs.createReadStream('./example.csv')
.pipe(parse({ delimiter: ';', from_line: 2 }))
.on('data', function (row) {
a.push(row);
console.log(a) // <------- here
})
.on('end', function () {
console.log('finished');
console.log(a) // <------- here
})
.on('error', function (error) {
console.log(error.message);
});
一种解决方案可能是使用Promise
const readCSVData = async () => new Promise((resolve, reject) => {
let a = []
fs.createReadStream('./example.csv')
.pipe(parse({ delimiter: ';', from_line: 2 }))
.on('data', function (row) {
a.push(row);
})
.on('end', function () {
// return the a value
resolve(a)
})
.on('error', function (error) {
reject(error)
});
})
// .....
const foo = async () => {
const data = await readCSVData()
console.log(data)
}
// or
readCSVData().then(a => console.log(a))