[Node] 스트림(Stream) 예시

 

fs.createWriteStream(path[, options]);

 

const fs = require('fs');

// 파일 생성 혹은 기존 파일 덮어쓰기
const writeStream = fs.createWriteStream('example.txt');

// 파일에 데이터 쓰기
writeStream.write('Hello World\n');

// 파일 쓰기 종료
writeStream.end();

// 파일 쓰기가 완료되면 콘솔에 로그 출력
writeStream.on('finish', () => {
  console.log('Data written to file');
});

// 에러 발생 시 콘솔에 로그 출력
writeStream.on('error', (err) => {
  console.error(err);
});

 

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


// 파일명 설정
const writeStream = fs.createWriteStream(`example.txt`, { flags: "a" });

// 파일에 데이터 쓰기
writeStream.write('Hello World\n');
writeStream.write('Hello World\n');

// 파일 쓰기 종료
writeStream.end();

// 파일 쓰기가 완료되면 콘솔에 로그 출력
writeStream.on('finish', () => {
  console.log('Data written to file');
});

// 에러 발생 시 콘솔에 로그 출력
writeStream.on('error', (err) => {
  console.error(err);
});

  
// Creating readable Stream
const inp = fs.createReadStream('example.txt');
  
// Creating writable stream
const out = fs.createWriteStream('example.txt.gz');
  
// Calling createGzip method
const gzip = zlib.createGzip();
  
// Piping
inp.pipe(gzip).pipe(out);
console.log("Gzip created!");

 

https://nodejs.org/api/stream.html#stream

Stream | Node.js v19.8.1 Documentation

 

 

[Node] 스트림(Stream)

 

Node.js zlib.createGzip() Method - GeeksforGeeks

https://psyhm.tistory.com/26#recentEntries

[Node.js][노드] stream(스트림) 이란??