問題タブ [kue]

Web Dynoは HTTP リクエストを処理できます

Web Dynoがそれらを処理している間、Worker Dynoはそこからジョブを処理できます。

しかし、 Web DynoとWorker Dynoが互いに通信するようにする方法がわかりません。

例えばWeb DynosでHTTPリクエストを受け取りたい

、それをWorker Dynosに送信します

、ジョブを処理し、結果をWeb Dynosに送り返す

、ウェブで結果を表示します。

これはNode.jsで可能ですか? (RabbitMQ や Kue などで)?

Heroku Documentationに例が見つかりませんでした

それとも、すべてのコードをWeb Dynoに実装し、 Web Dynoのみをスケーリングする必要がありますか?

フロー制御にはマングースとキューを使用しています。データベースから取得したオブジェクトを Kue に渡します。ジョブが処理されると、オブジェクトには .save() などの関数がなくなります。

前もって感謝します

node.js アプリケーションで遅延ジョブにkueを使用しています。

redis コマンドを使用して、ジョブの ID を失敗したジョブのリストから非アクティブなジョブのリストに手動で移動することなく、kue の API を使用してジョブを再開する方法を理解するのにいくつか問題があります。

これはkueを使用して可能ですか？

再試行の固定回数を設定したくありません。特定のジョブを再試行したいだけです。

kue に代わる適切に管理された代替案の提案も歓迎します。

バックグラウンド プロセスが指数関数的に増加しているプロジェクトに取り組んでいます。そのため、ノードの適切な優先度のバックグラウンド キューを探しています。

オンラインで探しているときにKueを見つけましたが、これは初めてなので、これが最適なオプションかどうかはわかりません.

私は自分が間違っていることを理解できません。おそらく誰かがそれを指摘することができます。「ジョブ完了」イベントが発生しない理由を突き止めようとしています。

これをノードで実行すると、123 が出力されますが、ジョブが完了したとは言いません。

Kue (https://github.com/LearnBoost/kue) を見ると、同じノード プロセスでジョブを生成して消費できるのか、それとも別のノード プロセスでコンシューマーを起動する必要があるのか​​、少し混乱しています。

HTTP 要求をブロックせずに、CPU を大量に消費するタスク (PDF の生成) をジョブ キューにオフロードする必要があります。

ジョブキューにkueを使用していますが、GUIを使用せずに、まだ残っているジョブの数、失敗したジョブの数などを知りたいのですが、この種の情報を取得するにはどうすればよいですか。

たとえば、ジョブキューの処理を開始してから数分後、これまでに失敗したすべてのジョブのステータスを「非アクティブ」に更新して、ジョブを再開したいと思います。

私がstackoverflowで見つけた唯一の関連する質問はこれでしたが、処理中に特定のイベントを発生させた後、一度に1つのジョブを処理します。特定のステータスを持つデータベース内のすべてのジョブを取得することに関心があるため、私の懸念は異なります。

この質問への答えは、データベース内のすべての完了したジョブを取得するkueライブラリの関数.completeに言及しています。他の可能な仕事のステータスのための同様の機能はありますか？

コードでメモリ リークが発生しています。数時間後、メモリ全体がいっぱいになり、クラッシュします。ここでコードを簡略化しましたが、これがリークしているように見えるかどうかを誰かが知ることができますか? ありがとう。

[1] https://groups.google.com/d/msg/nodejs/ZI6WnDgwwV0/sFm4QKK7ODEJ

私のメイン Node インスタンスは、 Kueに追加する新しいジョブに関する情報を含むオブジェクトである(組み込みの Nodeprocess.send()とを使用して) IPC 経由でメッセージを受け入れるワーカー プロセスを fork します。次に、それらのジョブを処理します。process.on('message'...

私のメイン Node インスタンスは次のように呼び出します。

ワーカー インスタンスは次のように動作します。

ジョブは正常に完了します。

ジョブが完了したときにメイン Node インスタンスでコールバックのような機能を取得するにはどうすればよいですか? ワーカー インスタンスからメイン ノード インスタンスに結果を返すにはどうすればよいですか?