неблокирующий ввод-вывод в рубинах на рельсах

Question

Мои отчеты о создании приложений основаны на данных, собранных из внешних API, что может занять несколько минут. Естественно, я не хочу блокировать рабочий процесс. Возможно ли отправить сбор данных на задний план и позволить пользователю работать с приложением дальше? Также будет хорошо отображать состояние задания с помощью SSE или WebSockets.

Answer 1

Обычно вы бы направить фоновое задание на к Resque или другой фоновой очереди заданий, и ваш работник выполняет задания из очереди.

Это выглядит следующим образом:

class ReportGenerationJob 
    # ... 

    def work 
    # do expensive operations here 
    end 
end 

r = Resque.new 
r << ReportGenerationJob.new(...) # Not a blocking operation! 

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