私が開発しているアプリケーションには、ユーザー入力から完全に分離されたビジネス ロジックを処理するための無限ループが必要です (ユーザーはそれを表示するだけです)。これは従来の MVC からの脱却であるため、Active Job を配置するのが適していると考えました。

ループ内のロジックは、同じネットワーク上のマイクロコントローラーをポーリングします。これらのコードを変更する能力はほとんどないため、使用している独自のプロトコルに適応する必要があります。マイクロコントローラーが応答すると、サーバーはいくつかの計算を行い、データベースに保存する必要があります。

ジョブは、サーバー アプリケーションの起動時に起動されます。そのインスタンスは 1 つだけ存在する必要があるため、モデルやコントローラーに入れたくありません。config フォルダーのいくつかの場所から起動しようとしましたが、初期化された定数 NameError が発生します。

サーバーの初期化時にジョブを起動する正しい方法はどれですか? あなたがとる別のアプローチはありますか？

私は Ruby 2.2.0 と Rails 4.2.0 を使用する webdev 初心者です。

私はActiveJobメールを送信するために使用しています：

使用deliver_now方法:

請求書_controller.rb

請求書_メーラー.rb

view_contextここで、コントローラーからメーラーに を送信していることに注意してください。メーラーは、再びそれをInvoicePdfクラスに渡して請求書を生成します。

結果:メールは正しく送信されました

使用deliver_later方法:

請求書_controller.rb

結果: ActiveJob::SerializationError in Members::InvoicesController#send_invoice Unsupported argument type: view_context。

の内側からロードするか、またはのview_context内側に を挿入する方法は?InvoicePdfInvoicePdfInvoiceMailer

編集：これはInvoicePdfがどのように見えるかです

請求書_pdf.rb

Active_job と sidekiq を使用してメールを非同期で送信しています。しかし、メール送信を実行すると current_locale が失われます。すべてのリクエストの URL パターンによって I18n.locale を設定しました。

以前は、current_locale を保存するためのプラグインを提供する Sidekiq を 使用し、送信時に使用していました。

しかし、私は現在Rails 4.2.1にアップグレードしています.ActiveJobはこのような解決策を提供していないようです.

何か考えはありますか？

私が知っている 1 つの方法は、 current_locale を引数としてメーラーに渡し、次に I18n.with_locale {... } を使用することですが、これは多くの場所を変更します...

アプリケーションは n 秒ごとに、トレーディング システム内の証券のライブ価格を提供するリモート JSON ファイルを要求しています。JSON には、必要なデータを含むmarketdataブロック ( ) と、現在のデータを含むブロックdataversion(versionおよびseqnum) があります。

現在、 ActionController::Live(EventSourceクライアント側で) を使用して、更新されたデータをブラウザーにプッシュしています。すべてのアクションは 1 つのメソッド内で実行されます。

1. SSE接続を開く;
2. 動的 URL の形成;
3. リモート サーバーから新しいデータを取得する。
4. 値の比較/再割り当てseqnum;
5. 必要に応じてデータベースを更新します。

したがって、私の目標は、データベースのプルと更新 ( ActiveJob) と、更新された値のブラウザーへのプッシュ( ) を分離することActionController::Liveです。これを達成するには、次のものが必要です。

• サーバー側のどこかに保存し、コントローラーseqnumとversionバックグラウンドジョブの間で共有します。
• または、フィールドの最新の変更についてデータベースを監視しますupdated_at。

だから基本的に私は2つの質問があります：

• 上記の 2 つのオプションのうち、どちらがより効率的ですか?他に良い方法はありますか?
• （最初のものに存在する権利がある場合）このアプローチをどのように実装しますか？

ActiveJob を作成し、実行ブロックが ActiveRecord オブジェクトの単一インスタンスであると予想される引数を受け入れる場合、ジョブがキューに入れられると問題のオブジェクトが存在しますが、実際の実行時にはそのオブジェクトは存在しなくなります。 、仕事は明らかに失敗しますよね？

したがって、ActiveJob が元の ActiveRecord オブジェクトをインスタンス化できないために失敗したこのジョブは、失敗し続けます。失敗のループを止めるために、ジョブに対してどのような更新を行うことができますか。へのフックを検討しましbefore_performたが、まだ道が見えていません。

当面の問題を解決する以外に、私がここで学んだもう 1 つのことはwidget_id、ActiveRecord オブジェクトではなく整数を渡す方がよいということです。その後、実行ブロック内から問題のウィジェットがまだ存在するかどうかを確認できたはずです。

SSE を使用して、Stripe サブスクリプションの詳細を表示するページを更新する予定です。

基本的には次のようになります。

1. サブスクリプションの詳細ページを読み込む
2. ActiveJob ジョブを使用して、Stripe API からサブスクリプションの詳細をリクエストします
3. タスクが終了したら、SSE を使用して、そのクライアント (サブスクリプション ページ) にページを更新することを通知します。
4. JavaScriptを介して更新を実行します

ステップ 1 と 2 と 4 のコードをセットアップしましたが、#3 の実行方法がわかりません。

私が目にする問題の 1 つは、ActiveJob には実際に after_perform コールバックがありますが、Rails に組み込まれた SSE はコントローラー (ActionController::Live::SSE) に存在することです。after_perform コールバックで SSE コントローラーで何かを行う方法がわかりません。

グーグル、私は潜在的な解決策を見つけました：

1. Sidekiq プラグインを使用して、タスクの完了を通知できるようにします。
2. PostgreSQL NOTIFY / LISTEN を使用する

SSEコントローラーがタスクが実行されたことをどのように知るかなど、その後どうなるかはわかりません。

その他の注意事項:

バックグラウンド処理に Brandon Hilkert の Sucker Punch gem を使用しています: https://github.com/brandonhilkert/sucker_punch

また、PostgreSQL 専用のコードに固執することを強制しないソリューションも必要です。ただし、それが機能する唯一のアプローチであるかどうかは気にしません。

また、sucker_punch で実行できず、Sidekiq に切り替える必要がある場合に備えて、Sidekiq ソリューションも投稿しました。

何か案は？

ありがとう！

Resque.queues jsonを使用してすべてのキュー データを取得できない理由は次のとおりです。

名前のみ:

遅延ペーパークリップと sidekiq を設定しましたが、写真のアップロードを再試行すると、ログの出力は次のようになります。

これは、Activejob がジョブを実行していることを示しています..sidekiq コンソールの反対側では、ログアウトされているものは何も表示されません..何かが足りないのではないかと思っています。