resque_retry.rb 0sH �U 9 �U # inspired by http://ariejan.net/2010/08/23/resque-how-to-requeue-failed-jobs # retry all failed Resque jobs except the ones that have already been retried # This is, for instance, useful if you have already retried some jobs via the web interface. Resque::Failure.count.times do |i| Resque::Failure.requeue(i) unless Resque::Failure.all(i, 1)['retried_at'].present? end
Resque (pronounced like "rescue") is a Redis-backed library for creating background jobs, placing those jobs on multiple queues, and processing them later. For the backstory, philosophy, and history of Resque's beginnings, please see the blog post (2009). Background jobs can be any Ruby class or module that responds to perform. Your existing classes can easily be converted to background jobs or yo
こんにちは、Go! Go! Heaven が頭から抜けないきたけーです。 最近、仕事や趣味でResqueをよく触っています。バックグラウンド処理をおこなう便利なライブラリなんですけど、「◯◯なときって何が起こるの?」と疑問に思うことが多かったので色々なケースでRedisに格納されている値を調べてみました。 ワーカのサンプル 今回はRailsプロジェクトの中に以下のような単純なワーカを用意しました。 class HogeWorker @queue = name class << self def perform(message) sleep 10 puts message end def perform_async(message) Resque.enqueue(self, message) end end end 起動するときは、 bundle exec rake resque:work
FlexやRuby on Railsなどで使い方とかを自分が後でわかるようにメモしておくブログ。最近はFlex系に飽きてます。 カテゴリ: Rails Resqueでのhookの使い方 Resqueを使う上で、enqueueする前に何かしたいなーやpeformされる前に何かしたいなーということはないでしょうか? プラグインも豊富にあるので、それを導入しても良いですが、ちょっとしたものであれば自分で書いてしまうのも手かも知れません。 今回は、久しぶりに役立つ(?)記事をちょろちょろっと 環境 Rails 3.2.11 Resque 1.23.0 Redis 2.6.7 様々なHookメソッド Resqueは容易なプラグイン開発をサポートするために 各種hookメソッドもサポートしています。 before_enqueue ... Enqueueされる前に実行される after_enqueue
This article was contributed by Abhinav Keswani Abhinav heads up the Bespoke Solutions team at Trineo, a boutique software development shop based in New Zealand and Australia. After way too many years wrangling the vagrancies of massive public facing web infrastructure, Abhinav and the Trineo team focus on developing applications that use modern cloud technology. Trineo are listed Heroku Dev Partn
class Archive @queue = :file_serve def self.perform(repo_id, branch = 'master') repo = Repository.find(repo_id) repo.create_archive(branch) end end ジョブは perform に応答可能(job.respond_to?(:perform) == true)な Ruby のオブジェクト インスタンス変数 @queue はジョブが置かれるキューを示す キューは不定で on the fly に作成できる class Repository def async_create_archive(branch) Resque.enqueue(Archive, self.id, branch) end end ジョブは Resque.enqueue でキューに置か
平素よりQA@ITをご利用いただき、誠にありがとうございます。 QA@ITは「質問や回答を『共有』し『編集』していくことでベストなQAを蓄積できる、ITエンジニアのための問題解決コミュニティー」として約7年間運営をしてきました。これまでサービスを続けることができたのは、QA@ITのコンセプトに共感をいただき、適切な質問や回答をお寄せいただいた皆さまのご支援があったからこそと考えております。重ねて御礼申し上げます。 しかしながら、エンジニアの情報入手方法の多様化やQAサービス市場の状況、@ITの今後のメディア運営方針などを検討した結果、2020年2月28日(金)15:00をもちましてQA@ITのサービスを終了することにしました。 これまでご利用をいただきました皆さまには残念なお知らせとなり、誠に心苦しく思っております。何とぞ、ご理解をいただけますと幸いです。 QA@ITの7年間で皆さまの知識
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
処理を実行中です
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く