Потоки с процентом завершения

Question

Мне нужно передать файл в base64 на конечную точку http, используя что-то вроде запроса или суперагента. Каков наилучший способ выяснить, какой процент файла был загружен?

Я предполагаю, что могу создать поток чтения, используя что-то вроде:

fs.createReadStream('/tmp/cats.jpg', {encoding: 'base64'})

Будем весьма благодарны за любые примеры, использующие одну из вышеуказанных библиотек.

Answer 1

В nodejs у нас есть поток Readable, он испускает data событие, когда он получает порцию данных, зная размер файла, вы можете легко отслеживать, сколько данных проходит через data приемник событий, а затем обновить процент.

Получите размер файла с

require('fs').watchFile('yourfile', function () {
    fs.stat('yourfile', function (err, stats) {
        console.log(stats.size);
    });
});

Answer 2

Я думаю, что вы можете использовать прогресс-стрим.

Answer 3

Я искал ответ на похожую проблему, и благодаря ответу Альберто Закканьи я смог заставить работать некоторый код.

Так что для людей, которые не хотят сами составлять пазл, вот код (отредактированный для Stackru):

var zipfile = "my_large_archive.zip";

// Get the size of the file
fs.stat(zipfile, function (err, stats) {
    var zipSize         = stats.size;
    var uploadedSize    = 0; // Incremented by on('data') to keep track of the amount of data we've uploaded

    // Create a new read stream so we can plug events on it, and get the upload progress
    var zipReadStream   = fs.createReadStream(zipfile);

    zipReadStream.on('data', function(buffer) {
        var segmentLength   = buffer.length;

        // Increment the uploaded data counter
        uploadedSize        += segmentLength;

        // Display the upload percentage
        console.log("Progress:\t",((uploadedSize/zipSize*100).toFixed(2)+"%"));
    });

    // Some other events you might want for your code
    zipReadStream.on('end', function() {
        console.log("Event: end");
    });
    zipReadStream.on('close', function() {
        console.log("Event: close");
    });


    var formData    = require('form-data');
    var form        = new formData();

    form.append('apikey', 'f4sd5f4sdf6ds456');  // Just some post parameters I need to send to the upload endpoint
    form.append('file', zipReadStream);         // The zip file, passed as a fs.createReadStream instance

    // Submit the form and the file
    form.submit('http://www.someserver.com/upload', function(err, res) {
        if (err) {
            console.log("Oups! We encountered an error :(\n\n", err);
            return false;
        }
        console.log("Your file has been uploaded.");
        res.resume();   // Fix is you use that code for a CLI, so that the execution will stop and let users enter new commands
    });
});