Solicitud de nodo: cómo determinar si se produjo un error durante la solicitud.

Question

Estoy tratando de aprovechar el node-request module, pero la documentación no es tan buena. Si realizo una solicitud a un recurso válido y lo canalizo a una secuencia de escritura, todo funciona bien. Sin embargo, si realizo una solicitud a un objeto no válido, la secuencia de escritura aún se crea. Ejemplo, tomemos el siguiente fragmento:

var x = request("http://localhost:3000/foo.jpg"); 
var st = fs.createWriteStream("foo.jpg"); 
x.pipe(st); 

Si el recurso existe foo.jpg en el servidor, los datos se canaliza a la corriente, y se crea la multa archivo en el servidor. Sin embargo, si foo.jpg no existe en el servidor, aún se crea un archivo contenedor en blanco. No parece haber ningún caso de error o cualquier cosa que se puede aprovechar para determinar si la petición devuelve un 404. He intentado algo como lo siguiente:

var x = request("http://localhost:3000/foo.jpg", function(err, response, body) { 
    if(response.statusCode === 200) { 
     // Success 
     var st = fs.createWriteStream("foo.jpg"); 
     x.pipe(st); 
    } 
}); 

Y también:

request("http://localhost:3000/foo.jpg", function(err, response, body) { 
    if(response.statusCode === 200) { 
     // Success 
     var x = response.request; 
     var st = fs.createWriteStream("foo.jpg"); 
     x.pipe(st); 
    } 
}); 

Para ningún aprovechar. La idea es bastante simple; Solo quiero copiar un archivo identificado por la URL al servidor local. Si la solicitud no es válida (404, etc.), no pipe el archivo; si la solicitud es válida, canalice el archivo. ¿Alguna sugerencia?

Answer 1

escribí petición :)

es posible que desee probar esta solución @Mikeal

var r = request(url) 
r.on('response', function (resp) { 
    resp.headers 
    resp.statusCode 
    r.pipe(new WritableStream()) 
}) 

Answer 2

¿Por qué no utilizar el módulo http directamente? http.request

Tiene un evento de 'error' que puede utilizar para detectar el error.

Answer 3

se ve muy bien, pero puede tener algún problema con la tubería (primeros bytes se puede perder). Hee es un código de actualización:

var r = request(url) 
r.pipe(new WritableStream()); 
r.on('response', function (resp) { 
    resp.headers 
    resp.statusCode 
    // Handle error case and remove your writablestream if need be. 
}) 

Answer 4

La forma en que terminé tener éxito con las nuevas corrientes en el nodo:

function doQuery(){ 
    var r = request(url) 
    r.pause() 
    r.on('response', function (resp) { 
     if(resp.statusCode === 200){ 
      r.pipe(new WritableStream()) //pipe to where you want it to go 
      r.resume() 
     }else{ } 
    }) 
} 

Esto es muy flexible - si desea volver a intentarlo, puede llamar a la función recursiva con setTimeout

function doQuery(){ 
    var r = request(url) 
    r.pause() 
    r.on('response', function (resp) { 
     if(resp.statusCode === 200){ 
      r.pipe(new WritableStream()) //pipe to where you want it to go 
      r.resume() 
     }else{ 
      setTimeout(doQuery,1000) 
     } 
    }) 
}