Upload Progress - Request

Question

Ich lade eine Datei mit Request hoch.

req = request.post url: "http://foo.com", body: fileAsBuffer, (err, res, body) -> 
    console.log "Uploaded!" 

Woher weiß ich, wie viele Daten tatsächlich hochgeladen wurden? Gibt es ein Ereignis, das ich abonnieren kann, oder gibt es eine Eigenschaft von request, die ich abfragen kann?

Wenn keine, was wäre der beste Ansatz zum Hochladen von Daten und wissen, wie viel hochgeladen wurde?

Answer 1

Ich brauchte einen Griff auf den Upload-Fortschritt für ein weiteres Projekt von mir.

Was ich herausgefunden habe ist, dass Sie die request 's connection._bytesDispatched Eigenschaft abfragen können.

Zum Beispiel:

r = request.post url: "http://foo.com", body: fileAsBuffer 
setInterval (-> console.log "Uploaded: #{r.req.connection._bytesDispatched}"), 250 

Hinweis: Wenn Sie r kochend wurden, abfragen r.req.connection.socket._bytesDispatched statt.

Answer 2

Jemand hat ein schönes Modul erstellt, das im Produktionstack für transloadit läuft (so ist es zuverlässig und gut gepflegt). Sie können es hier finden:

https://github.com/felixge/node-formidable

-Code sollte wie folgt aussehen:

var formidable = require('formidable'), 
    http = require('http'), 

    util = require('util'); 

http.createServer(function(req, res) { 
    if (req.url == '/upload' && req.method.toLowerCase() == 'post') { 
    // parse a file upload 
    var form = new formidable.IncomingForm(); 
    form.parse(req, function(err, fields, files) { 
     res.writeHead(200, {'content-type': 'text/plain'}); 
     res.write('received upload:\n\n'); 
     res.end(util.inspect({fields: fields, files: files})); 
    }); 
    return; 
    } 

    // show a file upload form 
    res.writeHead(200, {'content-type': 'text/html'}); 
    res.end(
    '<form action="/upload" enctype="multipart/form-data" method="post">'+ 
    '<input type="text" name="title"><br>'+ 
    '<input type="file" name="upload" multiple="multiple"><br>'+ 
    '<input type="submit" value="Upload">'+ 
    '</form>' 
); 
}).listen(80); 

Sie dann Status an einen Client mit Socket.io

Interessante Hinweis drücken könnte: Das war eines der Probleme das führte zur Erstellung des Knotens. In this video Ryan spricht darüber, wie Knoten gestartet wurde, um die beste Möglichkeit zu finden, einen Benutzer in Echtzeit über den Status des Datei-Uploads über das Web zu informieren ... trotzdem schweife ich ab, aber das Video ist eine Uhr wert, wenn Sie interessiert sind in Nodes Geschichte

Answer 3

Versuchen Sie diesen Ansatz:

var file = fs.createWriteStream("largefile.jpg"); 
var totalbytes = request.headers['content-length']; 
var donesofar = 0; 

request.pipe(file); 
request.on('data', function(chunk){ 
    donesofar += chunk.length; 
    var progress = (donesofar/totalbytes) * 100; 
    response.write(parseInt(progress, 10) + "%\n"); 

}); 

Answer 4

Ich verbrachte ein paar Stunden alles gültig in request und node Quellen zu finden, und fand schließlich einen anderen Ansatz, der mir mehr richtig anfühlt.

Wir können auf drain Veranstaltung verlassen und bytesWritten Eigenschaft:

request.put({ 
    url: 'https://example.org/api/upload', 
    body: fs.createReadStream(path) 
}).on('drain',() => { 
    console.log(req.req.connection.bytesWritten); 
}); 

Alternativ, wenn Sie Fortschritt der Datei Bytes zu handhaben müssen, ist es einfacher, Strom zu verwenden data Ereignis:

let size = fs.lstatSync(path).size; 
let bytes = 0; 

request.put({ 
    url: 'https://example.org/api/upload', 
    body: fs.createReadStream(path).on('data', (chunk) => { 
    console.log(bytes += chunk.length, size); 
    }) 
}); 

Stream-Puffergröße ist 65536 Bytes und Lese/Drain-Verfahren läuft iterativ.

Das scheint für mich mit node v4.5.0 und request v2.74.0 ziemlich gut zu funktionieren.

Answer 5

var request = require('request'); 
    var fs = require('fs'); 
    let path ="C:/path/to/file"; 
    var formData = { 
     vyapardb: fs.createReadStream(path) 
    }; 

    let size = fs.lstatSync(path).size; 

    var headers = { 
     'Accept' : 'application/json', 
     'Authorization' : 'Bearer '+token, 
    }; 

    var r = request.post({url:'http://35.12.13/file/upload', formData: formData, headers: headers}, function optionalCallback(err, httpResponse, body) { 
     clearInterval(q); 

    }); 
    var q = setInterval(function() { 
     var dispatched = r.req.connection._bytesDispatched; 
     let percent = dispatched*100/size; 
     console.dir("Uploaded: " + percent + "%"); 

    }, 250); 
}