使用 NodeJs 异步查询 redshift 集群

Question

我的任务是将几个红移表从集群一复制到新集群。为此，我在 nodejs 中编写了一个脚本。我正在使用 aws-sdk RedshiftData api 来获取数据。我有两个单独的查询，我想运行并行。以下是我的代码

class syncRedShiftNodes {
    
    constructor(){ ... }
    
    readDataOne(){
        let newSqlQuery = `select * from ${this.tableName} limit 10`;
        const params = {
          ClusterIdentifier: clusterIdentifier,
          Sql: newSqlQuery,
          Database: database,
          DbUser: dbUser
      };
      return new Promise((resolve, reject)=>{
        return awsRedshift.executeStatement(params, function(err, res){
                if (err) console.log(err, err.stack); // an error occurred
                else{
                    return awsRedshift.getStatementResult({Id:res.Id}, function(error, data){
                        if (error) console.log(error, error.stack); // an error occurred
                        else  return data;
                    });
                }
            });
      });
    }

   readDataTwo(){ ...//identical to above function except the query }

   main(){
       return Promise.all([this.readDataOne(), this.readDataTwo()])
         .spread((data1, data2)=>{
            console.log("promise resolved!!");
            return true;
   }
}

问题是我的代码从未到达“承诺已解决”日志。如果我在 redshift getStatementResult 的回调中放置一个日志，它被正确打印但我的句柄永远不会到达 promise.all().then 语句，我无法理解为什么会这样。

我想到的另一个问题是在 class 中使用这样的模式是否是一个好习惯？

Answer 1

您没有在 class 内解决或拒绝您的承诺。

示例如下

class syncRedShiftNodes {
  constructor() {}

  readDataOne() {
    let newSqlQuery = `select * from ${this.tableName} limit 10`;
    const params = {
      ClusterIdentifier: clusterIdentifier,
      Sql: newSqlQuery,
      Database: database,
      DbUser: dbUser,
    };
    return new Promise((resolve, reject) => {
      awsRedshift.executeStatement(params, function (err, res) {
        if (err) {
          console.log(err, err.stack);
          reject(err);
        } else {
          awsRedshift.getStatementResult(
            { Id: res.Id },
            function (error, data) {
              if (error) {
                console.log(error, error.stack);
                reject(error);
              } else {
                resolve(data);
              }
            }
          );
        }
      });
    });
  }

  readDataTwo() {}

  async main() {
    try {
      const result = await Promise.all([
        this.readDataOne(),
        this.readDataTwo(),
      ]);
      return result;
    } catch (err) {
      console.log(err);
    }
  }
}

使用 NodeJs 异步查询 redshift 集群

Query redshift cluster using NodeJs asynchronously

asynchronous

amazon-web-services

node.js

promise

amazon-redshift