Qiita Teams that are logged in
You are not logged in to any team

Log in to Qiita Team
Community
OrganizationAdvent CalendarQiitadon (β)
Service
Qiita JobsQiita ZineQiita Blog
0
Help us understand the problem. What is going on with this article?
@YumaInaura

Ruby の shoryuken gem は AWS SQS のリトライ処理をどうやって実現しているのか? ( Rails ActiveJob の例 ) #AWS #Rails

More than 1 year has passed since last update.

shoryukenはAWS SQS の可視性タイムアウトの仕組みを使ってリトライを実現していそうな気がした。
https://github.com/phstc/shoryuken/blob/master/lib/shoryuken/middleware/server/exponential_backoff_retry.rb#L54

 sqs_msg.change_visibility(visibility_timeout: next_visibility_timeout(interval.to_i, started_at))

AWS SQSではキュー単位ではなく、メッセージ単位での可視性タイムアウト指定というのが出来て。この仕組を使ってるのかな。

複数メッセージの可視性タイムアウトを設定する (例: メッセージごとに異なるタイムアウト値を設定する) には、ArrayList を作成して、可視性タイムアウト (秒) を設定したメッセージを追加し、メッセージのキュー URL および ArrayList を渡します。

そうすると ActiveJobで retry を書いておけば shoryuken がその仕組みを使ってくれるため、特にAWS SQS のキュー設定を意識する必要はない気がした。

むしろAWS SQSの仕組みにのっとらない形でリトライを実現していたらびっくりするし、使い物にならないはずだよね。

class ShoryukenExampleRetryJob < ApplicationJob
  queue_as :default

  class SomeJobError < StandardError; end

  retry_on SomeJobError, wait: 3.seconds, attempts: 3 do |job, exception|
    # リトライが全て失敗した時の処理をここに書く
    puts "SURRENDER!"
  end

  def perform(message)
    puts "PERFORM! #{message}"
    raise
  rescue
    raise SomeJobError.new('Watch out!')
  end
end

Original by Github issue

0
Help us understand the problem. What is going on with this article?
Why not register and get more from Qiita?
  1. We will deliver articles that match you
    By following users and tags, you can catch up information on technical fields that you are interested in as a whole
  2. you can read useful information later efficiently
    By "stocking" the articles you like, you can search right away
YumaInaura
Ruby on Rails 業務経験 約5年 / Perl PHP Python Golang Linux Apache MySQL BigQuery Jenkins ansible AWS など / いなうらゆうま / YumaInaura / 稲浦悠馬

Comments

No comments
Sign up for free and join this conversation.
Sign Up
If you already have a Qiita account Login
0
Help us understand the problem. What is going on with this article?