blocks|key|2450125|text|有人已经创建了一个很好的模块来实现这一点，该模块已经在transloadit的生产堆栈中运行(因此它是可靠的，并且维护良好)。你可以在这里找到它：|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|2450126|https://github.com/felixge/node-formidable|2450127|代码应如下所示：|2450128|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">'%2B
++++'<input+type="text"+name="title"> '%2B
++++'<input+type="file"+name="upload"+multiple="multiple"> '%2B
++++'<input+type="submit"+value="Upload">'%2B
++++'</form>'
++);
}).listen(80);|code-block|syntax|javascript|2450129|然后，您可以使用Socket.io将状态推送到客户端|2450130|有趣的注解:这是导致Node创建的问题之一。在node中，Ryan谈到了Node是如何开始尝试找到最佳的方式来实时通知用户关于web...anyway+I分支上的文件上传状态的，但如果你对Node的历史感兴趣，这段视频值得一看|2450131|entityMap|0|LINK|mutability|MUTABLE|url|http://transloadit.com/|1|2|http://www.google.com/url?sa=t&rct=j&q=&esrc=s&frm=1&source=web&cd=1&cad=rja&ved=0CCAQFjAA&url=http://socket.io/&ei=Ln43UOTvPI_g6wG90YD4BQ&usg=AFQjCNG8kzehIcRMCwXVQUB46eWDrmNbdA&sig2=JggUfYS92gmWyNN8rZLm7g^0|R|B|0|0|0|16|1|0|0|0|8|9|2|0|0^^$0|@$1|2|3|4|5|6|7|11|8|@]|9|@$A|12|B|13|1|14]]|C|$]]|$1|D|3|E|5|6|7|15|8|@]|9|@$A|16|B|17|1|18]]|C|$]]|$1|F|3|G|5|6|7|19|8|@]|9|@]|C|$]]|$1|H|3|I|5|J|7|1A|8|@]|9|@]|C|$K|L]]|$1|M|3|N|5|6|7|1B|8|@]|9|@$A|1C|B|1D|1|1E]]|C|$]]|$1|O|3|P|5|6|7|1F|8|@]|9|@]|C|$]]|$1|Q|3|-4|5|6|7|1G|8|@]|9|@]|C|$]]]|R|$S|$5|T|U|V|C|$W|X]]|Y|$5|T|U|V|C|$W|E]]|Z|$5|T|U|V|C|$W|10]]]]

Someone has created a nice module to accomplish this that has been running in the production stack for <a href="http://transloadit.com/" rel="nofollow">transloadit</a> (so it is dependable and well maintained). You can find it here: 

<a href="https://github.com/felixge/node-formidable" rel="nofollow">https://github.com/felixge/node-formidable</a>

Code should look like: 

<pre><code>var formidable = require('formidable'),
 http = require('http'),

 util = require('util');

