2

bluebird とジェネレーターの koa を使用して、複数のリクエストを Beats API に送信しようとしています。

いくつかのドキュメントを読んだ後、私は以下がうまくいくと考えました

var request = require('co-request'),
  _ = require('lodash'),
  Promise = require('bluebird');
  request = Promise.promisifyAll(request);

module.exports.getTracks = function *tracks(){    
    firstCall = yield makeAPICall('users/' + me + '/mymusic/tracks?limit=150');
      total = firstCall.body.info.total;
      total -= 150;
      tracks = firstCall.body.data;

      //Beats only allows a maximum of 150 tracks per call
      //If more tracks are needed then the remainder is called in sets of 150
      var offset = 150;
        while (total > 0) {
          promises.push(makeAPICall('users/' + me + '/mymusic/tracks?limit=150&offset=' + offset));
          offset += 150;
          total -= 150;
        }

    var responses = yield(Promise.all(promises));
}

    function makeAPICall (query){
      var authOptions = {
        url: 'https://partner.api.beatsmusic.com/v1/api/' + query,
        headers: { 'Authorization': 'Bearer ' + accessToken },
        json: true
      };
      return request.get(authOptions);
    }

メソッド makeAPI 呼び出しは、firstCall で使用すると期待どおりに機能しますが、何らかの理由で、配列に makeAPICall メソッドを配置し始めると、実行されないように見えます。変数 response は、beats API からの応答の配列ではなく、関数の配列のみを生成します。応答が firstCall と同様のオブジェクトの配列を返すようにするには、何を変更する必要がありますか?

4

1 に答える 1

2

すでにコールバックをサンクに変換している共同リクエストを使用しているため、物事を試して約束する必要はありません。

これは、コードに似た単純化された実行可能な例であり、Koa (内部で co を使用) と並行して API 呼び出しを実行する方法を示しています。
配列を生成すると、co はサンク/プロミス/ジェネレーターなどを並行して実行します。

var request = require('co-request'),
    co      = require('co');

co(function *(){
  var results = yield getTracks();
  results.forEach(function(result){
    console.log(result.body);
  })
}).then();

function * getTracks () {
  var queries = [];
  // swap out your queries here
  queries.push(makeAPICall('5185415ba171ea3a00704eed'));
  queries.push(makeAPICall('54fdc3c9862a3aab01dc95cf'));
  queries.push(makeAPICall('54fdc3da862a3aa501dc95d0'));
  // yielding an array returns an array of results
  var results = yield queries;
  return results;
}

function makeAPICall (query) {
  var options = {
    url: 'http://www.mocky.io/v2/' + query,
    json: true
  }
  return request.get(options)
}
于 2015-03-09T16:11:28.073 に答える