使用node.js创建Celery worker

Question

使用node-celery,我们可以启用节点将Celery作业推送到任务队列.我们如何允许节点成为Celery工作者并使用队列？

Answer 1

对于Celery,如果终点是amqp.Checkout Celery.js Github任何节点进程都启动,因为amqp使用者可以正常工作.对于其他所有 self.conf.backend_type类型,您可以拥有各种消费者.以下示例仅适用于amqp.

一个这样的例子.在message下面可能是芹菜任务对象.

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
    })
  })
})