资讯专栏INFORMATION COLUMN

上云采购季！| 2核2G4M爆款云服务器低至59元/年，更有多台、长期优惠，快来选购！

立即前往
首页/文章专栏/【每日一包0021】csv2,through2

【每日一包0021】csv2,through2

AnthonyHan / 3525人阅读

摘要：地址采用流模式读取文件，每次读取一行数据对流的二次封装，更加易于使用普通用法等同于可以使号或者号参数每次流传完可以和一样做一些数据处理将文件中的全部替换为输出到完事写入完成对于需要相同处理过程的数据可以采用该方法创建一个构造函数完事

[github地址：https://github.com/ABCDdouyae...]

csv2 
</>复制代码 
  1. 采用流模式读取.csv文件，每次读取一行数据
through2 
</>复制代码 
  1. 对node流的二次封装，更加易于使用
普通用法 through2([ options, ] [ transformFunction ] [, flushFunction ])

options：{objectMode: true} 等同于through2.obj

transformFunction(chunk, encode, callback)

flushFunction 可以使2号或者3号参数 每次流传完可以和transformFunction一样做一些数据处理

</>复制代码 
  1. //将文件中的a全部替换为z输出到out.txt
  2. const through2 = require("through2");
  3. const fs = require("fs");
  4. fs.createReadStream("./test/enter.txt")
  5.   .pipe(through2(function (chunk, enc, callback) {
  6.     for (var i = 0; i < chunk.length; i++)
  7.       if (chunk[i] == 97)
  8.         chunk[i] = 122 // swap "a" for "z"
  9.  
  10.     this.push(chunk)
  11.  
  12.     callback()
  13.    }))
  14.   .pipe(fs.createWriteStream("./test/out.txt"))
  15.   .on("finish", () => {
  16.       console.log("完事")
  17.   })
through2.obj
</>复制代码 
  1. const through2 = require("through2");
  2. const csv2 = require("csv2");
  3. const fs = require("fs");
  4. let all = [];
  5. fs.createReadStream("./test/enter.csv")
  6.   .pipe(csv2())
  7.   .pipe(through2.obj(function (chunk, enc, callback) {
  8.     this.push({
  9.         No : chunk[0], 
  10.         activity : chunk[1], 
  11.         time : chunk[2],
  12.         money: chunk[3]
  13.     })
  14.     callback()
  15.   }))
  16.   .on("data", (data)=>{
  17.       all.push(data)
  18.   })
  19.   .on("end", ()=>{
  20.       fs.writeFile("./test/a.js", JSON.stringify(all), ()=>{
  21.         console.log("写入完成")
  22.       })
  23.   })
through2.ctor对于需要相同处理过程的数据可以采用该方法创建一个构造函数
</>复制代码 
  1. let Fc = through2.ctor(function(chunk, enc, callback){
  2.    console.log(chunk)
  3.     for(var i=0;i {
  4.       console.log("完事")
  5.   })
云服务器 GPU云服务器 每日vps 每日经济新闻 每日一练 每日区块链

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/99750.html

相关文章

  • 【每日一包0021】csv2,through2

    摘要：地址采用流模式读取文件，每次读取一行数据对流的二次封装，更加易于使用普通用法等同于可以使号或者号参数每次流传完可以和一样做一些数据处理将文件中的全部替换为输出到完事写入完成对于需要相同处理过程的数据可以采用该方法创建一个构造函数完事 [github地址：https://github.com/ABCDdouyae...] csv2 采用流模式读取.csv文件，每次读取一行数据 throu...

    XBaron 评论0 收藏0

  • 【每日一包0021】csv2,through2

    摘要：地址采用流模式读取文件，每次读取一行数据对流的二次封装，更加易于使用普通用法等同于可以使号或者号参数每次流传完可以和一样做一些数据处理将文件中的全部替换为输出到完事写入完成对于需要相同处理过程的数据可以采用该方法创建一个构造函数完事 [github地址：https://github.com/ABCDdouyae...] csv2 采用流模式读取.csv文件，每次读取一行数据 throu...

    pkhope 评论0 收藏0

  • 【每日一包0022】through2-map,through2-filter,stream-spig

    摘要：地址对于包的参数封装为函数形式输出的为字符串形式而不是默认为， [github地址：https://github.com/ABCDdouyae...] through2-map 对于through2包的transformFunction参数封装为map函数形式 {wantStrings: true}输出的chunk为字符串形式而不是buffer 默认objectModal为true ...

    honmaple 评论0 收藏0

  • 【每日一包0022】through2-map,through2-filter,stream-spig

    摘要：地址对于包的参数封装为函数形式输出的为字符串形式而不是默认为， [github地址：https://github.com/ABCDdouyae...] through2-map 对于through2包的transformFunction参数封装为map函数形式 {wantStrings: true}输出的chunk为字符串形式而不是buffer 默认objectModal为true ...

    iKcamp 评论0 收藏0

发表评论

登陆后可评论

0条评论

AnthonyHan

男|高级讲师
我要私信

TA的文章

阅读更多
最新活动
阅读需要支付1元查看
<