15

我正在使用Request.

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

我如何知道实际上传了多少数据？是否有一些我可以订阅的事件，或者是否有request我可以投票的属性？

如果没有，上传数据并知道上传了多少数据的最佳方法是什么？

4

5 回答 5

13

我花了几个小时寻找任何有效的来源request和node来源，最后找到了一种不同的方法，这对我来说感觉更正确。

我们可以依赖drain事件和bytesWritten属性：

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

或者，如果您需要处理文件字节的进度，使用流data事件更容易：

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);
  })
});

流缓冲区大小为65536字节，读/漏过程迭代运行。

这对我来说似乎很好用node v4.5.0and request v2.74.0。

于 2016-09-14T13:49:59.893 回答
11

我需要处理我的另一个项目的上传进度。

我发现您可以轮询request'connection._bytesDispatched属性。

例如：

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

注意：如果您正在管道到r，请改为轮询r.req.connection.socket._bytesDispatched。

于 2013-08-20T20:34:37.037 回答
3 
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);
}
于 2018-03-07T13:24:14.997 回答
0

我知道这很旧，但我刚刚发现了一个没有被提及的库“progress-stream”并且做得很好。https://www.npmjs.com/package/progress-stream

const streamProg = require('progress-stream');
const fs = require('fs');
const request = require('request');

const myFile = 'path/to/file.txt';
const fileSize = fs.statSync('path/to/file.txt').size;
const readStream = fs.createReadStream(myFile);
const progress = streamProg({time: 1000, length: fileSize})
    .on('progress', state => console.log(state));

readStream.pipe(progress).pipe(request.put({url: 'SOMEURL/file.txt'}));

同样，它也可以在下载的管道之间使用。

于 2019-07-25T03:43:17.803 回答
-1

有人创建了一个很好的模块来完成此任务，该模块已在transloadit的生产堆栈中运行（因此它可靠且维护良好）。你可以在这里找到它：

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

代码应如下所示：

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);

然后，您可以使用Socket.io将状态推送到客户端

有趣的注释：这是导致 Node 创建的问题之一。在这段视频中，Ryan 谈到了 node 如何开始尝试寻找实时通知用户关于通过网络上传文件的状态的最佳方式......无论如何我离题了，但如果你是的话，这个视频值得一看对 Node 的历史感兴趣

于 2012-08-24T13:18:23.277 回答