6

私は Syncano をバスとして使用しています。ここで、外部 API を呼び出して JSON 配列を受信しようとしています。この JSON を解析し、後で syncano に保存する必要があります。その前に、DB から参照オブジェクトを受け取り、それを新しいチーム オブジェクトにリンクする必要があります。

チーム (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);
      });
  }
});
4

1 に答える 1

4

問題は、すべての保存呼び出しが行われる前にリクエスト プロセスを終了している可能性があるため、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);
      });
于 2016-02-23T01:18:26.437 に答える