업로드 진행 - 요청

Question

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

누구든지 transloadit의 프로덕션 스택에서 실행중인 좋은 모듈을 생성했습니다 (신뢰할 수 있고 잘 유지 관리되고 있습니다). 당신은 여기에서 찾을 수 있습니다 : 당신은 다음 Socket.io

흥미있는 참고를 사용하여 클라이언트 상태를 밀어 수

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

: 같은

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

코드가 보일 것입니다 이것은 문제 중 하나 노드가 생성되었습니다. In this video Ryan은 사용자에게 실시간으로 파일을 업로드하는 가장 좋은 방법을 찾기 위해 노드가 시작된 방법에 대해 이야기합니다. 어쨌든 나는 빗 나갈 수 있지만 관심이 있다면 비디오는 가치가 있습니다. in 노드의 역사

Answer 3

이 방법을 시도해보십시오

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

나는 request 및 node 소스에 유효한 것을 찾기 위해 몇 시간을 보냈다, 그리고 마지막으로 나에게 더 정확한 느낌이 다른 접근 방법을 발견했다.

우리는 drain 이벤트와 bytesWritten 특성에 의존 할 수

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

스트림 버퍼 크기 : 당신이 파일 바이트의 진행 상황을 처리해야하는 경우 또는

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

, 그것은 스트림을 data 이벤트를 사용하는 것이 더 쉽습니다 는 65536 바이트이고 읽기/배수 절차는 반복적으로 실행됩니다.

이것은 나를 위해 node v4.5.0과 request v2.74.0로 꽤 잘 작동하는 것 같습니다.

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