2016-04-08 17 views
0

私は、.jsonファイルをバッファしてそのデータをサーバーにPOSTする作業コードを用意しています。私が代わりにやりたいものをStream application/json POSTリクエスト

fs.readFile(filePath, 'utf-8', function (err, buf) { 

     if(err){ 
      reject(err); 
     } 
     else{ 
      const req = http.request({ 
       method: 'POST', 
       host: 'localhost', 
       path: '/event', 
       port: '4031', 
       headers: { 
        'Content-Type': 'application/json', 
        'Content-Length': buf.length 
       } 
      }); 


      req.on('error', reject); 

      var data = ''; 

      req.on('response', function (res) { 

       res.setEncoding('utf8'); 

       res.on('data', function ($data) { 
        data += $data 
       }); 

       res.on('end', function() { 

        data = JSON.parse(data); 
        console.log('data from SC:', data); 

        //call fn on data and if it passes we are good 
        resolve(); 
       }); 
      }); 

      // write data to request body 
      req.write(buf); 
      req.end(); 
     } 


    }); 

は、それをバッファリングを避けるためにある、とだけfs.createReadStreamを使用し、そのような何か:

fs.createReadStream(filePath, 'utf-8', function (err, strm) { 

    if(err){ 
     reject(err); 
    } 
    else{ 
     const req = http.request({ 
      method: 'POST', 
      host: 'localhost', 
      path: '/event', 
      port: '4031', 
      headers: { 
       'Content-Type': 'application/json', 
       // 'Content-Length': buf.length 
      } 
     }); 


     req.on('error', reject); 

     var data = ''; 

     req.on('response', function (res) { 

      res.setEncoding('utf8'); 

      res.on('data', function ($data) { 
       data += $data 
      }); 

      res.on('end', function() { 

       data = JSON.parse(data); 
       console.log('data from SC:', data); 

       //call fn on data and if it passes we are good 
       resolve(); 
      }); 
     }); 

     // write data to request body 
     req.write(strm); 
     req.end(); 
    } 


}); 

が、それはかなり動作しませんか?これは可能ですか?それは正しい100%かどう

答えて

0

これが動作しているようですが、わからない

const strm = fs.createReadStream(filePath); 


const req = http.request({ 
    method: 'POST', 
    host: 'localhost', 
    path: '/event', 
    port: '4031', 
    headers: { 
     'Content-Type': 'application/json', 
    } 
}); 


req.on('error', reject); 

var data = ''; 

req.on('response', function (res) { 

    res.setEncoding('utf8'); 

    res.on('data', function ($data) { 
     data += $data 
    }); 

    res.on('end', function() { 

     data = JSON.parse(data); 
     resolve(); 
    }); 
}); 

// write data to request body 
strm.pipe(req);