Empresas
Empleos
  • Sobre nosotros
  • Soluciones
    • Publicación de vacantes
      Publica tu vacante y recibe candidatos calificados en 48h.
    • Evaluación de candidatos
      500+ pruebas técnicas y psicológicas, más anti-fraude.
    • Headhunting
      Búsqueda ejecutiva a la medida de principio a fin.
    • Nómina + EOR
      Dispersión de nómina y EOR en más de 15 países de LATAM.
  • Precios
  • Empleos

0

192
Vistas
Consulta el clúster de corrimiento al rojo usando NodeJs de forma asíncrona

Mi tarea es copiar algunas tablas de corrimiento al rojo del grupo uno a un grupo nuevo. Para esto estoy escribiendo un script en nodejs. Estoy usando aws-sdk RedshiftData api para obtener los datos. Tengo dos consultas separadas que quiero ejecutar en paralelo. El siguiente es mi código

 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; } }

El problema es que mi código nunca llega al registro de "promesa resuelta". Si coloco un registro en la devolución de llamada de getStatementResult de corrimiento al rojo, eso se está imprimiendo correctamente, pero mi identificador nunca llega a la declaración de promise.all().then que no puedo entender por qué.

Otra pregunta que tenía en mente era si es una buena práctica usar un patrón de este tipo dentro de una clase.

over 4 years ago · Santiago Trujillo
1 Respuestas
Responde la pregunta

0

No resolviste o rechazaste tu promesa dentro de la clase.

Ejemplo a continuación

 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); } } }
over 4 years ago · Santiago Trujillo Denunciar
Responde la pregunta
Encuentra empleos remotos

¡Descubre la nueva forma de encontrar empleo!

Top de empleos
Top categorías de empleo
Empresas
Publicar vacante Precios Comercial
Legal
Términos y condiciones Política de privacidad
© 2026 PeakU Inc. All Rights Reserved.
Andres GPT
Recomiéndame algunas ofertas
Necesito ayuda