http.createServer(function(req, res) {
 if (req.url == '/upload' &amp;&amp; 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(
 '&lt;form action="/upload" enctype="multipart/form-data" method="post"&gt;'+
 '&lt;input type="text" name="title"&gt;&lt;br&gt;'+
 '&lt;input type="file" name="upload" multiple="multiple"&gt;&lt;br&gt;'+
 '&lt;input type="submit" value="Upload"&gt;'+
 '&lt;/form&gt;'
 );
}).listen(80);
</code></pre>

You could then push status to a client using <a href="http://www.google.com/url?sa=t&amp;rct=j&amp;q=&amp;esrc=s&amp;frm=1&amp;source=web&amp;cd=1&amp;cad=rja&amp;ved=0CCAQFjAA&amp;url=http://socket.io/&amp;ei=Ln43UOTvPI_g6wG90YD4BQ&amp;usg=AFQjCNG8kzehIcRMCwXVQUB46eWDrmNbdA&amp;sig2=JggUfYS92gmWyNN8rZLm7g" rel="nofollow">Socket.io</a>

Interesting Note: This was one of the problems that led to Node's creation. In <a href="http://www.youtube.com/watch?v=SAc0vQCC6UQ" rel="nofollow">this video</a> Ryan talks about how node was started trying to find the best way of notifying a user, real time, about the status of file upload over the web...anyway I digress, but the video is worth a watch if you are interested in Node's history

blocks|key|4085254|text|我需要一个句柄的上传进度为我的另一个项目。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|4085255|我发现您可以轮询request的connection._bytesDispatched属性。|offset|length|style|CODE|4085256|例如：|4085257|r+=+request.post+url:+"http://foo.com",+body:+fileAsBuffer
setInterval+(->+console.log+"Uploaded:+#{r.req.connection._bytesDispatched}"),+250|code-block|syntax|javascript|4085258|注意：如果您通过管道连接到r，则轮询r.req.connection.socket._bytesDispatched。|BOLD|4085259|entityMap^0|0|8|7|G|R|0|0|0|0|2|D|1|I|14|0^^$0|@$1|2|3|4|5|6|7|T|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|U|8|@$D|V|E|W|F|G]|$D|X|E|Y|F|G]]|9|@]|A|$]]|$1|H|3|I|5|6|7|Z|8|@]|9|@]|A|$]]|$1|J|3|K|5|L|7|10|8|@]|9|@]|A|$M|N]]|$1|O|3|P|5|6|7|11|8|@$D|12|E|13|F|Q]|$D|14|E|15|F|G]|$D|16|E|17|F|G]]|9|@]|A|$]]|$1|R|3|-4|5|6|7|18|8|@]|9|@]|A|$]]]|S|$]]

I needed a handle on the upload progress for yet another project of mine.

What I found out is that you can poll the <code>request</code>'s <code>connection._bytesDispatched</code> property.

For example:

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

Note: If you were piping to <code>r</code>, poll <code>r.req.connection.socket._bytesDispatched</code> instead.

blocks|key|4085320|text|我花了几个小时在request和node源代码中找到任何有效的东西，最后找到了一种不同的方法，这对我来说更正确。|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|4085321|我们可以依赖drain事件和bytesWritten属性：|4085322|request.put({
++url:+'https://example.org/api/upload',
++body:+fs.createReadStream(path)
}).on('drain',+()+=>+{
++console.log(req.req.connection.bytesWritten);
});|code-block|syntax|javascript|4085323|或者，如果您需要处理文件字节的进度，则更容易使用流data事件：|4085324|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+%2B=+chunk.length,+size);
++})
});|4085325|流缓冲区大小为65536字节，读取/排出过程迭代运行。|4085326|这对我来说在node+v4.5.0和request+v2.74.0上似乎工作得很好。|4085327|entityMap|0|LINK|mutability|MUTABLE|url|https://nodei.co/npm/request/|1|https://nodejs.org/api/stream.html#stream_event_drain|2|https://nodejs.org/api/net.html#net_socket_byteswritten|3|https://nodejs.org/api/stream.html#stream_event_data^0|8|7|G|4|8|7|0|0|6|5|E|C|6|5|1|E|C|2|0|0|P|4|P|4|3|0|0|7|5|0|6|B|I|F|0^^$0|@$1|2|3|4|5|6|7|18|8|@$9|19|A|1A|B|C]|$9|1B|A|1C|B|C]]|D|@$9|1D|A|1E|1|1F]]|E|$]]|$1|F|3|G|5|6|7|1G|8|@$9|1H|A|1I|B|C]|$9|1J|A|1K|B|C]]|D|@$9|1L|A|1M|1|1N]|$9|1O|A|1P|1|1Q]]|E|$]]|$1|H|3|I|5|J|7|1R|8|@]|D|@]|E|$K|L]]|$1|M|3|N|5|6|7|1S|8|@$9|1T|A|1U|B|C]]|D|@$9|1V|A|1W|1|1X]]|E|$]]|$1|O|3|P|5|J|7|1Y|8|@]|D|@]|E|$K|L]]|$1|Q|3|R|5|6|7|1Z|8|@$9|20|A|21|B|C]]|D|@]|E|$]]|$1|S|3|T|5|6|7|22|8|@$9|23|A|24|B|C]|$9|25|A|26|B|C]]|D|@]|E|$]]|$1|U|3|-4|5|6|7|27|8|@]|D|@]|E|$]]]|V|$W|$5|X|Y|Z|E|$10|11]]|12|$5|X|Y|Z|E|$10|13]]|14|$5|X|Y|Z|E|$10|15]]|16|$5|X|Y|Z|E|$10|17]]]]

