Проблема с попыткой запуска синхронных запросов REST в узле

Question

Прежде всего, я не испытываю асинхронного программирования, так что извините, если я пропустил что-то очевидное.

Я вижу этот вопрос много. Я знаю, что людям не нравится форсировать синхронность в Javascript, но это необходимо в этом случае. Я делаю громкие звонки в производственную базу данных, которая не может занять слишком много нагрузки из-за того, как часто она используется. Из-за этого я настраиваю свой код в цикле, чтобы сделать запрос, дождаться подтверждения, что он закончен, спать в течение 2 секунд и затем сделать следующий запрос. Это связано с тем, что я собираюсь получать много данных с этого сервера еженедельно в течение примерно 10-20 минут.

Вот код, который у меня есть. Сон - это функция, которая заставляет программу ждать с использованием класса Date.

var thread = function(cb){ 
     cb(); 

    }; 


    do{ 

     var x = thread(function(){ 
      request.post(options, function(e, r, body){ 
       console.log(e); 
       console.log(r.statusCode); 
       issues.push(body["issues"]); 
       maxResults = body["total"]; 
       options.body.startAt += 25; 
       console.log("Going to sleep"); 

      }); 
      sleep(2000); 
     }); 
     console.log("Waking up and moving to the next cycle"); 

    }while(issues.length < maxResults); 
    console.log("Finished with the requests"); 
} 

хотя у меня есть функция обратного вызова, мой код по-прежнему запускает запросы асинхронно. Поскольку я оставляю maxResults null, очевидно, что мой обратный вызов не работает. Это мой вывод:

Waking up and moving to the next cycle 
Finished with the requests 
Going to sleep 

Answer 1

Вам необходимо сделать рекурсивную асинхронную функцию.

Это будет выглядеть примерно так:

function fetch(existingIssues) { 
    return sendRequest().then(function() { 
     existingIssues.push(...); 
     if (existingIssues.length >= maxResults) 
      return existingIssues; 
     else 
      return fetch(existingIssues); 
    }); 
} 
fetch([]).then(...);