質問をすることでしか得られない、回答やアドバイスがある。

15分調べてもわからないことは、質問しよう!

新規登録して質問してみよう
ただいま回答率
85.37%
Heroku

HerokuはHeroku社が開発と運営を行っているPaaSの名称です。RubyやNode.js、Python、そしてJVMベース(Java、Scala、Clojureなど)の複数のプログラミング言語をサポートしている。

Redis

Redisは、オープンソースのkey-valueデータストアで、NoSQLに分類されます。すべてのデータをメモリ上に保存するため、処理が極めて高速です。

Ruby on Rails

Ruby on Railsは、オープンソースのWebアプリケーションフレームワークです。「同じことを繰り返さない」というRailsの基本理念のもと、他のフレームワークより少ないコードで簡単に開発できるよう設計されています。

Q&A

解決済

1回答

2319閲覧

Heroku x Redis x Sidekiqで送信したタスクが全部実行されません

dialbird

総合スコア379

Heroku

HerokuはHeroku社が開発と運営を行っているPaaSの名称です。RubyやNode.js、Python、そしてJVMベース(Java、Scala、Clojureなど)の複数のプログラミング言語をサポートしている。

Redis

Redisは、オープンソースのkey-valueデータストアで、NoSQLに分類されます。すべてのデータをメモリ上に保存するため、処理が極めて高速です。

Ruby on Rails

Ruby on Railsは、オープンソースのWebアプリケーションフレームワークです。「同じことを繰り返さない」というRailsの基本理念のもと、他のフレームワークより少ないコードで簡単に開発できるよう設計されています。

0グッド

0クリップ

投稿2020/02/14 02:20

Heroku上でRailsアプリを運用しているものです。
バージョンはRailsが5.2.1で、Sidekiqが6.0.4です。

workerとして「Heroku Redis」を連携しており、そちらでメール送信などを捌かせているのですが、アプリの「お知らせ通知」といった、4000人近くのユーザーにメールを送る処理を実行しようとすると、どうも一部のユーザーにはメールが届いていないようなのです

rb

1# アプリないで実際にやっている処理。(ループ数は4000くらい) 2User.where(is_news_notice_on: true).each do |user| 3 NewsMailer.published(News.last, user).deliver_later 4end

ログを確認してみたところ、下記のように、ジョブとしてキューにプッシュされた個数は、対象ユーザーの人数と一致しました。
つまり、キューにジョブを格納するところまでは正常に動いています

Enqueued ActionMailer::DeliveryJob (略) to Sidekiq(mailers) with arguments: "NewsMailer", "published", "deliver_now"

しかし下記のように、キューから取り出されたジョブ数は、プッシュされた個数よりも少なくなっていました。(800個くらい減っていた)

Performing ActionMailer::DeliveryJob (略) from Sidekiq(mailers) with arguments: "NewsMailer", "published", "deliver_now"

可能性は以下のようなものを考えたのですが、果たしてそれが現実的な結論かどうかがわかりません

  • Redis x Sidekiqによる非同期ジョブ処理は「ベストエフォート方式」のため、一気に大量のタスクが突っ込まれると失敗する確率が上がる。
  • Sidekiqは他にも「登録確認メール」などのジョブにも使っているため、それらの処理とぶつかって中断されてしまった
  • 一気に4000件近くもメールを送るための「Redisのメモリ」が足りていない。

どなたかRedis x Sidekiqの運用に詳しい方などいらっしゃいましたら、教えて欲しいです!
よろしくお願いします!

気になる質問をクリップする

クリップした質問は、後からいつでもMYページで確認できます。

またクリップした質問に回答があった際、通知やメールを受け取ることができます。

バッドをするには、ログインかつ

こちらの条件を満たす必要があります。

guest

回答1

0

ベストアンサー

Redis x Sidekiqによる非同期ジョブ処理は「ベストエフォート方式」のため、一気に大量のタスクが突っ込まれると失敗する確率が上がる。

キューに入っているのであれば、規定回数のリトライで失敗するまでリトライされるはずです

Sidekiqは他にも「登録確認メール」などのジョブにも使っているため、それらの処理とぶつかって中断されてしまった

