node.jsを使用してセルリーワーカーを作成する

Question

node-celeryを使用して、ノードがセレクタジョブをタスクキューにプッシュできるようにすることができます。ノードをセロリの作業者にしてキューを消費させるにはどうすればよいですか？

Answer 1

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

このような例の1つです。以下の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 
    }) 
    }) 
})