Возможно ли выполнение строковых/очередей Ruby-действий?

Question

Я написал несколько действий в приложении RoR, которые выполняют разные действия в процессе.

E.g. - Одно действие связывается со сторонней службой, используя их API и собирает данные. - Другой обрабатывает эти данные и помещает их в соответствующую базу данных. - Другой принимает эти новые данные и форматирует их определенным образом. и т. Д.

Я хотел бы отключить процесс с временными интервалами, например. Каждый час. Но я не хочу делать все это каждый раз.

Иногда я могу просто сделать первые два действия. В других случаях я мог бы выполнять каждую часть процесса.

Итак, выполните одно действие, а затем, когда оно будет завершено, вызовите другое действие. ETC ..

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

Что было бы лучшим способом достичь этого?

Answer 1

У вас есть довольно много вариантов для обработки заданий в фоновом режиме:

• Sidekiq: http://mperham.github.io/sidekiq/
• Queue Classic: https://github.com/ryandotsmith/queue_classic
• Задержка работы: https://github.com/collectiveidea/delayed_job
• Resque: https://github.com/resque/resque

Просто прочитайте и выберите тот, который кажется чтобы соответствовать вашим критериям наилучшим образом.

EDIT Как вы уточнили, вы хотите регулярно планировать задачи. Заводной является большим драгоценным камнем для этого (и в целом лучше, чем варианта хрон):

• https://github.com/tomykaira/clockwork

Answer 2

Если вы ищете хорошее решение ванили, что-то вроде этого должно вам начать

Generic класс с методами

class Api 
    def a 
    puts "a" 
    end 

    def b 
    puts "b" 
    end 

    def c *args 
    puts args.inspect 
    end 
end 

class Queue 

    def initialize delay 
    @queue = [] 
    @delay = delay 
    end 

    def add &block 
    @queue << block 
    end 

    def run 
    block = @queue.shift 
    block.call() if block 
    sleep @delay 
    run 
    end 
end 

Пример использования

api = Api.new 
q = Queue.new 5 

q.add { api.a } 
q.add { api.b } 
q.add { api.c 1, 2, 3 } 
q.run 

Выход

a 
b 
[1, 2, 3]