Node.js csv 包：实现条件性 CSV 记录过滤与删除的专业指南

npm install csv

const fs = require('fs');
const { parse } = require('csv'); // 导入 parse 函数

const csvFilePath = 'your_data.csv'; // 替换为你的 CSV 文件路径

// 假设 your_data.csv 内容如下：
// header1,header2,header3
// value1,value2,value3
// valueA,,valueC
// valueX,valueY,

// 读取 CSV 文件
const csvData = fs.readFileSync(csvFilePath, "utf-8");

// 解析 CSV 数据
const parsedData = parse(csvData, {
   delimiter: ",",
   skip_empty_lines: true,          // 跳过空行
   skip_records_with_error: true,   // 跳过有错误的记录
   cast: function (val, ctx) {
      if (ctx.header) {
         return val; // 保持标题不变
      }

      // 如果值为空字符串，则将其转换为 undefined
      if (!val.length) {
         return undefined;
      }

      // 根据字段索引进行类型转换（示例）
      switch (ctx.index) {
         case 0:
            return new Date(val); // 假设第一个字段是日期
         default:
            return Number(val).toFixed(2); // 其他字段转换为保留两位小数的数字
      }
   },
   columns: true, // 将每行解析为对象，以标题作为键
   trim: true,    // 移除字段值的首尾空白
});

   cast: function (val, ctx) {
      if (ctx.header) {
         return val;
      }

      if (!val.length) { // 如果原始字段值是空字符串
         return undefined; // 将其转换为 undefined
      }
      // ... 其他类型转换逻辑
   },

// 过滤掉包含 undefined 值的记录
const filteredData = parsedData.filter(record => {
  // 检查记录中所有值，确保没有 undefined
  return Object.values(record).every(value => value !== undefined);
});

// filteredData 现在只包含所有字段都非 undefined 的记录
// 你可以将 filteredData 存储到你的目标对象变量中
const finalObject = filteredData;

console.log(finalObject);

const fs = require('fs');
const { parse } = require('csv');

const csvFilePath = 'your_data.csv'; // 替换为你的 CSV 文件路径

// 示例 CSV 文件内容 (保存为 your_data.csv)
// header1,header2,header3
// 2023-01-01,100.50,abc
// 2023-01-02,200.75,def
// 2023-01-03,,ghi     // 第二个字段为空
// 2023-01-04,300.25,
// 2023-01-05,400.00,jkl

try {
    // 读取 CSV 文件同步
    const csvData = fs.readFileSync(csvFilePath, "utf-8");

    // 解析 CSV 数据同步
    const parsedData = parse(csvData, {
        delimiter: ",",
        skip_empty_lines: true,
        skip_records_with_error: true,
        cast: function (val, ctx) {
            if (ctx.header) {
                return val;
            }

            // 将空字符串转换为 undefined
            if (!val.length) {
                return undefined;
            }

            // 根据字段索引进行类型转换
            switch (ctx.index) {
                case 0:
                    return new Date(val); // 假设第一个字段是日期
                default:
                    // 尝试转换为数字，如果不是有效数字，则保留原始值或返回其他默认值
                    const numVal = Number(val);
                    return isNaN(numVal) ? val : numVal.toFixed(2);
            }
        },
        columns: true, // 将每行解析为对象
        trim: true,    // 移除字段值的首尾空白
    });

    console.log("原始解析数据：", parsedData);

    // 过滤掉任何字段值为 undefined 的记录
    const filteredData = parsedData.filter(record => {
        return Object.values(record).every(value => value !== undefined);
    });

    // 存储过滤后的数据
    const finalObject = filteredData;

    console.log("\n过滤后的数据：", finalObject);

} catch (error) {
    console.error("处理 CSV 文件时发生错误:", error);
}