クライアントにジップを動的に作成してストリームします。

Question

NodeJs（w/express）を使用しています。クライアントにzipファイルをストリーミングしようとしています。 zipに含まれるファイルは、ファイルシステム上には存在せず、動的に作成されます。ファイルの内容をzipにストリームし、zipをクライアントにストリームしたいと思います。

I.E.

1,2,3.txtはその場で作成され、zipファイルにストリーミングされます。これは可能ですか？

Answer 1

には、テキストをファイルとして保存できる追加メソッドがあります。そのデータをユーザーに「ストリーム」するには、単にHTTP応答オブジェクトにパイプするだけです。

var Http = require('http'); 
var Archiver = require('archiver'); 

Http.createServer(function (request, response) { 
    // Tell the browser that this is a zip file. 
    response.writeHead(200, { 
     'Content-Type': 'application/zip', 
     'Content-disposition': 'attachment; filename=myFile.zip' 
    }); 

    var zip = Archiver('zip'); 

    // Send the file to the page output. 
    zip.pipe(response); 

    // Create zip with some files. Two dynamic, one static. Put #2 in a sub folder. 
    zip.append('Some text to go in file 1.', { name: '1.txt' }) 
     .append('Some text to go in file 2. I go in a folder!', { name: 'somefolder/2.txt' }) 
     .file('staticFiles/3.txt', { name: '3.txt' }) 
     .finalize(); 

}).listen(process.env.PORT); 

これにより、2つのテキストファイルを含むzipファイルが作成されます。このページにアクセスしたユーザーには、ファイルダウンロードのプロンプトが表示されます。

Answer 2

はい、可能です。ノードストリームの仕組みを理解するには、Streams Playgroundをお勧めします。

コアzlibライブラリのzip圧縮は、複数のファイルをサポートしていないようです。 tar-gzipを使いたい場合はnode-tarでタールすることができます。しかし、あなたがZIPを望むなら、adm-zipは最良の選択肢のように見えます。別の可能性はnode-archiverです。

更新：

このexampleストリームをサポートアーカイバを使用する方法を示しています。 fs.createReadStreamを動的に作成するストリームに置き換えて、fs.createWriteStreamではなくoutputストリームをExpressのresに置き換えてください。

var fs = require('fs'); 

var archiver = require('archiver'); 

var output = fs.createWriteStream(__dirname + '/example-output.zip'); 
var archive = archiver('zip'); 

output.on('close', function() { 
    console.log('archiver has been finalized and the output file descriptor has closed.'); 
}); 

archive.on('error', function(err) { 
    throw err; 
}); 

archive.pipe(output); 

var file1 = __dirname + '/fixtures/file1.txt'; 
var file2 = __dirname + '/fixtures/file2.txt'; 

archive 
    .append(fs.createReadStream(file1), { name: 'file1.txt' }) 
    .append(fs.createReadStream(file2), { name: 'file2.txt' }); 

archive.finalize(function(err, bytes) { 
    if (err) { 
    throw err; 
    } 

    console.log(bytes + ' total bytes'); 
}); 

Answer 3

とソリューション：それはあなたが「zipファイルにストリーム」によって何を意味するかは明らかではありませんexpress.js、wait.for、ジップストリーム

app.get('/api/box/:box/:key/download', function (req, res) { 

    var wait = require('wait.for'); 

    var items = wait.for(function (next) { 
     BoxItem.find({box: req.Box}).exec(next) 
    }); 

    res.set('Content-Type', 'application/zip'); 
    res.set('Content-Disposition', 'attachment; filename=' + req.Box.id + '.zip'); 

    var ZipStream = require('zip-stream'); 
    var zip = new ZipStream(); 

    zip.on('error', function (err) { 
     throw err; 
    }); 

    zip.pipe(res); 

    items.forEach(function (item) { 

     wait.for(function (next) { 

      var path = storage.getItemPath(req.Box, item); 
      var source = require('fs').createReadStream(path); 

      zip.entry(source, { name: item.name }, next); 
     }) 

    }); 

    zip.finalize(); 

});