問題タブ [kue]

kue/node.js を使い始めました。チュートリアルを確認したところ、このコードがありました

したがって、ターミナル ノード test.js からこれを実行すると、3 秒ごとに「job {job id} is done」が出力されます。

今、私はコードを次のように変更しました

newJob 関数と setInterval を削除しました。最初にキューを作成してジョブを保存してから、以下で処理するため、コードが 1 回実行されることを期待していました。しかし、端末からコードを実行しても何も起こらず、出力もありません。

期待した結果が得られないのはなぜですか? この背後にあるロジックは何ですか。説明してください 。前もって感謝します 。

私は現在kue / node.jsで作業しています

https://github.com/Automattic/kue

ジョブを作成して保存すると、データはローカルの redis サーバーに保存されます。

Redis クリ

マシンを再起動して再度確認した後、

だから空です。

これは明らかですが、データを保持したいので、kue のドキュメントを確認しましたが、何も見つかりませんでした。

これを行う方法はありますか。

前もって感謝します 。

js/エクスプレス . 私がやっていることは、いくつかのユーザーの詳細を含む別のサーバーから Express サーバーにリクエストを送信することです。

リクエストの詳細をジョブ キュー (kue) に追加し、ワーカー (クラスター) を使用してジョブを処理し、ユーザーにメールを送信します。そして、リクエストをエクスプレスサーバーに送信するサーバーに応答を送り返したいです。

res.send()リクエストパラメータをキューに追加して処理した後、リクエストとレスポンスの間にリンクがないため、ここでは通常は機能しません。これが私のコードのサンプルです。

app.js

新しい要件があります。 メールを送信する代わりに、メール HTML を作成してリクエスタに送り返す必要があります。

ジョブ キューを使用しなかった場合は、 res.send() を使用できます。でも今はできません。

オブジェクトをジョブ キューに保存することを考えresた後、最近、その応答オブジェクトを使用して同じユーザーに応答を返そうとしました。

このような状況で使用できる解決策はありますか?

どんな助けでも大歓迎です:)

Kueを使用してジョブを作成しています。

すべてのジョブには遅延時間があり、通常は 3 時間です。

ここで、新しいジョブを作成して id を取得するすべての受信リクエストを確認します。

上記のコードからわかるように、ジョブを作成するときに、ジョブ ID をジョブに追加します。

したがって、キュー内の既存のジョブの job_id で着信 ID を確認し、一致する ID が見つかった場合は、その既存のジョブを新しいパラメーターで更新したいと考えています。

したがって、私のジョブキューには毎回一意の job_id があります:)。

出来ますか？私はたくさん検索しましたが、助けが見つかりませんでした。kue JSON APIを確認しました。ただし、ジョブの作成と取得のみが可能で、既存のレコードを更新することはできません。

nodejsアプリでKueを使用してredisキューを実装しています。にメールを追加する API があります。cron ジョブが新しい​​ジョブをリッスンするのは良い習慣ですか、それとも新しいメールが入力されたときにアプリからイベントが発生し、それを処理するために別のアプリからキャッチされる方法はありますか。私は正しいアプローチについて少し混乱しています。jobsemail queueredis email queuenode.jsjobnode.js

Parse Server (heroku でホストされている) でスケジュールされたジョブに kue を使用しようとしています。今index.jsのところ、Kue について見つけたいくつかのチュートリアルに記載されているように、ファイルを次のように変更しました。

アプリが : の行でクラッシュすることがわかりました.use(kue.app)。これが私が得るエラーです:

なぜこれが起こっているのかわかりません。