上传进度 - 请求(Upload Progress — Request)

我使用的上传文件Request 。

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

我怎么知道有多少数据实际上已被上传？ 有一些事件，我可以订阅或者是那里的属性request ，我可以查询？

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

Answer 1:

我需要在上传进度的手柄为我的另一个项目。

我发现的是，你可以查询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代替。

Answer 2:

我花了几个小时找到任何有效的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.0和request v2.74.0 。

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

Answer 4:

有人创造了一个很好的模块来实现这一点，已经在生产堆已经运行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

值得注意的一点是：这是对导致节点的创造的问题之一。 在这个视频瑞恩谈到节点是如何开始试图找到通知用户，实时，有关文件上传在网上的状态的最好方法......反正我离题了，但视频是值得如果你是一个手表感兴趣的节点的历史

文章来源: Upload Progress — Request