Servicio REST de sondeo con Node.js

Question

Estoy trabajando en un servicio que sondearía Foursquare para realizar comprobaciones cada minuto o así y guardar/actualizar los resultados en una base de datos NoSQL. ¿Es el mejor enfoque para ajustar una http.request con setInterval y luego agregar la respuesta fragmentada utilizando el emisor de eventos de datos? Planeo usar el emisor final para analizar el JSON e insertarlo en un DB NoSQL cuando la solicitud esté completa. ¿Pensamientos?

Answer 1

Puede haber mejores maneras, pero acabé utilizando emisores de eventos para procesar la respuesta RESTO de la siguiente manera:

var fourSquareGet = { 
    host: 'api.foursquare.com', 
    port: 443, 
    path: '/v2/venues/search?ll=33.88,-119.19&query=burger*', 
    method: 'GET' 
}; 
setInterval(function() { 
    var reqGet = https.request(fourSquareGet, function (res) { 
     var content; 

     res.on('data', function (chunk) { 
      content += chunk; 
     }); 
     res.on('end', function() { 
      // remove 'undefined that appears before JSON for some reason 
      content = JSON.parse(content.substring(9, content.length)); 
      db.checkins.save(content.response.venues, function (err, saved) { 
       if (err || !saved) throw err; 
      }); 
      console.info("\nSaved from Foursquare\n"); 
     }); 
    }); 

    reqGet.end(); 
    reqGet.on('error', function (e) { 
     console.error(e); 
    }); 
}, 25000); 

Sin embargo, no estoy seguro de por qué tenía omita "indefinido" de la JSON que recibí de foursquare.

Answer 2

Cuando me encontré con un problema similar, empleé una técnica similar y funcionó bien. Here's where I got the idea from. Espero que esto ayude un poco.

Answer 3

he fijado por la respuesta @occasl, y actualizados para mayor claridad:

var https = require('https'); 

setInterval(function() { 

    var rest_options = { 
     host: 'api.example.com', 
     port: 443, 
     path: '/endpoint', 
     method: 'GET' 
    }; 

    var request = https.request(rest_options, function(response) { 
     var content = ""; 

     // Handle data chunks 
     response.on('data', function(chunk) { 
      content += chunk; 
     }); 

     // Once we're done streaming the response, parse it as json. 
     response.on('end', function() { 
      var data = JSON.parse(content); 

      //TODO: Do something with `data`. 
     }); 
    }); 

    // Report errors 
    request.on('error', function(error) { 
     console.log("Error while calling endpoint.", error); 
    }); 

    request.end(); 
}, 5000);