javascript - node.js を使用して Celery ワーカーを作成する

Question

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

Answer 1

セロリの場合、エンドポイントが amqp の場合。Celery.js Githubをチェックアウトし、amqp コンシューマとして開始されたノード プロセスは正常に動作します。他のすべての self.conf.backend_typeタイプでは、さまざまな消費者を持つことができます。次の例は、amqp のみを対象としています。

その一例。message以下は Celery タスク オブジェクトの可能性があります。

var amqp = require('amqp');
var connection = amqp.createConnection({ host: "localhost", port: 5672 });
connection.on('ready', function () {
  connection.queue("my_celery_queue", function(queue){
    queue.bind('#'); 
    queue.subscribe(function (message) {
      //eat your Celery work here
    })
  })
})