JS - 火災事件中的最大每x秒一次

Question

我有這個事件是由外部進程觸發一次，每2秒（這是一個串行口接收數據）：

sp.on("data", function (rawData) { 
    try { 
     data = JSON.parse(rawData); 
     var collection = db.get('sensorsCollection'); 
     collection.insert({ 
      ... 
     }); 
    } catch (error) { 
     debug(error); 
    } 
}); 

但我想存儲在數據庫中的數據每一次只有一次，比如說500秒以避免我的數據庫超載。如何實現這一目標？

（注：我試圖用underscore.js的功能throttle但無法找到如何參數傳遞給調用throttle的功能，所以我不能錯過包含最新的數據我新鮮data變量）。

Answer 1

存儲您的上傳數據，給他們每500秒：

var my_datas=[]; 
sp.on("data", function (rawData){ 
    try { 
     //store the data 
     my_datas.push(rawData); 
     }); 
    } catch (error) { 
     debug(error); 
    } 
}); 

setInterval(function(){ 
    for(var i=0, len= my_datas.length; i<len; i++){ 

     data = JSON.parse(my_datas[i]); 
     var collection = db.get('sensorsCollection'); 
     collection.insert({ 
      ... 
     }); 

    } 
    },500*1000); 

Answer 2

完全未經測試，但將這樣的事情你想要做什麼？：

(function() { 
    var collection = db.get('sensorsCollection'); 
    var data = []; 

    sp.on("data", function (rawData) { 
     try { 
      data.push(JSON.parse(rawData)); 
     } catch (error) { 
      debug(error); 
     } 
    }); 

    setInterval(function() { // try-catch here too if necessary 
     collection.insert(data); // additional formatting? 
     data = []; 
    }, 500 * 1000); 
}()); 

編輯使用setTimeout而不是throttle，這是沒有意義的使用方式。