問題タブ [node-celery]

node-celeryを使用すると、ノードが Celery ジョブをタスク キューにプッシュできるようになります。ノードをCeleryワーカーにしてキューを消費させるにはどうすればよいですか?

次のように、セロリ タスク スクリプトを作成しました。

次のキューとルートを定義しました。

次のようにセロリワーカーを開始します。

セロリシェルからAddTask.get(1,3)を正常に実行できます。

次に、node-celeryモジュールを使用して、次の node.js スクリプトを実行しました。

スクリプトは次のエラーを返します。

スクリプトは正しいx: & y:パラメータをセロリ ワーカーに渡しますが、self引数は適切に処理されません。なぜこれが起こっているのか誰にもわかりますか？

上記のnode.jsスクリプトを、メンバー関数を持つクラスの代わりに一連の関数を定義するタスク スクリプトで正常にテストしました。

上記のケースでは、 celery.contrib.methodsモジュールが失敗していると推測しています。誰かがこの問題について何か洞察を持っていますか?

非同期タスクを実行するには、Node JS で Celery に相当するものを提案してください。以下で検索できました。

1. （後）
2. くえ（くえ）、
3. コーヒーレスク (コーヒーレスク)
4. クローン (クロン)
5. node-celery(ノードセロリ)

バックグラウンドで手動スレッドと自動スレッドの両方を実行し、MongoDB とやり取りしました。

node-celery は Mongo DB ではなく redis DB を使用しています。それを変更する方法はありますか?node-celeryをインストールすると、redisが依存関係としてインストールされました。

私はセロリが初めてです, ガイドしてください.ありがとう.

ブロードキャスト タスクを作成しようとしましたが、呼び出しごとに 1 人のワーカーしか受信しません。助けてくれませんか？（私はrabbitmqとnode-celeryを使用しています）

次の構成もテストしましたが、機能しません。

編集

-Qブロードキャストを追加してワーカーの実行方法を変更した後、次のエラーに直面しました：

redis バックエンドで node-celery (v0.2.8) を使用しています。celery.createClient() を呼び出そうとすると、次の結果が得られます。

celery.js の 137 行目に redis.createClient() の呼び出しがあり、返されたオブジェクトに対して duplicate() の呼び出しを試みます。ただし、オブジェクトには「重複」プロパティは含まれません。

私にとって本当に奇妙なのは、redis モジュールが node-celery の依存関係としてリストされていないようで、ローカルにインストールしていないことです。したがって、コードがこの時点に到達するずっと前に例外をスローする必要があるようです。

node-celery レポに関連する問題が見当たらないので、これを説明するのに途方に暮れています。