示例

回调

执行脚本命令 node samples/callback.js

var csv = require('csv');

csv.generate({seed: 1, columns: 2, length: 20}, function(err, data){
  csv.parse(data, function(err, data){
    csv.transform(data, function(data){
      return data.map(function(value){return value.toUpperCase()});
    }, function(err, data){
      csv.stringify(data, function(err, data){
        process.stdout.write(data);
      });
    });
  });
});

流

执行脚本命令 node samples/stream.js

var csv = require('csv');

var generator = csv.generate({seed: 1, columns: 2, length: 20});
var parser = csv.parse();
var transformer = csv.transform(function(data){
  return data.map(function(value){return value.toUpperCase()});
});
var stringifier = csv.stringify();

generator.on('readable', function(){
  while(data = generator.read()){
    parser.write(data);
  }
});

parser.on('readable', function(){
  while(data = parser.read()){
    transformer.write(data);
  }
});

transformer.on('readable', function(){
  while(data = transformer.read()){
    stringifier.write(data);
  }
});

stringifier.on('readable', function(){
  while(data = stringifier.read()){
    process.stdout.write(data);
  }
});

管道

执行脚本命令 node samples/pipe.js

var csv = require('csv');

csv.generate({seed: 1, columns: 2, length: 20})
   .pipe(csv.parse())
   .pipe(csv.transform (function(record){
        return record.map(function(value){
            return value.toUpperCase()
        });
      }))
   .pipe(csv.stringify ())
   .pipe(process.stdout)
;

真实用例

上传

解析

处理

输出