使用node.js创建芹菜工作者

Question

使用node-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 
    }) 
    }) 
})