如何在NodeJS中使用承诺链接Postgres查询和GET请求

How to chain Postgres query and then GET requests in NodeJS using promises

本文关键字:Postgres 链接 查询 请求 GET 承诺 NodeJS      更新时间:2023-09-26

在我的NodeJS应用程序中,我需要对Postgres进行查询,然后我需要对PG结果中的每一行进行GET请求。并以数组形式返回所有GET结果。

我的代码有什么问题?

var promise = require('bluebird');
var pgp = require('pg-promise')({ promiseLib: promise });
var db = pgp(connectionString);
var rp = require('request-promise');
var query = 'select id from my_table';
var processIDs = pgResults => {
    var requests = pgResults.map( row => rp(`mysite.com/${row.id}`) );
    return promise.all(requests);
}
db.any(query)
  .then(processIDs)
  .then( results => console.log(results) );

第二个问题,如何在最终结果数组中包含PG查询的id ?

在最终结果中包含PG查询id的一种方法是在processIDs调用中有另一个承诺,如:

var processIDs = (result) => {
    var ids = result.map(row => row.id);
    var requests = ids.map(id => request(`mysite.com/${id}`));
    return promise.all(requests)
        .then(results => {
            // not sure how u want to include `ids` in results, but its available in this scope
            // just think that it's weird, cuz `results` is supposed to be
            // an array of HTTP responses, right?
            return results; // results.concat(ids) || results.push(ids)
        });
}