1

我正在使用fast-csvnpm 包来解析传入的 csv 文件并捕获事件data并显示row是绝对可以的。我在这里得到了我想要的。

我做了什么:

fs.createReadStream(req.file.path)
  .pipe(csv.parse({ ignoreEmpty: true, trim: true }))
  .on("error", (error) => console.error(error))
  .on("data", (row) => console.log(row))
  .on("end", (rowCount) => console.log(rowCount));

我在data活动中得到了什么:

['Data Entry Form']
['no','name','email','phone','address']
['1','John','john@gmail.com','09111111111','abc']
['2','Mary','mary@gmail.com','09111111111','abc']

我需要的:

let data = [];

  fs.createReadStream(req.file.path)
    .pipe(csv.parse({ ignoreEmpty: true, trim: true }))
    .on("error", (error) => console.error(error))
    .on("data", (row) => data.push(_.compact(row)))
    .on("end", (rowCount) => console.log(rowCount));

  return res.status(201).send({
    status: "success",
    data,
  });

不好:

data是空的,我没有错误。

有什么建议么?谢谢。

4

1 回答 1

2

您应该仅在读取流结束时响应,如下所示:

let data = [];

fs.createReadStream(req.file.path)
    .pipe(csv.parse({ ignoreEmpty: true, trim: true }))
    .on("error", (error) => console.error(error))
    .on("data", (row) => data.push(_.compact(row)))
    .on("end", (rowCount) => {
        console.log(rowCount);
        res.status(201).send({
            status: "success",
            data,
        });
    });
于 2020-07-30T16:50:00.457 回答