सिंकानो कोडबॉक्स - कॉल एपीआई - पार्स जेएसओएन - संदर्भ प्राप्त करें - नए ऑब्जेक्ट्स सहेजें

Question

मैं सिंकानो को बास के रूप में उपयोग कर रहा हूं, जहां मैं एक JSON सरणी प्राप्त करने के लिए बाहरी API को कॉल करने का प्रयास कर रहा हूं। इस JSON को पार्स किया जाना चाहिए और बाद में सिंकानो में संग्रहीत किया जाना चाहिए। इससे पहले मुझे डीबी से संदर्भ वस्तु को नई टीम ऑब्जेक्ट से जोड़ने की आवश्यकता है।

मुझे टीम (जेसन) सरणी & संदर्भ वस्तु सफलतापूर्वक प्राप्त होती है। लेकिन मैं नए डेटा को संग्रहीत करने में असमर्थ हूं, क्योंकि केवल 12-14 टीमें (18 वर्ष होनी चाहिए) बचाई गई है।

मैंने इस & को आजमाया कि वादे के साथ लेकिन यह काम नहीं कर सका। कोई भी अच्छी सलाह देता है कि सभी डेटा स्टोर करने के लिए कोड को फिर से लिखना कैसे है? धन्यवाद - यहाँ है क्या मैं अब तक है ...

//TODO: get from ARGS when executing this codebox 
var teamKey = 394; 
var requestURL = 'http://api.football-data.org/v1/soccerseasons/' + teamKey + "/teams"; 

var request = require("request"); 
var Syncano = require('syncano'); 
var Promise = require('bluebird'); 
var account = new Syncano({ 
    accountKey: "abc" 
}); 
var promises = []; 

//from: http://docs.syncano.io/v1.0/docs/data-objects-filtering 
//"_eq" means equals to 
var filter = { 
    "query": { 
    "apikey": { 
     "_eq": apiKey 
    } 
    } 
}; 

request({ 
    headers: { 
    'X-Auth-Token': 'abc' 
    }, 
    url: requestURL, 
    'Content-Type': 'application/json;charset=utf-8;', 
    method: 'GET', 
}, function(error, response, body) { 
    if (error) { 
    console.log(error); 
    } else { 
    var json = JSON.parse(body); 
    var teamArray = json.teams; 
    var newObject; 

    account.instance('instance').class('competition').dataobject().list(filter) 
    .then(function(compRes) { 

     var competitionID = compRes.objects[0].id; 
     for (var i = 0; i < teamArray.length; i++) { 
      newObject = { 
      "name": teamArray[i].name, 
      "nameshort": teamArray[i].code, 
      "logo": teamArray[i].crestUrl, 
      "competition": competitionID 
      }; 

      (account.instance('instance').class('teams').dataobject().add(newObject).then(function(res) { 
       console.log(res); 
      }).catch(function(err) { 
       console.log("Error eq: " + err); 
      }) 
     ); 
     } 
     }).catch(function(err) { 
     console.log(err); 
     }); 
    } 
}); 

Answer 1

समस्या हो सकती है आप अनुरोध प्रक्रिया खत्म कर रहे हैं से पहले सभी को बचाने के कॉल किया जाता है, तो आप Promise.all() की कोशिश कर सकते:

account.instance('instance').class('competition').dataobject().list(filter) 
    .then(function(compRes) { 

     var competitionID = compRes.objects[0].id, promises=[]; 
     for (var i = 0; i < teamArray.length; i++) { 
      newObject = { 
      "name": teamArray[i].name, 
      "nameshort": teamArray[i].code, 
      "logo": teamArray[i].crestUrl, 
      "competition": competitionID 
      }; 
      promises.push(account.instance('instance').class('teams').dataobject().add(newObject).then(function(res) { 
       console.log(res); 
      }).catch(function(err) { 
       console.log("Error eq: " + err); 
      }) 
     ); 
     } 
     return Promise.all(promises); 
     }).catch(function(err) { 
     console.log(err); 
     }); 

अगर एक बार में भी कई समानांतर कॉल मुद्दा है तो एक के बाद एक कॉल श्रृंखला:

account.instance('instance').class('competition').dataobject().list(filter) 
    .then(function(compRes) { 

     var competitionID = compRes.objects[0].id, promise = Promise.resolve(); 
     function chainToPromise(promise, teamObj, waitTime){ 
      waitTime = waitTime || 500; 
      return promise.then(function(){ 
      return new Promise(function(resolve, reject){ 
       setTimeout(resolve, waitTime); 
      }); 
      }).then(function(){ 
      return account.instance('instance').class('teams').dataobject().add(teamObj); 
      }).then(function(res) { 
      console.log(res); 
      }).catch(function(err) { 
      console.log("Error eq: " + err); 
      }); 
     } 
     for (var i = 0; i < teamArray.length; i++) { 
      newObject = { 
      "name": teamArray[i].name, 
      "nameshort": teamArray[i].code, 
      "logo": teamArray[i].crestUrl, 
      "competition": competitionID 
      }; 
      promise = chainToPromise(promise, newObject); 
     } 
     return promise; 
     }).catch(function(err) { 
     console.log(err); 
     });