I spent a couple of hours to find anything valid in <a href="https://nodei.co/npm/request/" rel="noreferrer"><code>request</code></a> and <code>node</code> sources, and finally found a different approach, which feels more correct to me.

We can rely on <a href="https://nodejs.org/api/stream.html#stream_event_drain" rel="noreferrer"><code>drain</code></a> event and <a href="https://nodejs.org/api/net.html#net_socket_byteswritten" rel="noreferrer"><code>bytesWritten</code></a> property:

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

Alternatively if you need to handle progress of file bytes, it's easier to use stream <a href="https://nodejs.org/api/stream.html#stream_event_data" rel="noreferrer"><code>data</code></a> event:

<pre><code>let size = fs.lstatSync(path).size;
let bytes = 0;

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

Stream buffer size is <code>65536</code> bytes and read/drain procedure runs iteratively.

This seems to be working pretty well for me with <code>node v4.5.0</code> and <code>request v2.74.0</code>.

blocks|key|4085339|text|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+'%2Btoken,
++++};

++++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:+"+%2B+percent+%2B+"%25");

++++},+250);
}|type|code-block|depth|inlineStyleRanges|entityRanges|data|syntax|javascript|4085340|unstyled|entityMap^0|0^^$0|@$1|2|3|4|5|6|7|G|8|@]|9|@]|A|$B|C]]|$1|D|3|-4|5|E|7|H|8|@]|9|@]|A|$]]]|F|$]]

<pre><code>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);
}
</code></pre>

blocks|key|4085365|text|我知道这是旧的，但是我刚刚发现了一个没有被提及的库'progress-stream‘，它做得非常好。https://www.npmjs.com/package/progress-stream|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|4085366|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'}));|code-block|syntax|javascript|4085367|类似地，它也可以在下载时在管道之间使用。|4085368|entityMap|0|LINK|mutability|MUTABLE|url|https://www.npmjs.com/package/progress-stream^0|1E|19|0|0|0|0^^$0|@$1|2|3|4|5|6|7|S|8|@]|9|@$A|T|B|U|1|V]]|C|$]]|$1|D|3|E|5|F|7|W|8|@]|9|@]|C|$G|H]]|$1|I|3|J|5|6|7|X|8|@]|9|@]|C|$]]|$1|K|3|-4|5|6|7|Y|8|@]|9|@]|C|$]]]|L|$M|$5|N|O|P|C|$Q|R]]]]

I know this is old, but I just found a library 'progress-stream' that has not been mentioned and does this very nicely. <a href="https://www.npmjs.com/package/progress-stream" rel="nofollow noreferrer">https://www.npmjs.com/package/progress-stream</a>

<pre><code>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 =&gt; console.log(state));

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

Similarly, it can be used between a pipe on download as well.

I'm uploading a file using <a href="https://github.com/mikeal/request"><code>Request</code></a>.

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

How do I know how much data has actually been uploaded? Is there some event that I can subscribe to or is there a property of the <code>request</code> that I can poll?

If none, what would be the best approach to upload data and know how much has been uploaded?

Upload Progress — Request

翻译质量差，导致语言生硬或混乱。

没有提供实际的解决方法或示例。

解答不清晰，无法理解或解决问题。

页面排版不美观，阅读体验差。

文章

问答

视频

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

我正在使用上传文件。req = request.post url: "http://foo.com", body: fileAsBuffer, (err, res, body) ->    console.log "Uploaded!"我如何知道实际上传了多少数据？是否有我可以订阅的事件，或者是否有我可以轮询的requ...

问上传进度-请求
EN

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问上传进度-请求EN