nodejs中大文件的解压缩、转换和回压

const fs = require('fs');
const zlib = require('zlib');

const input = fs.createReadStream('input.gz');
const output = fs.createWriteStream('output.txt');

const unzip = zlib.createGunzip();
input.pipe(unzip).pipe(output);

const fs = require('fs');
const { Transform } = require('stream');

const input = fs.createReadStream('input.txt');
const output = fs.createWriteStream('output.txt');

const transformer = new Transform({
  transform(chunk, encoding, callback) {
    // 对每个数据块进行转换处理
    const transformedChunk = chunk.toString().toUpperCase();
    this.push(transformedChunk);
    callback();
  }
});

input.pipe(transformer).pipe(output);

const fs = require('fs');
const { Transform } = require('stream');

const input = fs.createReadStream('input.txt');
const output = fs.createWriteStream('output.txt');

const transformer = new Transform({
  transform(chunk, encoding, callback) {
    // 模拟处理延迟
    setTimeout(() => {
      const transformedChunk = chunk.toString().toUpperCase();
      this.push(transformedChunk);
      callback();
    }, 1000);
  }
});

input.pipe(transformer).pipe(output);