Рубиновый длительный процесс, реагирующий на события очереди

Question

У меня есть приложение rails 3, которое записывает определенные события в очередь.

Теперь на сервере я хочу создать службу, которая опрашивает очередь каждые x секунд и выполняет другие задачи по расписанию.

Кроме создания сценария ruby ​​и запуска его через задание cron, существуют ли другие альтернативы, которые стабильны?

Answer 1

Несмотря на то, что вариант постоянной задачи на основе Rails является опцией, вы можете рассмотреть более упорядоченные системы, такие как delayed_job или Starling для управления рабочей нагрузкой.1006 * Я бы посоветовал не запускать что-либо в cron, поскольку затраты на раскрутку целого стека Rails могут быть значительными.Запускать его каждые несколько секунд нецелесообразно, так как время разгона на Rails обычно составляет 5-15 секунд в зависимости от вашего оборудования.Делать это несколько раз в день, как правило, нет ничего сложного.

Простая альтернатива - создать рабочий цикл в скрипте, который вы можете использовать с runner:

interval = 15.minutes
next_time = Time.now + interval

while (true)
  if (stuff_to_do?)
    do_stuff
  end

  # Figure out how much time is left before the next iteration
  delay = next_time.to_i - Time.now.to_i

  if (delay > 0)
     # If ahead of schedule, take a break
    sleep(delay)
  end
end

Недостатком этого является то, что стек Rails будет оставаться в памяти до тех пор, пока выполняется этот фоновый процесс, но это компромисс между огромными обращениями к процессору и обращением к памяти.

Answer 2

У вас есть несколько вариантов для этого, включая DelayedJob и Resque .

Resque использует Redis и является решением, которым я пользуюсь все время (и я очень доволен).

Answer 3

Я бы порекомендовал Railscast Райана Бейтса на эту тему, в которой говорится о бобовом стебле и обертке сталкера:

http://railscasts.com/episodes/243-beanstalkd-and-stalker

Answer 4

@ Blankman, вы должны проверить http://www.simpleworker.com, это сделано для таких вещей и снимает с вас бремя запуска / планирования / мониторинга ваших процессов.И это очень стабильно.

Answer 5

Чтобы добавить сюда новые возможности, использование более сложной системы очередей, такой как AMQP (RabbitMQ), стало проще благодаря жемчужине minion. Похож на beanstalkd:

https://github.com/orionz/minion