キューに入っているのであれば、規定回数リトライが失敗するまで確実に実行されるはずです
(手動で Redis のデータを消す等しない限り

一気に4000件近くもメールを送るための「Redisのメモリ」が足りていない。

キューに入っているのであればメモリが足りないということはないかと思います。

しかし下記のように、キューから取り出されたジョブ数は、プッシュされた個数よりも少なくなっていました。(800個くらい減っていた)

キューに入っている Job が失敗すると、リトライされるためにむしろ多くなるはずかと思います。

以上踏まえて、その状況だと原因わからないのですが、 Sidekiq の Web Console で失敗やリトライに関しては stats が見られるので、その様子を見てみたい気がします

投稿2020/02/16 03:48

unhappychoice

総合スコア1531

バッドをするには、ログインかつ

こちらの条件を満たす必要があります。

dialbird

2020/02/16 05:33 編集

unhappychoiceさん 早速の返答ありがとうございます! なるほどです。 キューに入った以上、そもそもその回数以上ジョブが実行されないのはおかしな話なのですね。 実を言うとジョブの回数はSidekiq::Apiライブラリとかを使って王道で調べたわけではなくて、PaperTrailsのログで検索をかけて、その回数を追っかけているだけなのです。 情報がなかったので苦肉の策というかお恥ずかしい‥‥ ちなみにキューイングの回数は `to Sidekiq(mailers) with arguments: "HogehogeMailer", "welcome", "deliver_now"`で、ジョブ実行は `from Sidekiq(mailers) with arguments: "HogehogeMailer", "welcome", "deliver_now"`の回数で測ってました 一応Herokuの本番コンソールに入って、Sidekiq::Stats.newとかも使ってみたのですが、これをどう使ってどの様に調査に活かせばいいのかが検討がつかなくて‥‥。なにやら失敗回数とかわかる様ですが、ここからタスクの異常の発生をどうすれば抽出できるのかなど‥‥ 以下の様な情報を取得できたらおそらく解決できるとは思うのですが、 ・日付・時間指定で、その時間帯のタスクの実行状況・リトライ回数など ・失敗していた場合、何が原因で失敗したのかのメッセージ取得 私が調べたい様なstats情報を取る場合、unhappychoiceさんならどの様な手法を取られますか? 教えて頂けると幸いです!よろしくお願いいたします!
unhappychoice

2020/02/16 21:28

https://github.com/mperham/sidekiq/wiki/Monitoring にあるように、 Rails 側に Web Console を導入できるので、それでいつも見ています。 > ・日付・時間指定で、その時間帯のタスクの実行状況・リトライ回数など > ・失敗していた場合、何が原因で失敗したのかのメッセージ取得 は一応確認できるかと思いますmm
dialbird

2020/02/17 01:45

ありがとうございます! 調査してみたところ、該当する時間(もっというとその日)ではどうやらfailedは発生していない様でした‥‥ 「Sidekiqのジョブには異常はなかった」ということではあるのでしょうが、実際問題pushしたはずのJobタスクがpopされた形跡もないし、リトライされたログも出てこない‥‥(Sidekiq::Stats::History.newで、該当日のエラー数0、Sidekiq::DeadSet.newもSidekiq::RetrySet.newも0) やはりそうなるとなんらかの「オーバーフロー的な何か」でメール処理が漏れてしまった様にしか思えないのですが、可能性としては限りなく小さいのでしょうか?
unhappychoice

2020/02/17 02:24 編集

> なんらかの「オーバーフロー的な何か」でメール処理が漏れてしまった様にしか思えないのですが 何かわからない妖怪みたいなものを想定してそうなので、その可能性については多分議論できないですが、他にデバッグできる、気になるところを上げるとすれば # Redisのデータを消す(消える)ようなロジックを書いたり運用をしていないか # Redis の中身のデータを確認 # ログの集計は間違っていないのか - キューに入れたものと pop したものの探し方は同じか - push した400 件に余計なものは混じってないのか - ログの欠損は起こっていないのか # Email 周り ( Jobが正常な前提 メールが届かない、というはありふれた問題で原因として様々あるとおもいます - SPF や DKIM Sender ID - 迷惑メールフィルタリングサービス ( メールの内容でスパム認定するようなもの - Email が有効ではない - 送信しているメールサーバーがブラックリストに入っている等
dialbird

2020/02/17 06:10

感謝いたします! とりあえずこちらあげてくださったものを片っ端から試してみようと思います! 何も分からない私に知識を与えてくださり、感謝感謝です! それで分からなければまた新たに質問を立ち上げようと思います! ありがとうございました!
guest

あなたの回答

tips

太字

斜体

打ち消し線

見出し

引用テキストの挿入

コードの挿入

リンクの挿入

リストの挿入

番号リストの挿入

表の挿入

水平線の挿入

プレビュー

15分調べてもわからないことは
teratailで質問しよう!

ただいまの回答率
85.37%

質問をまとめることで
思考を整理して素早く解決

テンプレート機能で
簡単に質問をまとめる

質問する

関連した質問