Создание работника сельдерея с использованием node.js

Question

Используя node-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 
    }) 
    }) 
})