Node.jsでファイルをダウンロードする実装方法｜ストリーム処理でメモリ負荷を抑える手法

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

const url = 'https://example.com/sample-image.jpg';
const file = fs.createWriteStream('sample-image.jpg');

https.get(url, (response) => {
  // レスポンスをファイルストリームにパイプでつなぐ
  response.pipe(file);

  file.on('finish', () => {
    file.close();
    console.log('ダウンロードが完了しました');
  });
}).on('error', (err) => {
  console.error(`エラーが発生しました: ${err.message}`);
});

ダウンロードが完了しました

const { pipeline } = require('stream/promises');
const fs = require('fs');
const https = require('https');

async function downloadFile(url, dest) {
  return new Promise((resolve, reject) => {
    https.get(url, async (response) => {
      if (response.statusCode !== 200) {
        reject(new Error(`ステータスコード: ${response.statusCode}`));
        return;
      }

      try {
        // pipelineを使用して安全にストリームを結合
        await pipeline(
          response,
          fs.createWriteStream(dest)
        );
        resolve();
      } catch (err) {
        reject(err);
      }
    });
  });
}

downloadFile('https://example.com/large-video.mp4', 'video.mp4')
  .then(() => console.log('安全にダウンロードが完了しました'))
  .catch(err => console.error('エラー:', err));

安全にダウンロードが完了しました

const fs = require('fs');
const { Readable } = require('stream');
const { finished } = require('stream/promises');

async function downloadWithFetch(url, path) {
  const response = await fetch(url);
  
  if (!response.ok) {
    throw new Error(`リクエスト失敗: ${response.statusText}`);
  }

  const fileStream = fs.createWriteStream(path);
  
  // Node.jsのReadableストリームに変換してパイプ処理
  await finished(Readable.fromWeb(response.body).pipe(fileStream));
  
  console.log('Fetch APIによるダウンロードが完了しました');
}

downloadWithFetch('https://example.com/data.zip', 'data.zip');

Fetch APIによるダウンロードが完了しました

const fs = require('fs');

async function downloadWithProgress(url, path) {
  const response = await fetch(url);
  const totalBytes = parseInt(response.headers.get('content-length'), 10);
  let downloadedBytes = 0;

  const reader = response.body.getReader();
  const writer = fs.createWriteStream(path);

  while (true) {
    const { done, value } = await reader.read();
    
    if (done) break;

    downloadedBytes += value.length;
    writer.write(value);

    // 進捗率の計算と表示
    const progress = ((downloadedBytes / totalBytes) * 100).toFixed(2);
    process.stdout.write(`\rダウンロード中: ${progress}%`);
  }

  writer.end();
  console.log('\nダウンロード完了');
}

ダウンロード中: 100.00%
ダウンロード完了