在nodeJS中缓存流中的数据以执行大容量插入

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

// 创建可读流，从源中读取数据
const readableStream = fs.createReadStream('input.txt');

// 创建可写流，将数据写入缓存或其他目标
const writableStream = fs.createWriteStream('output.txt');

// 创建一个stream.Transform子类，用于将可读流中的数据转换为可写流中的数据
class TransformStream extends stream.Transform {
  constructor() {
    super();
    this.cache = '';
  }

  _transform(chunk, encoding, callback) {
    // 对数据进行处理和缓存
    const transformedData = chunk.toString().toUpperCase();
    this.cache += transformedData;

    callback();
  }

  _flush(callback) {
    // 将缓存的数据写入可写流
    this.push(this.cache);
    callback();
  }
}

// 创建一个TransformStream实例
const transformStream = new TransformStream();

// 将可读流和TransformStream连接起来
readableStream.pipe(transformStream);

// 将可写流连接到目标中，执行大容量插入操作
transformStream.pipe(writableStream);