我在我的本地目录中有一个部件文件列表
Directory: 'C:/Users/Documents/rast'
folder: rast
|
|____ rast_001.part (approx size: 500 MB)
|
|____ rast_002.part (approx size: 500 MB)
|
|____ rast_003.part (approx size: 500 MB)
|
|____ rast_004.part (approx size: 500 MB)
|
|____ rast_005.part (approx size: 500 MB)
|
|____ rast_006.part (approx size: 500 MB)我想将所有的部件文件合并成一个单独的部件文件。
我尝试了以下方法,但我无法做到这一点。
require('events').EventEmitter.defaultMaxListeners = 15;
//requiring path and fs modules
const path = require('path');
const fs = require('fs');
const outputPath = path.join('C:/Users/Documents/rast', 'output.part');
var w = fs.createWriteStream(outputPath, {flags: 'a'});
//joining path of directory
const directoryPath = path.join('C:/Users/Documents', 'rast');
//passsing directoryPath and callback function
fs.readdir(directoryPath, function (err, files) {
files.forEach(function (file) {
const filePath = path.join('C:/Users/Documents/rast', file);
var r = fs.createReadStream(filePath);
r.pipe(w, { end: true });
}
});如果我执行此代码,它将创建一个空输出文件(大小为零)。请帮助我如何做这件事。
注:部分文件可能包含任何内容,可以是文本文件、JAR文件、EXE文件、ZIP文件、PDF等。
发布于 2019-01-08 10:29:06
您能为管道中的每个读写器创建写吗?就像下面的例子。希望这能帮到你。尝试侦听写入流中的错误。
require('events').EventEmitter.defaultMaxListeners = 15;
var fs=require('fs');
var path=require('path');
fs.readdir('./',(err,files)=>{
files.forEach((file)=>{
if(file!='node_modules'){
console.log('Appending file-->'+file);
var stream= fs.createReadStream(path.join(__dirname,file))
.pipe(fs.createWriteStream('./output.part',{flags:'a',autoClose:true})
.on('finish',()=>{console.log('Wstrm Closed...');})
.on('error',(err)=>{console.log('Error at writrStream-->',err)}));
stream.on('error',(err)=>{
console.log('Read Stream Error-->',err);
})
.on('close',()=>{console.log('Rdstrm closed for file-->',file)});
}
});
});https://stackoverflow.com/questions/54086633
复制相似问题