ノード要求 - 要求中にエラーが発生したかどうかを判断する方法？

Question

私はnode-request moduleを活用しようとしていますが、ドキュメントはそれほど大きくありません。私が有効なリソースに要求し、それを書き込み可能なストリームにパイプすると、すべて正常に動作します。しかし、無効なオブジェクトに対して要求を行うと、書き込み可能なストリームが作成されます。たとえば、次のスニペットを取る：foo.jpgというリソースがサーバー上に存在する

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

場合は、データがストリームにパイプされ、そしてそれは、サーバー上のファイルの罰金を作成します。ただし、foo.jpg がサーバーにが存在しない場合は、空のコンテナファイルが作成されます。エラーイベントまたは要求が、私は以下のようなものを試してみた404を返されたかどうかを判断するために活用することができるものはないように見える：

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

も：

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

NOに利用可能。アイデアはかなりシンプルです。私は、URLで識別されるファイルをローカルサーバーにコピーしたいだけです。リクエストが無効な場合（404など）、ファイルをパイプしません。要求が有効な場合は、ファイルをパイプします。助言がありますか？

Answer 1

私は要求を書いた:)

あなたがしようとする場合があります。この

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

Answer 2

httpモジュールを直接使用してみませんか？ http.request

エラーをキャッチするために使用できる「エラー」イベントがあります。

Answer 3

@Mikealソリューションは偉大に見えるが、（最初の数バイトを見逃すことができます）配管といくつかの問題がある可能性があります。 喜が更新されたコードです：

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

私はノードの新しいストリームで成功してしまった方法：

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

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