使用node.js创build一个芹菜工作者

使用node-celery ，我们可以使节点将Celery作业推送到任务队列。 我们如何让节点成为芹菜工作者并使用队列？

Answer 1

对于芹菜如果终点是amqp。 签出Celery.js Github任何节点进程开始作为amqp消费者将正常工作。 对于其他每个self.conf.backend_typetypes，您可以有不同的使用者。 下面的例子仅仅是为了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 }) }) })