Задачи очереди в узле

Question

Я создаю приложение-узел, которое будет действовать как «рабочий», чтобы выложить новое приложение, а затем загрузить приложение в AWS. Есть пять задач, которые завершают цикл эшафота.

Я хотел бы знать, возможно ли в Node/Express отправлять очереди входящих запросов, а затем запускать цикл эшафота для запросов в очереди, когда цикл успешно завершен. Одновременно должен выполняться только один цикл эшафота.

Answer 1

Да, вы можете это сделать. Возможно, ваш текущий код выглядит примерно так (я предполагаю, что вы используете обещания):

app.get('/', function (req, res) { 
    scaffold().then(function() { 
    res.send('done'); 
    }); 
}); 

Мы будем использовать promise-queue упростить вещи. Сначала нам нужно создать очередь:

var queue = new Queue(1); 

Аргумент - количество элементов, которые очередь будет запускаться одновременно. Поскольку вы не хотите параллелизма, мы используем 1. Теперь мы должны перейти в обещании завода вместо выполнения обещания:

app.get('/', function (req, res) { 
    queue.add(function() { 
    return scaffold().then(function() { 
     res.send('done'); 
    }); 
    }); 
}); 

Если мы только что прошли в обещании, это будет начать немедленно. Вот почему мы должны передать функцию, которая возвращает обещание.

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

app.get('/', function (req, res) { 
    queue.add(scaffold); 
    res.send('done'); 
}); 

Answer 2

Попробуйте использовать вилку на входящей события:

http://nodejs.org/api/child_process.html

На каждого ребенка получить один за другим все элементы, необходимые brefore обработки леса и загрузку в AWS.

Answer 3

Это не «строго node.js» ответ, но я настоятельно рекомендую смотреть в Beanstalkd как способ решения этой проблемы (с использованием fivebeans как nodejs библиотеки).

Поместите каждую задачу в именованную очередь заданий, вытащите новое задание, когда будете готовы к работе над ней, и поставьте следующий шаг в следующую очередь, когда она будет готова. Мы используем это в производстве для выполнения сложной серии шагов транскодирования каждый раз, когда загружается новое видео, где каждый шаг зависит от одного или нескольких предыдущих шагов, которые были завершены.