gọi lại để xử lý hoàn thành đường ống

Question

Tôi đang sử dụng mã node.js sau để tải xuống tài liệu từ một số url và lưu nó vào đĩa. Tôi muốn được thông báo về thời điểm tài liệu được tải xuống. tôi đã không nhìn thấy bất kỳ gọi lại với pipe.Or, Có bất kỳ sự kiện 'kết thúc' có thể được chụp khi hoàn thành tải về?

request(some_url_doc).pipe(fs.createWriteStream('xyz.doc')); 

Answer 1

Luồng là EventEmitter để bạn có thể nghe một số sự kiện nhất định. Như bạn đã nói, có sự kiện finish cho yêu cầu (trước đây là end).

var stream = request(...).pipe(...); 
stream.on('finish', function() { ... }); 

Để biết thêm thông tin về sự kiện nào bạn có thể kiểm tra stream documentation page.

Answer 2

Tài liệu nodejs gốc, http://nodejs.org/api/stream.html#stream_event_finish, cần xử lý sự kiện finish của writableStream.

var writable = getWriteable(); 
var readable = getReadable(); 
readable.pipe(writable); 
writable.on('finish', function(){ ... }); 

Answer 3

Đoạn mã cho nội dung đường ống từ web qua http (s) đến hệ thống tệp. Như @starbeamrainbowlabs nhận thấy sự kiện finish làm xong nhiệm vụ

var tmpFile = "/tmp/somefilename.doc"; 

var ws = fs.createWriteStream(tmpFile); 
ws.on('finish', function() { 
    // pipe done here, do something with file 
}); 

var client = url.slice(0, 5) === 'https' ? https : http; 
client.get(url, function(response) { 
    return response.pipe(ws); 
}); 

Answer 4

Tôi tìm thấy một giải pháp khác nhau một chút vấn đề của tôi liên quan đến bối cảnh này. Tư tưởng đáng chia sẻ.

Hầu hết ví dụ tạo readStreams từ tệp. Nhưng trong trường hợp của tôi readStream phải được tạo từ JSON chuỗi đến từ một nhóm tin nhắn.

var jsonStream = through2.obj(function(chunk, encoding, callback) { 
        this.push(JSON.stringify(chunk, null, 4) + '\n'); 
        callback(); 
       }); 
// message.vale --> valeu/text to write in write.txt 
jsonStream.write(JSON.parse(message.value)); 
var writeStream = sftp.createWriteStream("/path/to/write/write.txt"); 

//"close" event didn't work for me! 
writeStream.on('close', function() { 
    console.log("- done!"); 
    sftp.end(); 
    } 
); 

//"finish" event didn't work for me either! 
writeStream.on('close', function() { 
    console.log("- done!" 
     sftp.end(); 
     } 
); 

// finally this worked for me! 
jsonStream.on('data', function(data) { 
    var toString = Object.prototype.toString.call(data); 
    console.log('type of data:', toString); 
    console.log("- file transferred"); 
}); 

jsonStream.pipe(writeStream); 

Answer 5

Dưới đây là một giải pháp để xử lý những sai sót trong các yêu cầu và kêu gọi một cuộc gọi lại sau khi các tập tin được viết:.

request(opts) 
    .on('error', function(err){ return callback(err)}) 
    .pipe(fs.createWriteStream(filename)) 
    .on('finish', function (err) { 
     return callback(err); 
    });