问快速-CSV流转换异步

EN

    var db = mongojs("mongodb://127.0.0.1:27017/", ['collection']);
    fs.createReadStream(path)
    .pipe(csv.parse({headers: false}))
    //pipe the parsed input into a csv formatter
    .pipe(csv.format({headers: true}))
    //Using the transform function from the formatting stream
    .transform(function(row, next){
            console.log(row);
            db.collection.find({email: row[0].toString()}, function (err, docs) {
                console.log(docs[0]);
                console.log(err);
                if (!err && docs.length > 0) {
                    next(void 0, {
                        email: docs[0].email,
                        name: docs[0].name
                    });
                } else {
                    next(err)
                }
            });
    })
    .pipe(fs.createWriteStream("tmp/list.csv"))
    .on("finish", function() {upload();});