1

更新 2

完整的代码清单

var request = require('request');
var cache = require('memory-cache');
var async = require('async');

var server = '172.16.221.190'
var user = 'admin'
var password ='Passw0rd'
var dn ='\\VE\\Policy\\Objects'

var jsonpayload = {"Username": user, "Password": password}


async.waterfall([
    //Get the API Key
    function(callback){
        request.post({uri: 'http://' + server +'/sdk/authorize/',
                json: jsonpayload,
                headers: {'content_type': 'application/json'}
            }, function (e, r, body) {
            callback(null, body.APIKey);
        })
},
    //List the credential objects
    function(apikey, callback){
        var jsonpayload2 = {"ObjectDN": dn, "Recursive": true}
        request.post({uri: 'http://' + server +'/sdk/Config/enumerate?apikey=' + apikey,
                json: jsonpayload2,
                headers: {'content_type': 'application/json'}
        }, function (e, r, body) {

            var dns = [];
            for (var i = 0; i < body.Objects.length; i++) {
                dns.push({'name': body.Objects[i].Name, 'dn': body.Objects[i].DN})
            }

            callback(null, dns, apikey);
        })

    },
    function(dns, apikey, callback){
      //  console.log(dns)

        var cb = [];

        for (var i = 0; i < dns.length; i++) {

        //Retrieve the credential
        var jsonpayload3 = {"CredentialPath": dns[i].dn, "Pattern": null, "Recursive": false}
            console.log(dns[i].dn)
        request.post({uri: 'http://' + server +'/sdk/credentials/retrieve?apikey=' + apikey,
            json: jsonpayload3,
            headers: {'content_type': 'application/json'}
        }, function (e, r, body) {
         //   console.log(body)
            cb.push({'cl': body.Classname})
            callback(null, cb, apikey);
            console.log(cb)
        });
        }


    }
], function (err, result) {
//    console.log(result)
    // result now equals 'done'
});

更新：

我正在构建一个小型应用程序，该应用程序需要对外部 API 进行多次 HTTP 调用，并将结果合并到单个对象或数组中。例如

  1. 连接到端点并获取身份验证密钥 - 将身份验证密钥传递到第 2 步
  2. 使用 auth key 连接到端点并获取 JSON 结果 - 创建一个包含摘要结果的对象并传递到步骤 3。
  3. 遍历传递的对象汇总结果，并为对象中的每个项目调用 API 以获取每个汇总行的详细信息
  4. 创建包含摘要和详细信息的单个 JSON 数据结构。

下面的原始问题概述了我到目前为止所尝试的内容！

原始问题：

async.waterfall 方法是否支持多个回调？

即迭代从链中的前一个项目传递的数组，然后调用多个http 请求，每个请求都有自己的回调。

例如，

sync.waterfall([

   function(dns, key, callback){

       var cb = [];

       for (var i = 0; i < dns.length; i++) {

       //Retrieve the credential
       var jsonpayload3 = {"Cred": dns[i].DN, "Pattern": null, "Recursive": false}
           console.log(dns[i].DN)
       request.post({uri: 'http://' + vedserver +'/api/cred/retrieve?apikey=' + key,
           json: jsonpayload3,
           headers: {'content_type': 'application/json'}
       }, function (e, r, body) {
           console.log(body)
           cb.push({'cl': body.Classname})
           callback(null, cb, key);

       });
       }


   }
4

1 回答 1

2

希望我正确理解了您的问题。在我看来，您想为每个项目调用 api，dns并且需要知道它们何时完成。async.waterfall 通常在您有一个使用前一个函数的结果的函数链时使用。在您的情况下，我只能看到您需要在一个回调中使用所有 api 调用的结果。而且由于您还想创建一个新数组，因此我将使用 async.map。

更新：

如果你想在 async.waterfall 中创建一个循环，async.each/map 是首选的武器。下面的代码将在调用每个 dns 时调用瀑布回调。

async.waterfall([
  // ...,
  function(dns, apikey, callback){
    async.map(dns, function (item, next) {
      var jsonpayload3 = {
        Cred: dns[i].DN,
        Pattern: null,
        Recursive: false
      };

      request.post({
        uri: 'http://' + vedserver +'/api/cred/retrieve?apikey=' + key,
        json: jsonpayload3,
        headers: {'content_type': 'application/json'}
      }, function (e, r, body) {
        next(e, { cl: body.Classname });
      });
    },
    callback);
  }],
  function (err, result) {
    // result now looks like [{ cl: <body.Classname> }]
  });
于 2013-06-27T09:08:09.403 回答