問題タブ [kue]

Kue を使用して、ジョブ キューを介して CPU を集中的に使用する計算を実行する子プロセスを生成しようとしています。現時点での私のコードは次のようになります。

consumer.js

コードは私がやりたいことをいくらか実行しますが、ジョブが失敗したことを (Kue に) 報告し、生成されたプロセスから stderr を取得するより良い方法はありますか?

いつものように、kue ジョブをセットアップします。

特定の条件で、ジョブが失敗して自動的に再起動されるようにしたい。そのために、プロセッサに次の行があります。

失敗したイベントを次のように変更しようとしました:

ここで提案されているように：Node.js Kue失敗したジョブを再起動する方法

また、 Readmeのように attempts() を追加しようとしました。

これらのことはどれもうまくいきませんでした。ジョブは「失敗」としてマークされ、コンソールには「問題」と表示されますが、「失敗」リスナーで定義されたメッセージが表示されません。

編集

さらに読んだ後、次を使用して、キューレベルで「ジョブが失敗しました」イベントをリッスンしようとしました：

同じ結果で、コンソール ログはありません...Kue 以外の何かのようです。何がイベントを発生させないのでしょうか?

renice要件は単純です。特定の優先度で kue でジョブを作成した後、実行がスケジュールされる前に(POSIX のように) 優先度を変更することは可能ですか?

KUE https://github.com/LearnBoost/kueでスクリプトをキューに入れ、ジョブとして実行することはできますか?

スクリプトのような/usr/bin/myScript.sh -a 10 -b 20 -c 30
私が見たすべての例は、ジョブが Node.js 関数として定義されることを想定しています。

可能であれば、ジョブ名、スクリプト パス、およびスクリプト パラメータを定義するにはどうすればよいですか?

同じタスクで KUE よりも優れた代替手段はありますか。
できれば、UI と小さなメモリ フットプリントを使用します。:)

Heroku での SailJS アプリのスケーリングについて質問があります。

セットアップ:

• SailJS
• Kue (Redis キューイング システム)
• ソケット io (sailsjs) によって接続されたクライアント
• 2 つの dyno (それぞれが SailsJS インスタンスを実行)
• CronJob のようなプロセス

接続された socketio クライアントに送信する必要があるプッシュ メッセージをトリガーする継続的な「cron」プロセスを自律的に実行したいと考えています。これが正しく構成されている場合、ソケット接続がRedisに存在することを認識しています。

nodejs にkueを使用し、ワーカーをトリガーしてタスクを処理します。ワーカーは、接続されたソケット クライアントにプッシュ メッセージを送信できるように、SailsJS インスタンスに配置されます。

しかし、すべての SailsJS インスタンス (dyno) が同じソケットに接続されているわけではないのではないでしょうか? 言い換えれば、すべての SailsJS インスタンスが同じ接続ソケット クライアントを利用できるのでしょうか、それとも dyno1 が接続されたクライアントのセットを持ち、他の dyno が他のクライアントのセットを持っている可能性はありますか??

例えば：

これをどのように解決しますか... :-D?

Kue とそのすべての依存関係をインストールしました。実行中

nodejs testing.js

次のエラーが表示されます

テスト コードは、 kueで使用できるものと同じです。「記述」はkueで定義されていませんか?ここで何が欠けていますか?

一定の間隔 (毎分) でジョブの新しいバッチを作成するプロセスがあり、それらを別のプロセスで処理するために kue に送信したいと考えています。

場合によっては、同じジョブが異なるバッチに含まれる場合があります。

前のバッチで送信されたジョブが、新しいバッチで再度送信されるまでに完了していなかった場合はどうなりますか?

私の理解では、それは新しいジョブとして扱われ、2 回実行されます。

これは正しいですか、これを回避する方法はありますか?

すべてが同じ redis データベースを使用する複数のインスタンス (docker 内の複数のコンテナーなど) を持つアプリで kue を使用する場合、ワーカーを一時停止する場合、すべてのインスタンスでそのワーカーを一時停止する必要がありますか、それとも redis レベルで処理されますか?したがって、あなたのために処理されますか？

https://github.com/Automattic/kue#pause-processing

すべてのワーカーを一時停止させるためにインスタンス間の通信を使用する必要がなかったら素晴らしいことです。

Hapi.js アプリケーションと並行して、Kue ( https://github.com/Automattic/kue )の UI を使用したいと考えています。

Kui UI は Express で構築されています。

Hapi と Express は、heroku dyno のポート 80 でリッスンしています。

どうやってやるの？誰かが私に例を挙げてもらえますか?