Girders Blog How Queuing with Resque works
Resque is a fast, lightweight, and powerful message queuing system used to run Ruby jobs asynchronously (or in the background) from your on-line software for scalability and response. I needed to integrate software written in different languages and environments for processing, and this is my understanding of the implementation. How Queuing with Redis works Resque’s real power comes with the Redis
perform ã®å¼•æ•°ã‚’ç ´å£Šçš„ã«å¤‰æ›´ã—ã¦ã„る㨠resque-retry ã®æŒ™å‹•ãŒãŠã‹ã—ã„ - milk1000cc
Resque ã®ãƒ—ラグインã§ã€Delayed::Job ã®ã‚ˆã†ã«è‡ªå‹•ãƒªãƒˆãƒ©ã‚¤ã‚’ã—ã¦ãれる resque-retry ã¨ã„ã†ã‚‚ã®ãŒã‚ã‚Šã¾ã™ã€‚ã§ã€ Resque::Failure::MultipleWithRetrySuppression.classes = [Resque::Failure::Redis] Resque::Failure.backend = Resque::Failure::MultipleWithRetrySuppression ã®ã‚ˆã†ã«ã—ã¦ãŠã‘ã°ã€ãƒªãƒˆãƒ©ã‚¤å¯èƒ½ãªé–“ã¯ã€ä¾‹å¤–ãŒç™ºç”Ÿã—ã¦ã‚‚ failed queue ã«å…¥ã‚‰ãªã„ã¯ãšãªã®ã§ã™ãŒã€ãªãœã‹å…¥ã£ã¦ã„ãŸã®ã§èª¿ã¹ã¾ã—ãŸã€‚ å‰æ 2012/5/16 ç¾åœ¨ã® resque 最新ãƒãƒ¼ã‚¸ãƒ§ãƒ³ 1.20.0 ã¯ã€resque-retry 0.2.2 ã¨ç›¸æ€§ãŒæ‚ªã„ã®ã§ã€resque-retry ã®ãƒãƒ¼ã‚¸ãƒ§ãƒ³ã‚’ 1.0.0.a ã«ã—ã¦ãŠã
GitHub製Resqueを使用ã—ãŸRubyã§ã®ãƒãƒƒã‚¯ã‚°ãƒ©ã‚¦ãƒ³ãƒ‰å‡¦ç†(ãƒãƒƒãƒå‡¦ç†) - Masatomo Nakano Blog - Web開発を極ã‚ã‚‹
ãã“ãã“ã®è¦æ¨¡ã®Webシステムã«ãªã£ã¦ãã‚‹ã¨ãƒãƒƒã‚¯ã‚°ãƒ©ãƒ³ãƒ‰å‡¦ç†(batch処ç†)ã¯æ¬ ã‹ã›ãªã„ã‚‚ã®ã«ãªã£ã¦ãる。メールã®é€ä¿¡ã€ãƒ‡ãƒ¼ã‚¿ã®æ—¥æ¬¡ã€æœˆæ¬¡ã€å¹´æ¬¡å‡¦ç†ã€å‰Šé™¤(フラグ)データã®purgeã‚„ãƒãƒƒã‚¯ã‚¢ãƒƒãƒ—ã€ç‰ã€…ã„ã‚ã„ã‚ãªç‰©ãŒå‡ºã¦ãる。 ç¾åœ¨ã¯BackgrounDRbを使ã£ã¦ã„ã‚‹ãŒã€ã„ã‚ã„ã‚ã¨ã„ã¾ã„ã¡ãªã®ã§ä»Šå›žResqueを評価ã—ã¦ã¿ãŸã€‚ã¡ã‚‡ã£ã¨è§¦ã£ãŸæ®µéšŽã§ã®ç¬¬ä¸€å°è±¡ã‚’メモ。 ã¾ãšã€ãƒãƒƒãƒå‡¦ç†ç³»ã§è©•ä¾¡ã®ãƒã‚¤ãƒ³ãƒˆã«ãªã£ã¦ãる部分ã¯ãªã‚“ã ã‚ã†ã‹ã¨è€ƒãˆã¦ã¿ã‚‹ã¨ã€ãªã‚“ã¨è¨€ã£ã¦ã‚‚見通ã—ã®ã‚ˆã•ã¨ç•°å¸¸ç³»ã®å‡¦ç†ã ã¨æ€ã†ã€‚ç”»é¢ç³»ã¨é•ã„ã€ãƒãƒƒãƒå‡¦ç†ã¯ã€Œè¦‹ãˆã«ãã„ã€ã¨ã“ã‚ã§å®Ÿè¡Œã•ã‚Œã‚‹ã®ã§ã€ãã®äºŒã¤ãŒç‰¹ã«å¤§äº‹ã«ãªã£ã¦ãる。「知らãªã„ã†ã¡ã«æ¢ã¾ã£ã¦ã„ã¾ã—ãŸã€ã§ã¯å›°ã‚‹ã®ãŒãƒãƒƒãƒå‡¦ç†ã€‚ ãŸã¨ãˆã°ã€ 異常時ã®å‡¦ç†ç„¡è¦–?管ç†è€…ã«é€šçŸ¥?リトライ? 復旧処ç†ã‚¿ã‚¹ã‚¯ã®å‰Šé™¤(å•é¡Œã‚’修復後)リトライ 状態ã®ç›£è¦–ã„ãã¤ã®JobãŒæ®‹ã£ã¦ã„ã‚‹ã‹
Resqueã§è‰²ã€…ã‚„ã£ã¦ã€Redisã«ä½•ãŒæ ¼ç´ã•ã‚Œã¦ã„ã‚‹ã®ã‹èª¿ã¹ã¦ã¿ãŸ - kitak blog
ã“ã‚“ã«ã¡ã¯ã€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
Pros and Cons of Redis-Resque and SQS
As with any system or application, there are upsides and downsides to using them. The two queueing systems that I want to explore are Resque and Amazon’s Simple Queuing Service. Resque is essentially a set of queuing APIs that run on Redis. Redis is an in-memory data store and is what actually handles the queues. It’s capable of handling complex data structures like lists (what Resque queues use),
1
リリースã€éšœå®³æƒ…å ±ãªã©ã®ã‚µãƒ¼ãƒ“スã®ãŠçŸ¥ã‚‰ã›
最新ã®äººæ°—エントリーã®é…ä¿¡
j次ã®ãƒ–ックマーク
kå‰ã®ãƒ–ックマーク
lã‚ã¨ã§èªã‚€
eコメント一覧を開ã
oページを開ã
Programmatically get the number of jobs in a Resque queue
{{#tags}}- {{label}}
{{/tags}}