使用 for 循环和 pg-bluebird

Question

如何使用 pg-bluebird (https://github.com/aphel-bilisim-hizmetleri/pg-bluebird) 合并 for 循环？

我想先获取每个位置的 ID、纬度和经度（来自位置 table）。然后对于每个位置我需要做一个 http 请求（这是我想要 for 循环的地方）。然后在我完成请求后，收到的数据应该插入 table Aeris。

我是 node.js 的新手，刚开始学习 promises。我是否按预期使用了 pg-bluebird？

这是我目前的情况：

var request = require("request");
var Pgb = require("pg-bluebird");

exports.retrieve = function(){

  var pgb = new Pgb();

  var cnn;

  pgb.connect(DB_URL)
  .then(function (connection) {

    cnn = connection;
    var queryString = 'SELECT id, latitude, longitude FROM locations';

    return cnn.client.query(queryString);
 })
 .then(function (result) {

    console.log(result.rows);

    //this needs to run for each location 
    //this needs to access result.rows[0].id then 
    //result.rows[1].id and so on
    location_id = result.rows.id; 

    lat = result.rows.latitude;
    lng = result.rows.longitude;
    console.log("Lat=" + lat + " Lng=" + lng);
    var aerisUrl = AERIS_URL+
        "?p="+lat+","+lng+
        "&radius=10miles"+
        "&client_id="+CLIENT_ID+
        "&client_secret="+CLIENT_SECRET;

    request.get(aerisUrl,function(err,response,body){

        //do something with request data
    });

    return cnn.client.query();

})
.then(function (result, aerisResults) {
        //insert data in aeris table
        return cnn.client.query(queryString);
})
.then(function (result){

    console.log(result.rows);

    cnn.done();
})
.catch(function (error) {

      console.log(error);
});

Answer 1

首先，使用pg-promise与数据库进行通信。其次，您需要将您的 http 请求逻辑分离到一个 return 承诺的函数中，这样您就可以将所有此类请求堆叠到一个数组中，然后通过 promise.all 执行。所有这些都显示在下面的代码中。

var request = require("request");
var promise = require("bluebird");
var pgp = require("pg-promise")({promiseLib: promise});

var db = pgp(DB_URL);

function createRequest(r) {

    var aerisUrl = AERIS_URL +
        "?p=" + r.latitude + "," + r.longitude +
        "&radius=10miles" +
        "&client_id=" + CLIENT_ID +
        "&client_secret=" + CLIENT_SECRET;

    return new promise.Promise(function (resolve, reject) {
        request.get(aerisUrl, function (err, response, body) {
            // do something with the request data and
            // then call either resolve(), if successful,
            // or reject(), if failed;
        });
    });
}

db.query("SELECT id, latitude, longitude FROM locations")
    .then(function (rows) {
        var req = rows.map(function (r) {
            return createRequest(r);
        });
        return promise.all(req);
    })
    .then(function (data) {
        // all http requests resolved successfully,
        // time to insert the data into table Aeris:
        return db.query("insert into Aeris(fields) values(, ,...)", [/*values*/]);
    })
    .then(function () {
        // successfully inserted data into table Aeris;

        // all done!
    })
    .catch(function (error) {
        // Ops, something failed;
        console.log("ERROR:", error);
    });

使用 for 循环和 pg​​-bluebird

Using for loops and pg-bluebird

node.js

bluebird

pg

使用 for 循环和 pg-bluebird